/
port.js
59 lines (56 loc) · 1.59 KB
/
port.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
"use strict";
var Socket = require("net").Socket;
var Class = require("./class").Class;
var EventTarget = require("./event").EventTarget;
var MessageEvent = require("./event").MessageEvent;
var Port = Class({
extends: EventTarget,
constructor: function(port, host) {
this.port = port;
this.host = host;
EventTarget.call(this);
this.socket = new Socket();
this.socket.on("data", this.receive.bind(this));
this.addEventListener("message", this);
},
handleEvent: function(event) {
var listener = this.onmessage;
return listener && listener(event);
},
start: function() {
this.socket.connect(this.port, this.host);
},
close: function() {
this.socket.end();
},
get onmessage(listener) {
return this.listener;
},
set onmessage(listener) {
this.listener = listener;
},
receive: function(chunk) {
var buffer = this.buffer ? Buffer.concat([this.buffer, chunk]) : chunk;
while (buffer.length) {
var index = buffer.toString().indexOf(":");
var size = parseInt(buffer.slice(0, index));
var start = index + 1;
var end = start + size;
if (buffer.length >= end) {
var frame = buffer.slice(start, end).toString();
var message = new MessageEvent("message", { data: JSON.parse(frame) });
this.dispatchEvent(message);
buffer = buffer.slice(end);
} else {
break;
}
}
this.buffer = buffer;
},
postMessage: function(data) {
var frame = JSON.stringify(data);
var packet = frame.length + ":" + frame;
this.socket.write(packet);
}
});
exports.Port = Port;