warden/rlgwebd
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Finish moving DglSession methods into the prototype.

Browse source
This commit is contained in:
John "Elwin" Edwards 2015-01-20 10:17:05 -05:00
parent 677d739bed
commit 583514764f
1 changed files with 90 additions and 81 deletions
Download patch file Download diff file Expand all files Collapse all files

171
rlgwebd.js
View file

@ -270,12 +270,11 @@ TermSession.prototype.destroy = function () {
};
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 @@ function DglSession(filename) {
* 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)) {