Method parse

www/js/ext/socket.js:99–221

(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
                    };
                  });