Mercurial > hg > rlgwebd
changeset 185:bbfda4a4eb7f
Finish moving DglSession methods into the prototype.
author | John "Elwin" Edwards |
---|---|
date | Tue, 20 Jan 2015 10:17:05 -0500 |
parents | ecedc6f7e4ac |
children | 674e8899703b |
files | rlgwebd.js |
diffstat | 1 files changed, 90 insertions(+), 81 deletions(-) [+] |
line wrap: on
line diff
--- a/rlgwebd.js Mon Jan 19 14:44:27 2015 -0500 +++ b/rlgwebd.js Tue Jan 20 10:17:05 2015 -0500 @@ -270,12 +270,11 @@ }; function DglSession(filename) { - var ss = this; BaseGame.call(this); var pathcoms = filename.split('/'); this.gname = pathcoms[pathcoms.length - 2]; if (!(this.gname in games)) { - ss.emit('open', false); + this.emit('open', false); return; } var basename = pathcoms[pathcoms.length - 1]; @@ -287,96 +286,106 @@ * getting into a race. */ this.reading = false; this.rpos = 0; - this.readchunk = function () { - if (this.reading) - return; - this.reading = true; - var header = new Buffer(12); - fs.read(ss.fd, header, 0, 12, ss.rpos, function (err, n, buf) { - /* Stop recursion if end of file has been reached. */ - if (err || n < 12) { - if (!err && n > 0) { - tslog("DGL %s: expected 12-byte header, got %d", ss.tag(), n); - } - ss.reading = false; - return; - } - ss.rpos += 12; - /* Update timestamp, to within 1 second. */ - ss.lasttime = new Date(1000 * buf.readUInt32LE(0)); - var datalen = buf.readUInt32LE(8); - if (datalen > 16384) { - // Something is probably wrong... - tslog("DGL %s: looking for %d bytes", ss.tag(), datalen); - } - var databuf = new Buffer(datalen); - fs.read(ss.fd, databuf, 0, datalen, ss.rpos, function (err, n, buf) { - if (err || n < datalen) { - /* Next time, read the header again. */ - ss.rpos -= 12; - ss.reading = false; - tslog("DGL %s: expected %d bytes, got %d", ss.tag(), datalen, n); - return; - } - ss.rpos += n; - ss.reading = false; - /* Process the data */ - ss.framepush(buf); - var wmsg = JSON.stringify({"t": "d", "d": buf.toString("hex")}); - for (var i = 0; i < ss.watchers.length; i++) { - if (ss.watchers[i].connected) - ss.watchers[i].sendUTF(wmsg); - } - ss.emit("data", buf); - //tslog("DGL %s: %d bytes", ss.tag(), buf.length); - /* Recurse. */ - ss.readchunk(); - }); - }); - }; - fs.readFile(filename, {encoding: "utf8"}, function (err, data) { + fs.readFile(filename, {encoding: "utf8"}, (function (err, data) { if (err) { - ss.emit('open', false); + this.emit('open', false); return; } var lines = data.split('\n'); - ss.h = Number(lines[1]); - ss.w = Number(lines[2]); - fs.open(ss.ttyrec, "r", function(err, fd) { + this.h = Number(lines[1]); + this.w = Number(lines[2]); + fs.open(this.ttyrec, "r", (function (err, fd) { if (err) { - ss.emit('open', false); + this.emit('open', false); } else { - ss.fd = fd; - ss.emit('open', true); - tslog("DGL %s: open", ss.tag()); - gamemux.emit('begin', ss.gname, ss.pname, 'dgl'); - ss.readchunk(); - ss.recwatcher = fs.watch(ss.ttyrec, function (ev, finame) { - if (ev == "change") - ss.readchunk(); - }); + this.fd = fd; + this.emit('open', true); + tslog("DGL %s: open", this.tag()); + gamemux.emit('begin', this.gname, this.pname, 'dgl'); + this.startchunk(); + this.recwatcher = fs.watch(this.ttyrec, this.notifier.bind(this)); } - }); - }); - this.close = function () { - this.recwatcher.close() - /* Ensure all data is handled before quitting. */ - this.readchunk(); - var connlist = this.watchers; - this.watchers = []; - for (var i = 0; i < connlist.length; i++) { - if (connlist[i].connected) - connlist[i].close(); - } - fs.close(this.fd); - this.emit("close"); - gamemux.emit('end', this.gname, this.pname); - tslog("DGL %s: closed", ss.tag()); - }; + }).bind(this)); + }).bind(this)); } DglSession.prototype = new BaseGame(); +/* 3 functions to get data from the ttyrec file. */ +DglSession.prototype.startchunk = function () { + if (this.reading) + return; + this.reading = true; + var header = new Buffer(12); + fs.read(this.fd, header, 0, 12, this.rpos, this.datachunk.bind(this)); +}; + +DglSession.prototype.datachunk = function (err, n, buf) { + /* Stop recursion if end of file has been reached. */ + if (err || n < 12) { + if (!err && n > 0) { + tslog("DGL %s: expected 12-byte header, got %d", this.tag(), n); + } + this.reading = false; + return; + } + this.rpos += 12; + /* Update timestamp, to within 1 second. */ + this.lasttime = new Date(1000 * buf.readUInt32LE(0)); + var datalen = buf.readUInt32LE(8); + if (datalen > 16384) { + // Something is probably wrong... + tslog("DGL %s: looking for %d bytes", this.tag(), datalen); + } + var databuf = new Buffer(datalen); + fs.read(this.fd, databuf, 0, datalen, this.rpos, this.handledata.bind(this)); +}; + +DglSession.prototype.handledata = function (err, n, buf) { + if (err || n < buf.length) { + /* Next time, read the header again. */ + this.rpos -= 12; + this.reading = false; + tslog("DGL %s: expected %d bytes, got %d", this.tag(), buf.length, n); + return; + } + this.rpos += n; + this.reading = false; + /* Process the data */ + this.framepush(buf); + var wmsg = JSON.stringify({"t": "d", "d": buf.toString("hex")}); + for (var i = 0; i < this.watchers.length; i++) { + if (this.watchers[i].connected) + this.watchers[i].sendUTF(wmsg); + } + this.emit("data", buf); + /* Recurse. */ + this.startchunk(); +}; + +/* Handles events from the ttyrec file watcher. */ +DglSession.prototype.notifier = function (ev, finame) { + if (ev == "change") + this.startchunk(); + /* If another kind of event appears, something strange happened. */ +}; + +DglSession.prototype.close = function () { + this.recwatcher.close(); + /* Ensure all data is handled before quitting. */ + this.startchunk(); + var connlist = this.watchers; + this.watchers = []; + for (var i = 0; i < connlist.length; i++) { + if (connlist[i].connected) + connlist[i].close(); + } + fs.close(this.fd); + this.emit("close"); + gamemux.emit('end', this.gname, this.pname); + tslog("DGL %s: closed", this.tag()); +}; + function wsStartGame(wsReq) { var playmatch = wsReq.resourceURL.pathname.match(/^\/play\/([^\/]*)$/); if (!playmatch[1] || !(playmatch[1] in games)) {