Compare View
Commits (2)
Changes
Showing 3 changed files Side-by-side Diff
center/http-response-server.js
... | ... | @@ -0,0 +1,42 @@ |
1 | +"use strict"; | |
2 | + | |
3 | +/** | |
4 | + * HTTP Response Server | |
5 | + * | |
6 | + * Untuk menangkap respon dari core | |
7 | + */ | |
8 | + | |
9 | + | |
10 | +const http = require('http'); | |
11 | +const url = require('url'); | |
12 | + | |
13 | +const config = require('../config'); | |
14 | +const logger = require('../logger'); | |
15 | + | |
16 | +let transport; | |
17 | + | |
18 | +function onRequest(request, response) { | |
19 | + response.end('OK'); | |
20 | + var qs = url.parse(request.url, true).query; | |
21 | + logger.verbose('Got reverse report from CORE', {qs: qs}); | |
22 | + | |
23 | + if (transport && transport.send && qs && qs.terminal_name && qs.message) { | |
24 | + transport.send(qs.terminal_name, qs.message); | |
25 | + } | |
26 | +} | |
27 | + | |
28 | +function setTransport(newTransport) { | |
29 | + transport = newTransport; | |
30 | +} | |
31 | + | |
32 | +function create() { | |
33 | + let listenPort = config.listen_port; | |
34 | + | |
35 | + http.createServer(onRequest).listen(listenPort, function() { | |
36 | + logger.info('HTTP Reverse/Report server listen on port ' + listenPort); | |
37 | + });; | |
38 | +} | |
39 | + | |
40 | +create(); | |
41 | + | |
42 | +exports.setTransport = setTransport; |
center/messaging/trx-center.js