Compare View

switch
from
...
to
 
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
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');
1 1 {
2 2 "name": "komodo-sdk",
3   - "version": "1.2.0",
  3 + "version": "1.3.0",
4 4 "description": "SDK for Komodo",
5 5 "main": "index.js",
6 6 "scripts": {