-
-
Notifications
You must be signed in to change notification settings - Fork 351
/
Copy pathprovider.ts
66 lines (56 loc) · 1.69 KB
/
provider.ts
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
60
61
62
63
64
65
66
/* tslint:disable:no-unused-expression no-empty */
import net = require('net');
import express = require('express');
import * as http from 'http';
import { generateMattMessage, parseMattMessage } from './protocol';
export const startTCPServer = (
host: string,
port?: number
): Promise<number> => {
const server = net.createServer();
server.on('connection', (sock) => {
sock.on('error', (err) => {
console.log(`received TCP socket error: ${err}. Error will be ignored`);
});
sock.on('data', (data) => {
const msg = parseMattMessage(data.toString());
if (msg === 'hellotcp') {
sock.write(generateMattMessage('tcpworld'));
} else {
sock.write(generateMattMessage('message not understood'));
}
sock.write('\n');
sock.end();
});
});
return new Promise((resolve) => {
server.listen(port, host, () => {
console.log('listening on part');
});
server.on('error', (err) => {
console.log(`received TCP server error: ${err}. Error will be ignored`);
});
server.on('listening', () => {
resolve((server.address() as net.AddressInfo).port);
});
});
};
export const startHTTPServer = (
host: string,
port?: number
): Promise<http.Server> => {
const server: express.Express = express();
server.post('/matt', (_, res) => {
res.setHeader('content-type', 'application/matt');
res.send(generateMattMessage('world'));
});
server.on('error', (err) => {
console.log(`received HTTP error: ${err}. Error will be ignored`);
});
let s: http.Server;
return new Promise<void>((resolve) => {
s = server.listen(port ? port : 0, host, () => {
resolve();
});
}).then(() => s);
};