James Coglan
119 lines
3.0 KiB
JavaScript
119 lines
3.0 KiB
JavaScript
var Base = require('./base'),
|
|
util = require('util');
|
|
|
|
var Draft75 = function(request, url, options) {
|
|
Base.apply(this, arguments);
|
|
this._stage = 0;
|
|
this.version = 'hixie-75';
|
|
};
|
|
util.inherits(Draft75, Base);
|
|
|
|
var instance = {
|
|
close: function() {
|
|
if (this.readyState === 3) return false;
|
|
this.readyState = 3;
|
|
this.emit('close', new Base.CloseEvent(null, null));
|
|
return true;
|
|
},
|
|
|
|
parse: function(buffer) {
|
|
if (this.readyState > 1) return;
|
|
|
|
var data, message, value;
|
|
for (var i = 0, n = buffer.length; i < n; i++) {
|
|
data = buffer[i];
|
|
|
|
switch (this._stage) {
|
|
case -1:
|
|
this._body.push(data);
|
|
this._sendHandshakeBody();
|
|
break;
|
|
|
|
case 0:
|
|
this._parseLeadingByte(data);
|
|
break;
|
|
|
|
case 1:
|
|
value = (data & 0x7F);
|
|
this._length = value + 128 * this._length;
|
|
|
|
if (this._closing && this._length === 0) {
|
|
return this.close();
|
|
}
|
|
else if ((0x80 & data) !== 0x80) {
|
|
if (this._length === 0) {
|
|
this._stage = 0;
|
|
}
|
|
else {
|
|
this._skipped = 0;
|
|
this._stage = 2;
|
|
}
|
|
}
|
|
break;
|
|
|
|
case 2:
|
|
if (data === 0xFF) {
|
|
message = new Buffer(this._buffer).toString('utf8', 0, this._buffer.length);
|
|
this.emit('message', new Base.MessageEvent(message));
|
|
this._stage = 0;
|
|
}
|
|
else {
|
|
if (this._length) {
|
|
this._skipped += 1;
|
|
if (this._skipped === this._length)
|
|
this._stage = 0;
|
|
} else {
|
|
this._buffer.push(data);
|
|
if (this._buffer.length > this._maxLength) return this.close();
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
},
|
|
|
|
frame: function(data) {
|
|
if (this.readyState === 0) return this._queue([data]);
|
|
if (this.readyState > 1) return false;
|
|
|
|
var buffer = new Buffer(data, 'utf8'),
|
|
frame = new Buffer(buffer.length + 2);
|
|
|
|
frame[0] = 0x00;
|
|
frame[buffer.length + 1] = 0xFF;
|
|
buffer.copy(frame, 1);
|
|
|
|
this._write(frame);
|
|
return true;
|
|
},
|
|
|
|
_handshakeResponse: function() {
|
|
return new Buffer('HTTP/1.1 101 Web Socket Protocol Handshake\r\n' +
|
|
'Upgrade: WebSocket\r\n' +
|
|
'Connection: Upgrade\r\n' +
|
|
'WebSocket-Origin: ' + this._request.headers.origin + '\r\n' +
|
|
'WebSocket-Location: ' + this.url + '\r\n' +
|
|
this.__headers.toString() +
|
|
'\r\n',
|
|
'utf8');
|
|
},
|
|
|
|
_parseLeadingByte: function(data) {
|
|
if ((0x80 & data) === 0x80) {
|
|
this._length = 0;
|
|
this._stage = 1;
|
|
} else {
|
|
delete this._length;
|
|
delete this._skipped;
|
|
this._buffer = [];
|
|
this._stage = 2;
|
|
}
|
|
}
|
|
};
|
|
|
|
for (var key in instance)
|
|
Draft75.prototype[key] = instance[key];
|
|
|
|
module.exports = Draft75;
|
|
|