Method parse

src/ext/socket.js:44–187

(parser)

	}

	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 = 10000;
		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: args,
								};
								socket = socket ? socket : new WebSocket(parseUrl(url.evalStatically())); //recreate socket if needed
								socket.send(JSON.stringify(rpcInfo));