Method parse

www/js/ext/socket.esm.js:98–220

(parser)

    runtime.assignToNamespace(target, this.nameSpace, this.socketName, this.socketObject);
  }
  static parse(parser) {
    if (!parser.matchToken("socket")) return;
    var name = parser.requireElement("dotOrColonPath");
    var qualifiedName = name.evalStatically();
    var nameSpace = qualifiedName.split(".");
    var socketName = nameSpace.pop();
    var promises = {};
    var url = parser.parseURLOrExpression();
    var defaultTimeout = 1e4;
    if (parser.matchToken("with")) {
      parser.requireToken("timeout");
      defaultTimeout = parser.requireElement("expression").evalStatically();
    }
    var jsonMessages = false;
    var messageHandler = null;
    if (parser.matchToken("on")) {
      parser.requireToken("message");
      if (parser.matchToken("as")) {
        if (!parser.matchToken("JSON")) parser.requireToken("json");
        jsonMessages = true;
      }
      messageHandler = parser.requireElement("commandList");
      parser.ensureTerminated(messageHandler);
    }
    var socket = new WebSocket(parseUrl(url.evalStatically()));
    function getProxy(timeout) {
      return new Proxy(
        {},
        {
          get: function(obj, property) {
            if (PROXY_BLACKLIST.includes(property)) {
              return null;
            } else if (property === "noTimeout") {
              return getProxy(-1);
            } else if (property === "timeout") {
              return function(i) {
                return getProxy(parseInt(i));
              };
            } else {
              return function() {
                var uuid = genUUID();
                var args = [];
                for (var i = 0; i < arguments.length; i++) {
                  args.push(arguments[i]);
                }
                var rpcInfo = {
                  iid: uuid,
                  function: property,
                  args
                };
                socket = socket ? socket : new WebSocket(parseUrl(url.evalStatically()));
                socket.send(JSON.stringify(rpcInfo));
                var promise = new Promise(function(resolve, reject) {
                  promises[uuid] = {
                    resolve,
                    reject
                  };
                });