Commit 49e9a634a5a4f58c271c9674273f60f5679fd333

Authored by Adhidarma Hadiwinoto
1 parent 0b466a0e06
Exists in master

http-response-server

Showing 2 changed files with 46 additions and 0 deletions 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
1 1 "use strict";
2 2  
  3 +/**
  4 + * Trx Handler untuk center messaging
  5 + */
  6 +
3 7 const path = require('path');
4 8 const request = require('request');
5 9 const strftime = require('strftime');