forked from lucidsoftware/nodegun
-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.js
37 lines (37 loc) · 1.18 KB
/
server.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
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const net = require("net");
const chunk_1 = require("./chunk");
const handler_1 = require("./handler");
class BaseServer {
constructor(commandFactory, ref) {
this.handler = new handler_1.Handler(commandFactory, ref);
}
connection(socket) {
socket.setNoDelay(true);
socket.unref();
const parser = new chunk_1.ChunkParser();
const serializer = new chunk_1.ChunkSerializer();
socket.pipe(parser);
serializer.pipe(socket);
this.handler.handle(parser, serializer);
socket.on('error', socket.destroy);
socket.on('timeout', () => socket.destroy(new Error('timeout')));
}
status() {
return Promise.resolve(this.handler.status());
}
}
exports.BaseServer = BaseServer;
class Server extends BaseServer {
constructor(commandFactory) {
const server = net.createServer({ allowHalfOpen: true }, socket => this.connection(socket));
super(commandFactory, server);
this.server = server;
}
shutdown() {
this.server.close();
}
}
exports.Server = Server;
//# sourceMappingURL=server.js.map