RLGWebD: rlgwebd.js comparison

comparison rlgwebd.js @ 107:b64e31c5ec31

RLG-Web server: add playing through WebSockets. Games can be played with a WebSocket connection to /play/<game>?key=<loginkey>&w=<cols>&h=<rows>

author	John "Elwin" Edwards <elwin@sdf.org>
date	Sun, 15 Jul 2012 09:04:39 -0700
parents	7d444ba4739e
children	67b393f10c2b

comparison

equal deleted inserted replaced

-:dc1414faee19
+:b64e31c5ec31
 delete sessions[id];
 tslog("Game %s ended.", id);
 gamemux.emit('end', id);
 });
 this.close = function () {
-this.term.kill('SIGHUP');
+if (this.sessid in sessions)
+this.term.kill('SIGHUP');
 };
 }
 TermSession.prototype = new events.EventEmitter();
 function Watcher(session) {
 }));
 conn.sendUTF(JSON.stringify({"t": "d",
 "d": session.framebuf.toString("hex", 0, session.frameoff)}));
 }
+function wsPlay(wsReq, game, lkey, dims) {
+var conn;
+var session;
+/* Listeners on the WebSocket */
+function messageH(message) {
+var parsedMsg = getMsgWS(message);
+if (parsedMsg.t == 'q') {
+session.close();
+}
+else if (parsedMsg.t == 'd') {
+var hexstr = parsedMsg.d.replace(/[^0-9a-f]/gi, "");
+if (hexstr.length % 2 != 0) {
+hexstr = hexstr.slice(0, -1);
+}
+var keybuf = new Buffer(hexstr, "hex");
+session.write(keybuf);
+}
+}
+function closeH() {
+session.close();
+}
+/* These listen on the TermSession. */
+function openH(success, id) {
+if (success) {
+var reply = {"t": "s", "id": id, "w": sessions[id].w, "h":
+sessions[id].h, "p": sessions[id].pname, "g": game};
+conn = wsReq.accept(null, wsReq.origin);
+conn.sendUTF(JSON.stringify(reply));
+conn.on('message', messageH);
+conn.on('close', closeH);
+}
+else {
+wsReq.reject(500, errorcodes[5]);
+tslog("Unable to allocate TTY for %s", game);
+}
+}
+function dataH(chunk) {
+var msg = {};
+msg.t = "d";
+msg.d = chunk.toString("hex");
+conn.sendUTF(JSON.stringify(msg));
+}
+function exitH() {
+if (conn.connected)
+conn.sendUTF(JSON.stringify({"t": "q"}));
+conn.close();
+session.removeListener('open', openH);
+session.removeListener('data', dataH);
+session.removeListener('exit', exitH);
+}
+var handlers = {'open': openH, 'data': dataH, 'exit': exitH};
+session = new TermSession(game, lkey, dims, handlers);
+}
+function wsStart(wsReq) {
+var playmatch = wsReq.resourceURL.pathname.match(/^\/play\/([^\/]*)$/);
+if (!playmatch[1] || !(playmatch[1] in games)) {
+wsReq.reject(404, errorcodes[2]);
+return;
+}
+var gname = playmatch[1];
+if (!allowlogin) {
+wsReq.reject(404, errorcodes[6]);
+return;
+}
+if (!("key" in wsReq.resourceURL.query)) {
+wsReq.reject(404, "No key given.");
+return;
+}
+var lkey = wsReq.resourceURL.query["key"];
+if (!(lkey in logins)) {
+wsReq.reject(404, errorcodes[1]);
+return;
+}
+var pname = logins[lkey].name;
+var dims = [wsReq.resourceURL.query.h, wsReq.resourceURL.query.w];
+function progcallback(err, fname) {
+if (fname) {
+wsReq.reject(404, errorcodes[4]);
+tslog("%s is already playing %s", pname, gname);
+}
+else
+wsPlay(wsReq, gname, lkey, dims);
+};
+checkprogress(pname, games[gname], progcallback, []);
+}
 /* Some functions which check whether a player is currently playing or
 * has a saved game.  Maybe someday they will provide information on
 * the game. */
 function checkprogress(user, game, callback, args) {
 var progressdir = "/dgldir/inprogress-" + game.uname;
 return {};
 }
 if (typeof(jsonobj) != "object")
 return {};
 return jsonobj;
+}
+function getMsgWS(msgObj) {
+if (msgObj.type != "utf8")
+return {};
+return getMsg(msgObj.utf8Data);
 }
 function reaper() {
 var now = new Date();
 function reapcheck(session) {
 if (!(client instanceof Player)) {
 sendError(res, 7, "Watching", true);
 return;
 }
 /* process the keys */
-hexstr = formdata.d.replace(/[^0-9a-f]/gi, "");
+var hexstr = formdata.d.replace(/[^0-9a-f]/gi, "");
 if (hexstr.length % 2 != 0) {
 sendError(res, 2, "incomplete byte", true);
 return;
 }
-keybuf = new Buffer(hexstr, "hex");
+var keybuf = new Buffer(hexstr, "hex");
 client.write(keybuf, formdata.n);
 }
 readFeed(client, res);
 }
 else if (target == "/login") {
 }
 function wsHandler(wsRequest) {
 var watchmatch = wsRequest.resource.match(/^\/watch\/([0-9]*)$/);
+var playmatch = wsRequest.resource.match(/^\/play\//);
 if (watchmatch !== null) {
 if (watchmatch[1] && Number(watchmatch[1]) in sessions) {
 var tsession = sessions[Number(watchmatch[1])];
 var conn = wsRequest.accept(null, wsRequest.origin);
 new wsWatcher(conn, tsession);
 tslog("Game %d is being watched via WebSockets", tsession.sessid);
 }
 else
 wsRequest.reject(404, errorcodes[7]);
 }
-else if (wsRequest.resource == "/status") {
+else if (playmatch !== null) {
+wsStart(wsRequest);
+}
+else if (wsRequest.resourceURL.pathname == "/status") {
 var conn = wsRequest.accept(null, wsRequest.origin);
 var tell = function () {
 getStatus(function (info) {
 info["t"] = "t";
 conn.sendUTF(JSON.stringify(info));