annotate rlgwebd @ 195:3bdee6371c3f

Change various filenames. The shell script previously used to launch the daemon is now called "initscript". The script files have had the ".js" extension removed from their names.
author John "Elwin" Edwards
date Thu, 14 Jan 2016 20:52:29 -0500
parents rlgwebd.js@5483d413a45b
children ea28353d620a
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1 #!/usr/bin/env node
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
2
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
3 var http = require('http');
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
4 var net = require('net');
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
5 var url = require('url');
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
6 var path = require('path');
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
7 var fs = require('fs');
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
8 var events = require('events');
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
9 var child_process = require('child_process');
141
1a156a7746a7 RLGWebD: use NODE_PATH to find modules.
John "Elwin" Edwards
parents: 139
diff changeset
10 // Dependencies
1a156a7746a7 RLGWebD: use NODE_PATH to find modules.
John "Elwin" Edwards
parents: 139
diff changeset
11 var posix = require("posix");
1a156a7746a7 RLGWebD: use NODE_PATH to find modules.
John "Elwin" Edwards
parents: 139
diff changeset
12 var pty = require("pty.js");
1a156a7746a7 RLGWebD: use NODE_PATH to find modules.
John "Elwin" Edwards
parents: 139
diff changeset
13 var WebSocketServer = require("websocket").server;
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
14
30
b5570a594266 rlgwebd.js: listen on any address
John "Elwin" Edwards <elwin@sdf.org>
parents: 29
diff changeset
15 /* Configuration variables */
139
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
16 // The first file is NOT in the chroot.
194
5483d413a45b RLGWebD: move the control socket into /var/run.
John "Elwin" Edwards
parents: 191
diff changeset
17 var ctlsocket = "/var/run/rlgwebd.sock";
30
b5570a594266 rlgwebd.js: listen on any address
John "Elwin" Edwards <elwin@sdf.org>
parents: 29
diff changeset
18 var httpPort = 8080;
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
19 var chrootDir = "/var/dgl/";
157
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
20 var dropToUser = "rodney";
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
21 var serveStaticRoot = "/var/www/"; // inside the chroot
30
b5570a594266 rlgwebd.js: listen on any address
John "Elwin" Edwards <elwin@sdf.org>
parents: 29
diff changeset
22
180
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
23 var clearbufs = [
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
24 new Buffer([27, 91, 72, 27, 91, 50, 74]), // xterm: CSI H CSI 2J
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
25 new Buffer([27, 91, 72, 27, 91, 74]) // screen: CSI H CSI J
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
26 ];
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
27
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
28 /* Data on the games available. */
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
29 var games = {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
30 "rogue3": {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
31 "name": "Rogue V3",
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
32 "uname": "rogue3",
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
33 "suffix": ".r3sav",
180
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
34 "path": "/usr/bin/rogue3"
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
35 },
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
36 "rogue4": {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
37 "name": "Rogue V4",
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
38 "uname": "rogue4",
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
39 "suffix": ".r4sav",
180
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
40 "path": "/usr/bin/rogue4"
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
41 },
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
42 "rogue5": {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
43 "name": "Rogue V5",
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
44 "uname": "rogue5",
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
45 "suffix": ".r5sav",
180
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
46 "path": "/usr/bin/rogue5"
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
47 },
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
48 "srogue": {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
49 "name": "Super-Rogue",
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
50 "uname": "srogue",
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
51 "suffix": ".srsav",
180
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
52 "path": "/usr/bin/srogue"
120
54979d35611a Add support for Advanced Rogue 5.
John "Elwin" Edwards <elwin@sdf.org>
parents: 113
diff changeset
53 },
54979d35611a Add support for Advanced Rogue 5.
John "Elwin" Edwards <elwin@sdf.org>
parents: 113
diff changeset
54 "arogue5": {
54979d35611a Add support for Advanced Rogue 5.
John "Elwin" Edwards <elwin@sdf.org>
parents: 113
diff changeset
55 "name": "Advanced Rogue 5",
54979d35611a Add support for Advanced Rogue 5.
John "Elwin" Edwards <elwin@sdf.org>
parents: 113
diff changeset
56 "uname": "arogue5",
54979d35611a Add support for Advanced Rogue 5.
John "Elwin" Edwards <elwin@sdf.org>
parents: 113
diff changeset
57 "suffix": ".ar5sav",
180
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
58 "path": "/usr/bin/arogue5"
191
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
59 },
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
60 "arogue7": {
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
61 "name": "Advanced Rogue 7",
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
62 "uname": "arogue7",
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
63 "suffix": ".ar7sav",
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
64 "path": "/usr/bin/arogue7"
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
65 },
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
66 "xrogue": {
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
67 "name": "XRogue",
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
68 "uname": "xrogue",
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
69 "suffix": ".xrsav",
9758ca68e7f1 Add support for Advanced Rogue 7 and XRogue.
John "Elwin" Edwards
parents: 190
diff changeset
70 "path": "/usr/bin/xrogue"
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
71 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
72 };
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
73
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
74 /* Global state */
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
75 var logins = {};
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
76 var sessions = {};
156
127f9e256d02 Keep a list of dgamelaunch games and put it in the /status message.
John "Elwin" Edwards
parents: 155
diff changeset
77 var dglgames = {};
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
78 var allowlogin = true;
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
79 var gamemux = new events.EventEmitter();
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
80
184
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
81 /* A base class. TermSession and DglSession inherit from it. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
82 function BaseGame() {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
83 /* Games subclass EventEmitter, though there are few listeners. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
84 events.EventEmitter.call(this);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
85 /* Array of watching WebSockets. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
86 this.watchers = [];
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
87 /* replaybuf holds the output since the last screen clear, so watchers can
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
88 * begin with a complete screen. replaylen is the number of bytes stored. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
89 this.replaybuf = new Buffer(1024);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
90 this.replaylen = 0;
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
91 /* Time of last activity. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
92 this.lasttime = new Date();
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
93 }
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
94 BaseGame.prototype = new events.EventEmitter();
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
95
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
96 BaseGame.prototype.tag = function () {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
97 if (this.pname === undefined || this.gname === undefined)
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
98 return "";
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
99 return this.gname + "/" + this.pname;
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
100 };
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
101
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
102 BaseGame.prototype.framepush = function(chunk) {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
103 /* If this chunk resets the screen, discard what preceded it. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
104 if (isclear(chunk)) {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
105 this.replaybuf = new Buffer(1024);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
106 this.replaylen = 0;
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
107 }
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
108 /* Make sure there's space. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
109 while (this.replaybuf.length < chunk.length + this.replaylen) {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
110 var nbuf = new Buffer(this.replaybuf.length * 2);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
111 this.replaybuf.copy(nbuf, 0, 0, this.replaylen);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
112 this.replaybuf = nbuf;
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
113 if (this.replaybuf.length > 65536) {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
114 tslog("Warning: %s frame buffer at %d bytes", this.tag(),
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
115 this.replaybuf.length);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
116 }
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
117 }
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
118 chunk.copy(this.replaybuf, this.replaylen);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
119 this.replaylen += chunk.length;
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
120 };
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
121
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
122 /* Adds a watcher. */
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
123 BaseGame.prototype.attach = function (wsReq) {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
124 var conn = wsReq.accept(null, wsReq.origin);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
125 conn.sendUTF(JSON.stringify({
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
126 "t": "w", "w": this.w, "h": this.h, "p": this.pname, "g": this.gname
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
127 }));
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
128 conn.sendUTF(JSON.stringify({"t": "d",
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
129 "d": this.replaybuf.toString("hex", 0, this.replaylen)}));
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
130 conn.on('close', this.detach.bind(this, conn));
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
131 this.watchers.push(conn);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
132 };
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
133
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
134 BaseGame.prototype.detach = function (socket) {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
135 var n = this.watchers.indexOf(socket);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
136 if (n >= 0) {
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
137 this.watchers.splice(n, 1);
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
138 tslog("A WebSocket watcher has left game %s", this.tag());
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
139 }
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
140 };
181
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
141
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
142 /* Constructor. A TermSession handles a pty and the game running on it.
169
6f4b7e1b32e8 rlgwebd.js: clean up TermSession parameters.
John "Elwin" Edwards
parents: 168
diff changeset
143 * gname: (String) Name of the game to launch.
6f4b7e1b32e8 rlgwebd.js: clean up TermSession parameters.
John "Elwin" Edwards
parents: 168
diff changeset
144 * pname: (String) The player's name.
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
145 * wsReq: (WebSocketRequest) The request from the client.
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
146 *
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
147 * Events:
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
148 * "data": Data generated by child. Parameters: buf (Buffer)
87
bd2cf6dda28d RLG-Web: use the pty module.
John "Elwin" Edwards <elwin@sdf.org>
parents: 85
diff changeset
149 * "exit": Child terminated. Parameters: none
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
150 */
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
151 function TermSession(gname, pname, wsReq) {
184
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
152 BaseGame.call(this);
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
153 /* Don't launch anything that's not a real game. */
169
6f4b7e1b32e8 rlgwebd.js: clean up TermSession parameters.
John "Elwin" Edwards
parents: 168
diff changeset
154 if (gname in games) {
6f4b7e1b32e8 rlgwebd.js: clean up TermSession parameters.
John "Elwin" Edwards
parents: 168
diff changeset
155 this.game = games[gname];
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
156 this.gname = gname;
32
c75fc4b1d13d rlgwebd.js: add a status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 31
diff changeset
157 }
c75fc4b1d13d rlgwebd.js: add a status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 31
diff changeset
158 else {
168
0ceaca924b4c Remove the TermSession 'open' event.
John "Elwin" Edwards
parents: 167
diff changeset
159 this.failed = true;
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
160 wsReq.reject(404, errorcodes[2], "No such game");
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
161 tslog("Game %s is not available", game);
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
162 return;
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
163 }
169
6f4b7e1b32e8 rlgwebd.js: clean up TermSession parameters.
John "Elwin" Edwards
parents: 168
diff changeset
164 this.pname = pname;
16
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
165 /* Set up the sizes. */
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
166 this.w = Math.floor(Number(wsReq.resourceURL.query.w));
16
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
167 if (!(this.w > 0 && this.w < 256))
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
168 this.w = 80;
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
169 this.h = Math.floor(Number(wsReq.resourceURL.query.h));
16
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
170 if (!(this.h > 0 && this.h < 256))
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
171 this.h = 24;
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
172 /* Environment. */
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
173 var childenv = {};
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
174 for (var key in process.env) {
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
175 childenv[key] = process.env[key];
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
176 }
87
bd2cf6dda28d RLG-Web: use the pty module.
John "Elwin" Edwards <elwin@sdf.org>
parents: 85
diff changeset
177 var args = ["-n", this.pname];
bd2cf6dda28d RLG-Web: use the pty module.
John "Elwin" Edwards <elwin@sdf.org>
parents: 85
diff changeset
178 var spawnopts = {"env": childenv, "cwd": "/", "rows": this.h, "cols": this.w,
bd2cf6dda28d RLG-Web: use the pty module.
John "Elwin" Edwards <elwin@sdf.org>
parents: 85
diff changeset
179 "name": "xterm-256color"};
bd2cf6dda28d RLG-Web: use the pty module.
John "Elwin" Edwards <elwin@sdf.org>
parents: 85
diff changeset
180 this.term = pty.spawn(this.game.path, args, spawnopts);
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
181 tslog("%s playing %s (pid %d)", this.pname, this.gname, this.term.pid);
168
0ceaca924b4c Remove the TermSession 'open' event.
John "Elwin" Edwards
parents: 167
diff changeset
182 this.failed = false;
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
183 sessions[this.gname + "/" + this.pname] = this;
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
184 gamemux.emit('begin', this.gname, this.pname, 'rlg');
40
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
185 /* Set up the lockfile and ttyrec */
160
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
186 var ts = timestamp(this.lasttime);
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
187 var progressdir = path.join("/dgldir/inprogress", this.gname);
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
188 this.lock = path.join(progressdir, this.pname + ":node:" + ts + ".ttyrec");
110
18a81cc0084b RLG-Web: fix lockfile mixup.
John "Elwin" Edwards <elwin@sdf.org>
parents: 109
diff changeset
189 var lmsg = this.term.pid.toString() + '\n' + this.h + '\n' + this.w + '\n';
40
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
190 fs.writeFile(this.lock, lmsg, "utf8");
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
191 var ttyrec = path.join("/dgldir/ttyrec", this.pname, this.gname,
40
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
192 ts + ".ttyrec");
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
193 this.record = fs.createWriteStream(ttyrec, { mode: 0664 });
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
194 /* The player's WebSocket and its handlers. */
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
195 this.playerconn = wsReq.accept(null, wsReq.origin);
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
196 this.playerconn.on('message', this.input_msg.bind(this));
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
197 this.playerconn.on('close', this.close.bind(this));
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
198 /* Send initial data. */
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
199 this.playerconn.sendUTF(JSON.stringify({"t": "s", "w": this.w, "h": this.h,
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
200 "p": this.pname, "g": this.gname}));
181
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
201 /* Begin the ttyrec with some metadata, like dgamelaunch does. */
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
202 var descstr = "\x1b[2J\x1b[1;1H\r\n";
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
203 descstr += "Player: " + this.pname + "\r\nGame: " + this.game.name + "\r\n";
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
204 descstr += "Server: Roguelike Gallery - rlgallery.org\r\n";
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
205 descstr += "Filename: " + ts + ".ttyrec\r\n";
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
206 descstr += "Time: (" + Math.floor(this.lasttime.getTime() / 1000) + ") ";
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
207 descstr += this.lasttime.toUTCString().slice(0, -4) + "\r\n";
926b0780bc44 Print metadata at the beginning of ttyrec files.
John "Elwin" Edwards
parents: 180
diff changeset
208 descstr += "Size: " + this.w + "x" + this.h + "\r\n\x1b[2J";
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
209 this.write_ttyrec(descstr);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
210 this.term.on("data", this.write_ttyrec.bind(this));
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
211 this.term.on("exit", this.destroy.bind(this));
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
212 }
184
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
213 TermSession.prototype = new BaseGame();
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
214
183
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
215 /* Currently this also sends to the player and any watchers. */
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
216 TermSession.prototype.write_ttyrec = function (datastr) {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
217 this.lasttime = new Date();
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
218 var buf = new Buffer(datastr);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
219 var chunk = new Buffer(buf.length + 12);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
220 /* TTYREC headers */
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
221 chunk.writeUInt32LE(Math.floor(this.lasttime.getTime() / 1000), 0);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
222 chunk.writeUInt32LE(1000 * (this.lasttime.getTime() % 1000), 4);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
223 chunk.writeUInt32LE(buf.length, 8);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
224 buf.copy(chunk, 12);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
225 this.record.write(chunk);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
226 this.framepush(buf);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
227 /* Send to the player. */
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
228 var msg = JSON.stringify({"t": "d", "d": buf.toString("hex")});
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
229 this.playerconn.sendUTF(msg);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
230 /* Send to any watchers. */
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
231 for (var i = 0; i < this.watchers.length; i++) {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
232 if (this.watchers[i].connected)
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
233 this.watchers[i].sendUTF(msg);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
234 }
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
235 this.emit('data', buf);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
236 };
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
237
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
238 /* For writing to the subprocess's stdin. */
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
239 TermSession.prototype.write = function (data) {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
240 this.term.write(data);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
241 };
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
242
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
243 TermSession.prototype.input_msg = function (message) {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
244 var parsedMsg = getMsgWS(message);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
245 if (parsedMsg.t == 'q') {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
246 this.close();
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
247 }
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
248 else if (parsedMsg.t == 'd') {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
249 var hexstr = parsedMsg.d.replace(/[^0-9a-f]/gi, "");
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
250 if (hexstr.length % 2 != 0) {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
251 hexstr = hexstr.slice(0, -1);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
252 }
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
253 var keybuf = new Buffer(hexstr, "hex");
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
254 this.write(keybuf);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
255 }
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
256 };
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
257
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
258 /* Teardown. */
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
259 TermSession.prototype.close = function () {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
260 if (this.tag() in sessions)
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
261 this.term.kill('SIGHUP');
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
262 };
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
263
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
264 TermSession.prototype.destroy = function () {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
265 var tag = this.tag();
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
266 fs.unlink(this.lock);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
267 this.record.end();
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
268 var watchsocks = this.watchers;
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
269 this.watchers = [];
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
270 for (var i = 0; i < watchsocks.length; i++) {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
271 if (watchsocks[i].connected)
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
272 watchsocks[i].close();
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
273 }
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
274 if (this.playerconn.connected) {
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
275 this.playerconn.sendUTF(JSON.stringify({"t": "q"}));
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
276 this.playerconn.close();
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
277 }
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
278 this.emit('exit');
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
279 gamemux.emit('end', this.gname, this.pname);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
280 delete sessions[tag];
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
281 tslog("Game %s ended.", tag);
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
282 };
db2f5ab112e9 Move all TermSession methods into the prototype.
John "Elwin" Edwards
parents: 182
diff changeset
283
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
284 function DglSession(filename) {
184
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
285 BaseGame.call(this);
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
286 var pathcoms = filename.split('/');
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
287 this.gname = pathcoms[pathcoms.length - 2];
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
288 if (!(this.gname in games)) {
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
289 this.emit('open', false);
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
290 return;
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
291 }
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
292 var basename = pathcoms[pathcoms.length - 1];
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
293 var firstsep = basename.indexOf(':');
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
294 this.pname = basename.slice(0, firstsep);
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
295 var fname = basename.slice(firstsep + 1);
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
296 this.ttyrec = path.join("/dgldir/ttyrec", this.pname, this.gname, fname);
165
59e62710cbb5 rlgwebd.js: prevent races when reading ttyrecs.
John "Elwin" Edwards
parents: 164
diff changeset
297 /* Flag to prevent multiple handlers from reading simultaneously and
59e62710cbb5 rlgwebd.js: prevent races when reading ttyrecs.
John "Elwin" Edwards
parents: 164
diff changeset
298 * getting into a race. */
59e62710cbb5 rlgwebd.js: prevent races when reading ttyrecs.
John "Elwin" Edwards
parents: 164
diff changeset
299 this.reading = false;
174
dc12ba30d559 Fix further crashes when following dgamelaunch games.
John "Elwin" Edwards
parents: 171
diff changeset
300 this.rpos = 0;
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
301 fs.readFile(filename, {encoding: "utf8"}, (function (err, data) {
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
302 if (err) {
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
303 this.emit('open', false);
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
304 return;
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
305 }
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
306 var lines = data.split('\n');
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
307 this.h = Number(lines[1]);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
308 this.w = Number(lines[2]);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
309 fs.open(this.ttyrec, "r", (function (err, fd) {
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
310 if (err) {
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
311 this.emit('open', false);
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
312 }
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
313 else {
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
314 this.fd = fd;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
315 this.emit('open', true);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
316 tslog("DGL %s: open", this.tag());
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
317 gamemux.emit('begin', this.gname, this.pname, 'dgl');
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
318 this.startchunk();
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
319 this.recwatcher = fs.watch(this.ttyrec, this.notifier.bind(this));
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
320 }
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
321 }).bind(this));
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
322 }).bind(this));
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
323 }
184
ecedc6f7e4ac Move TermSession and DglSession common code into a base class.
John "Elwin" Edwards
parents: 183
diff changeset
324 DglSession.prototype = new BaseGame();
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
325
185
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
326 /* 3 functions to get data from the ttyrec file. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
327 DglSession.prototype.startchunk = function () {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
328 if (this.reading)
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
329 return;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
330 this.reading = true;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
331 var header = new Buffer(12);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
332 fs.read(this.fd, header, 0, 12, this.rpos, this.datachunk.bind(this));
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
333 };
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
334
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
335 DglSession.prototype.datachunk = function (err, n, buf) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
336 /* Stop recursion if end of file has been reached. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
337 if (err || n < 12) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
338 if (!err && n > 0) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
339 tslog("DGL %s: expected 12-byte header, got %d", this.tag(), n);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
340 }
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
341 this.reading = false;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
342 return;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
343 }
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
344 this.rpos += 12;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
345 /* Update timestamp, to within 1 second. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
346 this.lasttime = new Date(1000 * buf.readUInt32LE(0));
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
347 var datalen = buf.readUInt32LE(8);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
348 if (datalen > 16384) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
349 // Something is probably wrong...
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
350 tslog("DGL %s: looking for %d bytes", this.tag(), datalen);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
351 }
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
352 var databuf = new Buffer(datalen);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
353 fs.read(this.fd, databuf, 0, datalen, this.rpos, this.handledata.bind(this));
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
354 };
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
355
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
356 DglSession.prototype.handledata = function (err, n, buf) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
357 if (err || n < buf.length) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
358 /* Next time, read the header again. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
359 this.rpos -= 12;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
360 this.reading = false;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
361 tslog("DGL %s: expected %d bytes, got %d", this.tag(), buf.length, n);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
362 return;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
363 }
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
364 this.rpos += n;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
365 this.reading = false;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
366 /* Process the data */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
367 this.framepush(buf);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
368 var wmsg = JSON.stringify({"t": "d", "d": buf.toString("hex")});
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
369 for (var i = 0; i < this.watchers.length; i++) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
370 if (this.watchers[i].connected)
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
371 this.watchers[i].sendUTF(wmsg);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
372 }
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
373 this.emit("data", buf);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
374 /* Recurse. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
375 this.startchunk();
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
376 };
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
377
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
378 /* Handles events from the ttyrec file watcher. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
379 DglSession.prototype.notifier = function (ev, finame) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
380 if (ev == "change")
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
381 this.startchunk();
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
382 /* If another kind of event appears, something strange happened. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
383 };
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
384
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
385 DglSession.prototype.close = function () {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
386 this.recwatcher.close();
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
387 /* Ensure all data is handled before quitting. */
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
388 this.startchunk();
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
389 var connlist = this.watchers;
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
390 this.watchers = [];
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
391 for (var i = 0; i < connlist.length; i++) {
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
392 if (connlist[i].connected)
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
393 connlist[i].close();
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
394 }
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
395 fs.close(this.fd);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
396 this.emit("close");
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
397 gamemux.emit('end', this.gname, this.pname);
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
398 tslog("DGL %s: closed", this.tag());
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
399 };
bbfda4a4eb7f Finish moving DglSession methods into the prototype.
John "Elwin" Edwards
parents: 184
diff changeset
400
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
401 function wsStartGame(wsReq) {
107
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
402 var playmatch = wsReq.resourceURL.pathname.match(/^\/play\/([^\/]*)$/);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
403 if (!playmatch[1] || !(playmatch[1] in games)) {
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
404 wsReq.reject(404, errorcodes[2]);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
405 return;
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
406 }
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
407 var gname = playmatch[1];
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
408 if (!allowlogin) {
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
409 wsReq.reject(404, errorcodes[6]);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
410 return;
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
411 }
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
412 if (!("key" in wsReq.resourceURL.query)) {
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
413 wsReq.reject(404, "No key given.");
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
414 return;
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
415 }
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
416 var lkey = wsReq.resourceURL.query["key"];
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
417 if (!(lkey in logins)) {
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
418 wsReq.reject(404, errorcodes[1]);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
419 return;
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
420 }
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
421 var pname = logins[lkey].name;
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
422 function progcallback(err, fname) {
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
423 if (fname) {
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
424 wsReq.reject(404, errorcodes[4]);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
425 tslog("%s is already playing %s", pname, gname);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
426 }
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
427 else {
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
428 new TermSession(gname, pname, wsReq);
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
429 }
107
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
430 };
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
431 checkprogress(pname, games[gname], progcallback, []);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
432 }
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
433
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
434 /* Some functions which check whether a player is currently playing or
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
435 * has a saved game. Maybe someday they will provide information on
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
436 * the game. */
40
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
437 function checkprogress(user, game, callback, args) {
142
c4304f08e35b RLGWebD: inprogress dirs have moved
John "Elwin" Edwards
parents: 141
diff changeset
438 var progressdir = path.join("/dgldir/inprogress", game.uname);
40
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
439 fs.readdir(progressdir, function(err, files) {
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
440 if (err) {
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
441 args.unshift(err, null);
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
442 callback.apply(null, args);
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
443 return;
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
444 }
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
445 var fre = RegExp("^" + user + ":");
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
446 for (var i = 0; i < files.length; i++) {
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
447 if (files[i].match(fre)) {
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
448 args.unshift(null, files[i]);
40
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
449 callback.apply(null, args);
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
450 return;
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
451 }
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
452 }
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
453 args.unshift(null, false);
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
454 callback.apply(null, args);
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
455 });
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
456 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
457
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
458 function checksaved(user, game, callback, args) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
459 var savedirc = game.uname + "save";
157
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
460 var basename = String(pwent.uid) + "-" + user + game.suffix;
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
461 var savefile = path.join("/var/games/roguelike", savedirc, basename);
81
e4773ac5d4d5 Switch to node v0.8.
John "Elwin" Edwards <elwin@sdf.org>
parents: 66
diff changeset
462 fs.exists(savefile, function (exist) {
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
463 args.unshift(exist);
40
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
464 callback.apply(null, args);
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
465 });
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
466 }
f7116eb3f791 rlgwebd.js: refactor some game-starting code.
John "Elwin" Edwards <elwin@sdf.org>
parents: 39
diff changeset
467
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
468 function playerstatus(user, callback) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
469 var sdata = {};
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
470 function finishp() {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
471 for (var gname in games) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
472 if (!(gname in sdata))
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
473 return;
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
474 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
475 callback(sdata);
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
476 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
477 function regsaved(exists, game) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
478 if (exists)
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
479 sdata[game.uname] = "s";
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
480 else
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
481 sdata[game.uname] = "0";
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
482 finishp();
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
483 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
484 function regactive(err, filename, game) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
485 if (!err && filename) {
88
d644e7d46852 RLG-Web: make /pstatus/* differentiate between dgl and RLG-Web games.
John "Elwin" Edwards <elwin@sdf.org>
parents: 87
diff changeset
486 if (filename.match(/^[^:]*:node:/))
d644e7d46852 RLG-Web: make /pstatus/* differentiate between dgl and RLG-Web games.
John "Elwin" Edwards <elwin@sdf.org>
parents: 87
diff changeset
487 sdata[game.uname] = "p";
d644e7d46852 RLG-Web: make /pstatus/* differentiate between dgl and RLG-Web games.
John "Elwin" Edwards <elwin@sdf.org>
parents: 87
diff changeset
488 else
d644e7d46852 RLG-Web: make /pstatus/* differentiate between dgl and RLG-Web games.
John "Elwin" Edwards <elwin@sdf.org>
parents: 87
diff changeset
489 sdata[game.uname] = "d";
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
490 finishp();
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
491 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
492 else
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
493 checksaved(user, game, regsaved, [game]);
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
494 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
495 for (var gname in games) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
496 checkprogress(user, games[gname], regactive, [games[gname]]);
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
497 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
498 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
499
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
500 /* A few utility functions */
160
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
501 function timestamp(dd) {
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
502 if (!(dd instanceof Date)) {
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
503 dd = new Date();
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
504 }
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
505 sd = dd.toISOString();
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
506 sd = sd.slice(0, sd.indexOf("."));
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
507 return sd.replace("T", ".");
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
508 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
509
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
510 function randkey(words) {
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
511 if (!words || !(words > 0))
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
512 words = 1;
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
513 function rand32() {
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
514 rnum = Math.floor(Math.random() * 65536 * 65536);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
515 hexstr = rnum.toString(16);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
516 while (hexstr.length < 8)
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
517 hexstr = "0" + hexstr;
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
518 return hexstr;
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
519 }
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
520 var key = "";
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
521 for (var i = 0; i < words; i++)
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
522 key += rand32();
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
523 return key;
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
524 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
525
60
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
526 /* Compares two buffers, returns true for equality up to index n */
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
527 function bufncmp(buf1, buf2, n) {
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
528 if (!Buffer.isBuffer(buf1) || !Buffer.isBuffer(buf2))
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
529 return false;
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
530 for (var i = 0; i < n; i++) {
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
531 if (i == buf1.length && i == buf2.length)
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
532 return true;
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
533 if (i == buf1.length || i == buf2.length)
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
534 return false;
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
535 if (buf1[i] != buf2[i])
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
536 return false;
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
537 }
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
538 return true;
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
539 }
31bb3cf4f25f Make sure watchers start with completely drawn screens.
John "Elwin" Edwards <elwin@sdf.org>
parents: 55
diff changeset
540
180
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
541 function isclear(buf) {
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
542 for (var i = 0; i < clearbufs.length; i++) {
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
543 if (bufncmp(buf, clearbufs[i], clearbufs[i].length))
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
544 return true;
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
545 }
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
546 return false;
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
547 }
85fde763c7ed Improve the clear-command recognition.
John "Elwin" Edwards
parents: 176
diff changeset
548
26
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
549 function tslog() {
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
550 arguments[0] = new Date().toISOString() + ": " + String(arguments[0]);
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
551 console.log.apply(console, arguments);
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
552 }
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
553
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
554 /* Returns a list of the cookies in the request, obviously. */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
555 function getCookies(req) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
556 cookies = [];
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
557 if ("cookie" in req.headers) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
558 cookstrs = req.headers["cookie"].split("; ");
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
559 for (var i = 0; i < cookstrs.length; i++) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
560 eqsign = cookstrs[i].indexOf("=");
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
561 if (eqsign > 0) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
562 name = cookstrs[i].slice(0, eqsign).toLowerCase();
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
563 val = cookstrs[i].slice(eqsign + 1);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
564 cookies[name] = val;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
565 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
566 else if (eqsign < 0)
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
567 cookies[cookstrs[i]] = null;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
568 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
569 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
570 return cookies;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
571 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
572
16
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
573 function getMsg(posttext) {
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
574 var jsonobj;
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
575 if (!posttext)
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
576 return {};
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
577 try {
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
578 jsonobj = JSON.parse(posttext);
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
579 }
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
580 catch (e) {
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
581 if (e instanceof SyntaxError)
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
582 return {};
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
583 }
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
584 if (typeof(jsonobj) != "object")
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
585 return {};
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
586 return jsonobj;
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
587 }
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
588
107
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
589 function getMsgWS(msgObj) {
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
590 if (msgObj.type != "utf8")
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
591 return {};
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
592 return getMsg(msgObj.utf8Data);
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
593 }
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
594
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
595 function login(req, res, formdata) {
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
596 if (!allowlogin) {
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
597 sendError(res, 6, null, false);
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
598 return;
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
599 }
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
600 if (!("name" in formdata)) {
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
601 sendError(res, 2, "Username not given.", false);
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
602 return;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
603 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
604 else if (!("pw" in formdata)) {
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
605 sendError(res, 2, "Password not given.", false);
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
606 return;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
607 }
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
608 var username = String(formdata["name"]);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
609 var password = String(formdata["pw"]);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
610 function checkit(code, signal) {
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
611 /* Checks the exit status, see sqlickrypt.c for details. */
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
612 if (code != 0) {
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
613 sendError(res, 3);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
614 if (code == 1)
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
615 tslog("Password check failed for user %s", username);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
616 else if (code == 2)
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
617 tslog("Attempted login by nonexistent user %s", username);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
618 else
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
619 tslog("Login failed: sqlickrypt error %d", code);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
620 return;
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
621 }
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
622 var lkey = randkey(2);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
623 while (lkey in logins)
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
624 lkey = randkey(2);
160
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
625 logins[lkey] = {"name": username, "ts": new Date()};
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
626 res.writeHead(200, {'Content-Type': 'application/json'});
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
627 var reply = {"t": "l", "k": lkey, "u": username};
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
628 res.write(JSON.stringify(reply));
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
629 res.end();
190
11b7baed2e21 Stop printing credentials in the logfile.
John "Elwin" Edwards
parents: 185
diff changeset
630 tslog("%s has logged in", username);
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
631 return;
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
632 }
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
633 /* Launch the sqlickrypt utility to check the password. */
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
634 var pwchecker = child_process.spawn("/bin/sqlickrypt", ["check"]);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
635 pwchecker.on("exit", checkit);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
636 pwchecker.stdin.end(username + '\n' + password + '\n', "utf8");
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
637 return;
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
638 }
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
639
20
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
640 /* Sets things up for a new user, like dgamelaunch's commands[register] */
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
641 function regsetup(username) {
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
642 function regsetup_l2(err) {
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
643 for (var g in games) {
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
644 fs.mkdir(path.join("/dgldir/ttyrec", username, games[g].uname), 0755);
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
645 }
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
646 }
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
647 fs.mkdir(path.join("/dgldir/userdata", username), 0755);
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
648 fs.mkdir(path.join("/dgldir/ttyrec/", username), 0755, regsetup_l2);
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
649 }
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
650
19
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
651 function register(req, res, formdata) {
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
652 var uname, passwd, email;
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
653 if (typeof (formdata.name) != "string" || formdata.name === "") {
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
654 sendError(res, 2, "No name given.");
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
655 return;
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
656 }
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
657 else
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
658 uname = formdata["name"];
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
659 if (typeof (formdata.pw) != "string" || formdata.pw === "") {
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
660 sendError(res, 2, "No password given.");
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
661 return;
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
662 }
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
663 else
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
664 passwd = formdata["pw"];
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
665 if (typeof (formdata.email) != "string" || formdata.email === "") {
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
666 /* E-mail is optional */
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
667 email = "nobody@nowhere.not";
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
668 }
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
669 else
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
670 email = formdata["email"];
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
671 function checkreg(code, signal) {
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
672 if (code === 0) {
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
673 var lkey = randkey(2);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
674 while (lkey in logins)
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
675 lkey = randkey(2);
160
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
676 logins[lkey] = {"name": uname, "ts": new Date()};
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
677 var reply = {"t": "r", "k": lkey, "u": uname};
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
678 res.writeHead(200, {'Content-Type': 'application/json'});
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
679 res.write(JSON.stringify(reply));
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
680 res.end();
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
681 tslog("Added new user: %s", uname);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
682 regsetup(uname);
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
683 }
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
684 else if (code == 4) {
19
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
685 sendError(res, 2, "Invalid characters in name or email.");
26
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
686 tslog("Attempted registration: %s %s", uname, email);
20
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
687 }
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
688 else if (code == 1) {
19
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
689 sendError(res, 2, "Username " + uname + " is already being used.");
26
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
690 tslog("Attempted duplicate registration: %s", uname);
20
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
691 }
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
692 else {
19
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
693 sendError(res, 0, null);
26
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
694 tslog("sqlickrypt register failed with code %d", code);
20
5f785e1d5cca RLG-Web: set up user directories on registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 19
diff changeset
695 }
19
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
696 }
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
697 var child_adder = child_process.spawn("/bin/sqlickrypt", ["register"]);
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
698 child_adder.on("exit", checkreg);
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
699 child_adder.stdin.end(uname + '\n' + passwd + '\n' + email + '\n', "utf8");
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
700 return;
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
701 }
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
702
111
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
703 /* Stops a running game if the request has the proper key. */
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
704 function stopgame(res, formdata) {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
705 if (!("key" in formdata) || !(formdata["key"] in logins)) {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
706 sendError(res, 1);
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
707 return;
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
708 }
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
709 var pname = logins[formdata["key"]].name;
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
710 if (!("g" in formdata) || !(formdata["g"] in games)) {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
711 sendError(res, 2, "No such game.");
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
712 return;
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
713 }
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
714 var gname = formdata["g"];
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
715 function checkback(err, fname) {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
716 if (!fname) {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
717 sendError(res, 7);
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
718 return;
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
719 }
142
c4304f08e35b RLGWebD: inprogress dirs have moved
John "Elwin" Edwards
parents: 141
diff changeset
720 var fullfile = path.join("/dgldir/inprogress", gname, fname);
111
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
721 fs.readFile(fullfile, "utf8", function(err, fdata) {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
722 if (err) {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
723 sendError(res, 7);
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
724 return;
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
725 }
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
726 var pid = parseInt(fdata.split('\n')[0], 10);
139
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
727 try {
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
728 process.kill(pid, 'SIGHUP');
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
729 }
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
730 catch (err) {
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
731 /* If the PID is invalid, the lockfile is stale. */
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
732 if (err.code == "ESRCH") {
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
733 var nodere = RegExp("^" + pname + ":node:");
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
734 if (fname.match(nodere)) {
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
735 fs.unlink(fullfile);
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
736 }
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
737 }
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
738 }
111
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
739 /* The response doesn't mean that the game is gone. The only way
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
740 * to make sure a dgamelaunch-supervised game is over would be to
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
741 * poll fname until it disappears. */
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
742 res.writeHead(200, {'Content-Type': 'application/json'});
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
743 res.write(JSON.stringify({"t": "q"}));
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
744 res.end();
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
745 });
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
746 }
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
747 checkprogress(pname, games[gname], checkback, []);
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
748 }
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
749
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
750 function startProgressWatcher() {
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
751 var watchdirs = [];
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
752 for (var gname in games) {
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
753 watchdirs.push(path.join("/dgldir/inprogress", gname));
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
754 }
167
fba1b34e7554 Rename watcher to dglwatcher.
John "Elwin" Edwards
parents: 165
diff changeset
755 var subproc = child_process.spawn("/bin/dglwatcher", watchdirs);
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
756 subproc.stdout.setEncoding('utf8');
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
757 subproc.stdout.on('data', function (chunk) {
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
758 var fname = chunk.slice(2, -1);
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
759 var filere = /.*\/([^\/]*)\/([^\/:]*):(node:)?(.*)/;
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
760 var matchresult = fname.match(filere);
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
761 if (!matchresult || matchresult[3])
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
762 return;
156
127f9e256d02 Keep a list of dgamelaunch games and put it in the /status message.
John "Elwin" Edwards
parents: 155
diff changeset
763 var gname = matchresult[1];
127f9e256d02 Keep a list of dgamelaunch games and put it in the /status message.
John "Elwin" Edwards
parents: 155
diff changeset
764 var pname = matchresult[2];
127f9e256d02 Keep a list of dgamelaunch games and put it in the /status message.
John "Elwin" Edwards
parents: 155
diff changeset
765 var tag = gname + "/" + pname;
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
766 if (chunk[0] == "E") {
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
767 tslog("DGL: %s is playing %s: %s", pname, gname, fname)
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
768 dglgames[tag] = new DglSession(fname);
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
769 }
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
770 else if (chunk[0] == "C") {
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
771 tslog("DGL: %s started playing %s: %s", pname, gname, fname)
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
772 dglgames[tag] = new DglSession(fname);
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
773 }
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
774 else if (chunk[0] == "D") {
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
775 tslog("DGL: %s finished playing %s: %s", pname, gname, fname)
164
3a97e4ee50f0 rlgwebd.js: read ttyrecs created by dgamelaunch.
John "Elwin" Edwards
parents: 163
diff changeset
776 dglgames[tag].close();
156
127f9e256d02 Keep a list of dgamelaunch games and put it in the /status message.
John "Elwin" Edwards
parents: 155
diff changeset
777 delete dglgames[tag];
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
778 }
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
779 else {
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
780 tslog("Watcher says: %s", chunk)
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
781 }
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
782 });
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
783 subproc.stdout.resume();
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
784 return subproc;
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
785 }
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
786
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
787 function serveStatic(req, res, fname) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
788 var nname = path.normalize(fname);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
789 if (nname == "" || nname == "/")
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
790 nname = "index.html";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
791 if (nname.match(/\/$/))
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
792 path.join(nname, "index.html"); /* it was a directory */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
793 var realname = path.join(serveStaticRoot, nname);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
794 var extension = path.extname(realname);
81
e4773ac5d4d5 Switch to node v0.8.
John "Elwin" Edwards <elwin@sdf.org>
parents: 66
diff changeset
795 fs.exists(realname, function (exists) {
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
796 var resheaders = {};
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
797 if (!exists || !extension || extension == ".html")
31
7dd6becf9ce9 rlgwebd.js: improve MIME types.
John "Elwin" Edwards <elwin@sdf.org>
parents: 30
diff changeset
798 resheaders["Content-Type"] = "text/html; charset=utf-8";
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
799 else if (extension == ".png")
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
800 resheaders["Content-Type"] = "image/png";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
801 else if (extension == ".css")
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
802 resheaders["Content-Type"] = "text/css";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
803 else if (extension == ".js")
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
804 resheaders["Content-Type"] = "text/javascript";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
805 else if (extension == ".svg")
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
806 resheaders["Content-Type"] = "image/svg+xml";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
807 else
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
808 resheaders["Content-Type"] = "application/octet-stream";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
809 if (exists) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
810 fs.readFile(realname, function (error, data) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
811 if (error) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
812 res.writeHead(500, {});
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
813 res.end();
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
814 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
815 else {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
816 res.writeHead(200, resheaders);
34
57f4b36ef06b rlgwebd.js: handle HTTP HEAD properly.
John "Elwin" Edwards <elwin@sdf.org>
parents: 32
diff changeset
817 if (req.method != 'HEAD')
57f4b36ef06b rlgwebd.js: handle HTTP HEAD properly.
John "Elwin" Edwards <elwin@sdf.org>
parents: 32
diff changeset
818 res.write(data);
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
819 res.end();
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
820 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
821 });
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
822 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
823 else {
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
824 send404(res, nname, req.method == 'HEAD');
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
825 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
826 });
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
827 return;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
828 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
829
160
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
830 /* Currently, this doesn't do anything blocking, but keep the callback */
103
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
831 function getStatus(callback) {
66
57bf0dcd080e Display idle time of games in progress.
John "Elwin" Edwards <elwin@sdf.org>
parents: 64
diff changeset
832 var now = new Date();
103
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
833 var statusinfo = {"s": allowlogin, "g": []};
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
834 for (var tag in sessions) {
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
835 var gamedesc = {"c": "rlg"};
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
836 gamedesc["p"] = sessions[tag].pname;
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
837 gamedesc["g"] = sessions[tag].game.uname;
160
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
838 gamedesc["i"] = now - sessions[tag].lasttime;
175
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
839 gamedesc["w"] = sessions[tag].watchers.length;
103
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
840 statusinfo["g"].push(gamedesc);
32
c75fc4b1d13d rlgwebd.js: add a status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 31
diff changeset
841 }
156
127f9e256d02 Keep a list of dgamelaunch games and put it in the /status message.
John "Elwin" Edwards
parents: 155
diff changeset
842 for (var tag in dglgames) {
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
843 var dglinfo = {"c": "dgl"};
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
844 var slash = tag.search('/');
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
845 dglinfo["g"] = tag.slice(0, slash);
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
846 dglinfo["p"] = tag.slice(slash + 1);
175
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
847 dglinfo["i"] = now - dglgames[tag].lasttime;
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
848 dglinfo["w"] = dglgames[tag].watchers.length;
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
849 statusinfo["g"].push(dglinfo);
156
127f9e256d02 Keep a list of dgamelaunch games and put it in the /status message.
John "Elwin" Edwards
parents: 155
diff changeset
850 }
160
ed837da65e5f RLGWebD: Clean up code related to session timestamps.
John "Elwin" Edwards
parents: 159
diff changeset
851 callback(statusinfo);
32
c75fc4b1d13d rlgwebd.js: add a status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 31
diff changeset
852 }
c75fc4b1d13d rlgwebd.js: add a status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 31
diff changeset
853
103
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
854 function statusmsg(req, res) {
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
855 function respond(info) {
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
856 res.writeHead(200, { "Content-Type": "application/json" });
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
857 if (req.method != 'HEAD')
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
858 res.write(JSON.stringify(info));
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
859 res.end();
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
860 }
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
861 getStatus(respond);
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
862 }
f30495f7ede8 RLG-Web server: refactor statusmsg() to work with WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 102
diff changeset
863
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
864 function pstatusmsg(req, res) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
865 if (req.method == 'HEAD') {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
866 res.writeHead(200, { "Content-Type": "application/json" });
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
867 res.end();
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
868 return;
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
869 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
870 var target = url.parse(req.url).pathname;
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
871 var pmatch = target.match(/^\/pstatus\/(.*)/);
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
872 if (pmatch && pmatch[1])
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
873 var pname = pmatch[1];
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
874 else {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
875 sendError(res, 2, "No name given.");
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
876 return;
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
877 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
878 var reply = {"name": pname};
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
879 playerstatus(pname, function (pdata) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
880 reply["stat"] = pdata;
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
881 res.writeHead(200, { "Content-Type": "application/json" });
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
882 res.write(JSON.stringify(reply));
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
883 res.end();
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
884 });
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
885 }
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
886
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
887 function getuinfo(req, res) {
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
888 var urlobj = url.parse(req.url, true);
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
889 var query = urlobj.query;
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
890 if (!("key" in query) || !(query["key"] in logins)) {
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
891 sendError(res, 1);
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
892 return;
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
893 }
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
894 var match = urlobj.pathname.match(/^\/[^\/]*\/(.*)/);
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
895 if (!match || !match[1]) {
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
896 send404(res, urlobj.pathname, req.method == 'HEAD');
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
897 return;
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
898 }
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
899 var which = match[1];
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
900 var name = logins[query["key"]].name;
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
901 var reply = { "u": name };
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
902 function send() {
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
903 res.writeHead(200, { "Content-Type": "application/json" });
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
904 res.write(JSON.stringify(reply));
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
905 res.end();
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
906 }
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
907 if (which == "pw") {
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
908 /* Don't actually divulge passwords. */
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
909 reply["pw"] = "";
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
910 send();
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
911 }
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
912 else if (which == "email") {
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
913 var address;
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
914 function finish(code, signal) {
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
915 if (code != 0) {
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
916 tslog("sqlickrypt: %d with name %s", code, name);
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
917 sendError(res, 2);
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
918 }
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
919 else {
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
920 reply["email"] = address;
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
921 send();
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
922 }
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
923 }
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
924 var subproc = child_process.spawn("/bin/sqlickrypt", ["getmail"]);
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
925 subproc.stdout.on("data", function (data) {
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
926 address = data.toString().replace(/\n/g, "");
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
927 });
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
928 subproc.on("exit", finish);
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
929 subproc.stdin.end(name + '\n', "utf8");
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
930 }
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
931 else {
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
932 send404(res, urlobj.pathname, req.method == 'HEAD');
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
933 return;
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
934 }
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
935 }
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
936
126
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
937 function setuinfo(req, res, postdata) {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
938 var urlobj = url.parse(req.url, true);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
939 var query = urlobj.query;
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
940 if (!("key" in query) || !(query["key"] in logins)) {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
941 sendError(res, 1);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
942 return;
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
943 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
944 var name = logins[query["key"]].name;
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
945 var match = urlobj.pathname.match(/^\/[^\/]*\/(.*)/);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
946 if (!match || !match[1]) {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
947 send404(res, urlobj.pathname, true);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
948 return;
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
949 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
950 var which = match[1];
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
951 if (!("v" in postdata)) {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
952 sendError(res, 2, "No value provided");
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
953 return;
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
954 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
955 if (which == "email" || which == "pw") {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
956 var args;
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
957 if (which == "email")
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
958 args = ["setmail"];
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
959 else
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
960 args = ["setpw"];
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
961 var child = child_process.execFile("/bin/sqlickrypt", args,
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
962 function (err, stdout, stderr) {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
963 if (err) {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
964 tslog("Could not set %s: sqlickrypt error %d", which, err.code);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
965 sendError(res, 2);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
966 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
967 else {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
968 tslog("User %s has changed %s", name, which);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
969 res.writeHead(200, { "Content-Type": "application/json" });
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
970 res.end(JSON.stringify({"t": "t"}));
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
971 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
972 });
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
973 child.stdin.end(name + "\n" + postdata.v + "\n", "utf8");
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
974 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
975 else {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
976 send404(res, urlobj.pathname, true);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
977 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
978 }
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
979
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
980 var errorcodes = [ "Generic Error", "Not logged in", "Invalid data",
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
981 "Login failed", "Already playing", "Game launch failed",
39
e8ac0e3d2614 RLG-Web: separate logging in and starting a game.
John "Elwin" Edwards <elwin@sdf.org>
parents: 37
diff changeset
982 "Server shutting down", "Game not in progress" ];
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
983
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
984 function sendError(res, ecode, msg, box) {
31
7dd6becf9ce9 rlgwebd.js: improve MIME types.
John "Elwin" Edwards <elwin@sdf.org>
parents: 30
diff changeset
985 res.writeHead(200, { "Content-Type": "application/json" });
16
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
986 var edict = {"t": "E"};
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
987 if (!(ecode < errorcodes.length && ecode > 0))
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
988 ecode = 0;
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
989 edict["c"] = ecode;
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
990 edict["s"] = errorcodes[ecode];
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
991 if (msg)
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
992 edict["s"] += ": " + msg;
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
993 if (box)
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
994 res.write(JSON.stringify([edict]));
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
995 else
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
996 res.write(JSON.stringify(edict));
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
997 res.end();
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
998 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
999
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1000 function send404(res, path, nopage) {
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1001 res.writeHead(404, {"Content-Type": "text/html; charset=utf-8"});
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1002 if (!nopage) {
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1003 res.write("<html><head><title>" + path + "</title></head>\n<body><h1>"
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1004 + path + " Not Found</h1></body></html>\n");
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1005 }
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1006 res.end();
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1007 }
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1008
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1009 function webHandler(req, res) {
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1010 /* default headers for the response */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1011 var resheaders = {'Content-Type': 'text/html'};
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1012 /* The request body will be added to this as it arrives. */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1013 var reqbody = "";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1014 var formdata;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1015
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1016 /* Register a listener to get the body. */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1017 function moredata(chunk) {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1018 reqbody += chunk;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1019 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1020 req.on('data', moredata);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1021
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1022 /* This will send the response once the whole request is here. */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1023 function respond() {
16
ef6127ed6da3 RLGWeb: switch to JSON protocol.
John "Elwin" Edwards <elwin@sdf.org>
parents: 8
diff changeset
1024 formdata = getMsg(reqbody);
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1025 var target = url.parse(req.url).pathname;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1026 /* First figure out if the client is POSTing to a command interface. */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1027 if (req.method == 'POST') {
159
a613380ffdc2 RLGWebD: excise polling.
John "Elwin" Edwards
parents: 158
diff changeset
1028 if (target == "/login") {
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1029 login(req, res, formdata);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1030 }
19
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
1031 else if (target == "/addacct") {
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
1032 register(req, res, formdata);
188bbd857124 RLG-Web: add user registration
John "Elwin" Edwards <elwin@sdf.org>
parents: 17
diff changeset
1033 }
111
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
1034 else if (target == "/quit") {
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
1035 stopgame(res, formdata);
f56fdfeed01a Replace taking over games with forced saves.
John "Elwin" Edwards <elwin@sdf.org>
parents: 110
diff changeset
1036 }
126
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
1037 else if (target.match(/^\/uinfo\//)) {
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
1038 setuinfo(req, res, formdata);
3e3824711791 RLG-Web server: allow changing e-mail and password.
John "Elwin" Edwards <elwin@sdf.org>
parents: 125
diff changeset
1039 }
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1040 else {
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1041 res.writeHead(405, resheaders);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1042 res.end();
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1043 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1044 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1045 else if (req.method == 'GET' || req.method == 'HEAD') {
159
a613380ffdc2 RLGWebD: excise polling.
John "Elwin" Edwards
parents: 158
diff changeset
1046 if (target == '/status') {
32
c75fc4b1d13d rlgwebd.js: add a status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 31
diff changeset
1047 statusmsg(req, res);
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1048 }
125
5ad15380f851 Improve the /uinfo interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 124
diff changeset
1049 else if (target.match(/^\/uinfo\//)) {
124
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
1050 getuinfo(req, res);
fbeb0bf2b51d Add a user information interface at /uinfo.
John "Elwin" Edwards <elwin@sdf.org>
parents: 121
diff changeset
1051 }
42
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
1052 else if (target.match(/^\/pstatus\//)) {
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
1053 pstatusmsg(req, res);
8f6bc0df58fa rlgwebd.js: add a player status interface.
John "Elwin" Edwards <elwin@sdf.org>
parents: 40
diff changeset
1054 }
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1055 else /* Go look for it in the filesystem */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1056 serveStatic(req, res, target);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1057 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1058 else { /* Some other method */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1059 res.writeHead(501, resheaders);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1060 res.write("<html><head><title>501</title></head>\n<body><h1>501 Not Implemented</h1></body></html>\n");
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1061 res.end();
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1062 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1063 return;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1064 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1065 req.on('end', respond);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1066 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1067
100
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1068 function wsHandler(wsRequest) {
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1069 var watchmatch = wsRequest.resource.match(/^\/watch\/(.*)$/);
107
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
1070 var playmatch = wsRequest.resource.match(/^\/play\//);
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1071 if (watchmatch !== null) {
175
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1072 if (watchmatch[1] in sessions) {
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1073 var tsession = sessions[watchmatch[1]];
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1074 tsession.attach(wsRequest);
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1075 tslog("Game %s is being watched via WebSockets", tsession.tag());
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1076 }
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1077 else if (watchmatch[1] in dglgames) {
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1078 var dsession = dglgames[watchmatch[1]];
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1079 dsession.attach(wsRequest);
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1080 tslog("DGL game %s is being watched via WebSockets", dsession.tag());
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1081 }
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1082 else {
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1083 wsRequest.reject(404, errorcodes[7]);
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1084 return;
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1085 }
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1086 }
107
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
1087 else if (playmatch !== null) {
170
50e4c9feeac2 RLGWebD: fix simultaneous player bug.
John "Elwin" Edwards
parents: 169
diff changeset
1088 wsStartGame(wsRequest);
107
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
1089 }
b64e31c5ec31 RLG-Web server: add playing through WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 104
diff changeset
1090 else if (wsRequest.resourceURL.pathname == "/status") {
100
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1091 var conn = wsRequest.accept(null, wsRequest.origin);
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1092 var tell = function () {
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1093 getStatus(function (info) {
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1094 info["t"] = "t";
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1095 conn.sendUTF(JSON.stringify(info));
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1096 });
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1097 }
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
1098 var beginH = function (gname, pname, client) {
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
1099 conn.sendUTF(JSON.stringify({"t": "b", "c": client, "p": pname,
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
1100 "g": gname}));
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1101 };
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1102 var listH = function (list) {
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1103 conn.sendUTF(JSON.stringify(list));
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1104 };
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1105 var endH = function (gname, pname) {
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1106 conn.sendUTF(JSON.stringify({"t": "e", "p": pname, "g": gname}));
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1107 };
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1108 gamemux.on('begin', beginH);
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1109 gamemux.on('list', listH);
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1110 gamemux.on('end', endH);
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1111 conn.on('message', tell);
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1112 conn.on('close', function () {
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1113 gamemux.removeListener('begin', beginH);
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1114 gamemux.removeListener('list', listH);
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1115 gamemux.removeListener('end', endH);
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1116 });
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1117 tell();
100
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1118 }
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1119 else
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1120 wsRequest.reject(404, "No such resource.");
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1121 }
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1122
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1123 /* Only games with low idle time are included. Use getStatus() for the
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1124 * complete list. */
104
7d444ba4739e RLG-Web server: send status events over WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 103
diff changeset
1125 function pushStatus() {
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1126 var now = new Date();
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
1127 var statusinfo = {"t": "p", "s": allowlogin, "g": []};
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1128 for (var tag in sessions) {
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1129 var delta = now - sessions[tag].lasttime;
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1130 if (delta < 60000) {
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
1131 var gamedesc = {"c": "rlg"};
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1132 gamedesc["p"] = sessions[tag].pname;
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1133 gamedesc["g"] = sessions[tag].game.uname;
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1134 gamedesc["i"] = delta;
175
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1135 gamedesc["w"] = sessions[tag].watchers.length;
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1136 statusinfo["g"].push(gamedesc);
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1137 }
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1138 }
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1139 for (var tag in dglgames) {
175
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1140 var delta = now - dglgames[tag].lasttime;
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1141 if (delta < 60000) {
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
1142 var dglinfo = {"c": "dgl"};
175
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1143 var slash = tag.search('/');
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1144 dglinfo["g"] = tag.slice(0, slash);
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1145 dglinfo["p"] = tag.slice(slash + 1);
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1146 dglinfo["i"] = delta;
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1147 dglinfo["w"] = dglgames[tag].watchers.length;
176
bf518a00190b Add client-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 175
diff changeset
1148 statusinfo["g"].push(dglinfo);
175
4dd87508fc96 Add server-side support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 174
diff changeset
1149 }
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1150 }
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1151 gamemux.emit('list', statusinfo);
100
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1152 }
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1153
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1154 function shutdown () {
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1155 httpServer.close();
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1156 httpServer.removeAllListeners('request');
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1157 ctlServer.close();
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1158 tslog("Shutting down...");
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1159 process.exit();
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1160 }
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1161
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1162 function consoleHandler(chunk) {
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1163 var msg = chunk.toString().split('\n')[0];
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1164 if (msg == "quit") {
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1165 allowlogin = false;
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1166 tslog("Disconnecting...");
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1167 for (var tag in sessions) {
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1168 sessions[tag].close();
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1169 }
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
1170 progressWatcher.stdin.end("\n");
55
96815eae4ebe RLG-Web: make multiple watchers possible.
John "Elwin" Edwards <elwin@sdf.org>
parents: 49
diff changeset
1171 setTimeout(shutdown, 2000);
27
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1172 }
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1173 }
83f9a799a374 rlgwebd.js: read commands from the console
John "Elwin" Edwards <elwin@sdf.org>
parents: 26
diff changeset
1174
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1175 process.on("exit", function () {
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1176 for (var tag in sessions) {
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1177 sessions[tag].term.kill('SIGHUP');
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1178 }
26
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
1179 tslog("Quitting...");
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1180 return;
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1181 });
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1182
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1183 /* Initialization STARTS HERE */
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1184 process.env["TERM"] = "xterm-256color";
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1185
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1186 if (process.getuid() != 0) {
26
9b58f8d3ea70 rlgwebd.js: add timestamps to log messages.
John "Elwin" Edwards <elwin@sdf.org>
parents: 23
diff changeset
1187 tslog("Not running as root, cannot chroot.");
0
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1188 process.exit(1);
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1189 }
bd412f63ce0d Put this project under version control, finally.
John "Elwin" Edwards <elwin@sdf.org>
parents:
diff changeset
1190
29
cf9d294bc52f rlgwebd.js: fix reference error
John "Elwin" Edwards <elwin@sdf.org>
parents: 28
diff changeset
1191 var httpServer; // declare here so shutdown() can find it
100
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1192 var wsServer;
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
1193 var progressWatcher;
29
cf9d294bc52f rlgwebd.js: fix reference error
John "Elwin" Edwards <elwin@sdf.org>
parents: 28
diff changeset
1194
157
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1195 var pwent;
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1196 try {
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1197 pwent = posix.getpwnam(dropToUser);
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1198 }
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1199 catch (err) {
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1200 tslog("Could not drop to user %s: user does not exist", dropToUser);
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1201 process.exit(1);
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1202 }
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1203
85
4303d94d87a2 rlgwebd.js: Unlink control socket at startup.
John "Elwin" Edwards <elwin@sdf.org>
parents: 84
diff changeset
1204 /* This could be nonblocking, but nothing else can start yet anyway. */
4303d94d87a2 rlgwebd.js: Unlink control socket at startup.
John "Elwin" Edwards <elwin@sdf.org>
parents: 84
diff changeset
1205 if (fs.existsSync(ctlsocket)) {
4303d94d87a2 rlgwebd.js: Unlink control socket at startup.
John "Elwin" Edwards <elwin@sdf.org>
parents: 84
diff changeset
1206 fs.unlinkSync(ctlsocket);
4303d94d87a2 rlgwebd.js: Unlink control socket at startup.
John "Elwin" Edwards <elwin@sdf.org>
parents: 84
diff changeset
1207 }
4303d94d87a2 rlgwebd.js: Unlink control socket at startup.
John "Elwin" Edwards <elwin@sdf.org>
parents: 84
diff changeset
1208
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1209 /* Open the control socket before chrooting where it can't be found */
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1210 var ctlServer = net.createServer(function (sock) {
158
9961a538c00e rlgwebd.js: get rid of numerical game identifiers.
John "Elwin" Edwards
parents: 157
diff changeset
1211 sock.on('data', consoleHandler);
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1212 });
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1213 ctlServer.listen(ctlsocket, function () {
139
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
1214 /* rlgwebd.js now assumes that it has been started by the rlgwebd shell
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
1215 * script, or some other method that detaches it and sets up stdio. */
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
1216 /* chroot and drop permissions. posix.chroot() does chdir() itself. */
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1217 try {
139
dcd07c1d846a Replace the daemon module with posix.
John "Elwin" Edwards
parents: 132
diff changeset
1218 posix.chroot(chrootDir);
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1219 }
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1220 catch (err) {
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1221 tslog("chroot to %s failed: %s", chrootDir, err);
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1222 process.exit(1);
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1223 }
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1224 try {
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1225 // drop gid first, that requires UID=0
157
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1226 process.setgid(pwent.gid);
e7f809f06c5c Use posix.getpwnam() to look up UID/GID to drop to.
John "Elwin" Edwards
parents: 156
diff changeset
1227 process.setuid(pwent.uid);
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1228 }
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1229 catch (err) {
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1230 tslog("Could not drop permissions: %s", err);
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1231 process.exit(1);
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1232 }
29
cf9d294bc52f rlgwebd.js: fix reference error
John "Elwin" Edwards <elwin@sdf.org>
parents: 28
diff changeset
1233 httpServer = http.createServer(webHandler);
30
b5570a594266 rlgwebd.js: listen on any address
John "Elwin" Edwards <elwin@sdf.org>
parents: 29
diff changeset
1234 httpServer.listen(httpPort);
b5570a594266 rlgwebd.js: listen on any address
John "Elwin" Edwards <elwin@sdf.org>
parents: 29
diff changeset
1235 tslog('rlgwebd running on port %d', httpPort);
100
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1236 wsServer = new WebSocketServer({"httpServer": httpServer});
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1237 wsServer.on("request", wsHandler);
3dbfdaf62623 RLG-Web: begin converting to WebSockets.
John "Elwin" Edwards <elwin@sdf.org>
parents: 94
diff changeset
1238 tslog('WebSockets are online');
155
245a2959f504 Begin support for watching dgamelaunch games.
John "Elwin" Edwards
parents: 148
diff changeset
1239 progressWatcher = startProgressWatcher();
163
0f6da35b27a0 RLGWebD: overhaul the list of current games.
John "Elwin" Edwards
parents: 162
diff changeset
1240 setInterval(pushStatus, 40000);
28
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1241 });
2ad2b6491aa9 rlgwebd.js: become a real daemon.
John "Elwin" Edwards <elwin@sdf.org>
parents: 27
diff changeset
1242