Komodo / komodo-sdk

Compare View

switch
from
...
to
 
Commits (2)

Changes

Showing 2 changed files Inline Diff

center/http-response-server.js
Diff comments   View file @ 5b4de1a
1 "use strict"; 1 "use strict";
2 2
3 /** 3 /**
4 * HTTP Response Server 4 * HTTP Response Server
5 * 5 *
6 * Untuk menangkap respon dari core 6 * Untuk menangkap respon dari core
7 */ 7 */
8 8
9 9
10 const http = require('http'); 10 const http = require('http');
11 const url = require('url'); 11 const url = require('url');
12 12
13 const config = require('../config'); 13 const config = require('../config');
14 const logger = require('../logger'); 14 const logger = require('../logger');
15 15
16 let transport; 16 let transport;
17 17
18 function onRequest(request, response) { 18 function onRequest(request, response) {
19 response.end('OK'); 19 response.end('OK');
20 var qs = url.parse(request.url, true).query; 20 var qs = url.parse(request.url, true).query;
21 logger.verbose('Got reverse report from CORE', {qs: qs}); 21 logger.verbose('Got reverse report from CORE', {qs: qs});
22 22
23 if (!transport || !transport.send) { 23 if (!transport || !transport.send) {
24 logger.warn('UNDEFINED TRANSPORT, not forwarding message from CORE'); 24 logger.warn('UNDEFINED TRANSPORT, not forwarding message from CORE');
25 return; 25 return;
26 } 26 }
27 27
28 if (!qs.terminal_name || !qs.message) { 28 if (!qs.terminal_name || !qs.message) {
29 return; 29 return;
30 } 30 }
31 31
32 transport.send(qs.terminal_name, qs.message, { 32 transport.send(qs.terminal_name, qs.message, {
33 reverse_url: qs.reverse_url 33 reverse_url: qs.reverse_url
34 }); 34 });
35 } 35 }
36 36
37 function setTransport(newTransport) { 37 function setTransport(newTransport) {
38 transport = newTransport; 38 transport = newTransport;
39 } 39 }
40 40
41 function create() { 41 function create() {
42 let listenPort = config.listen_port; 42 let listenPort = config.listen_port;
43 43
44 http.createServer(onRequest).listen(listenPort, function() { 44 http.createServer(onRequest).listen(listenPort, function() {
45 logger.info('HTTP Reverse/Report server listen on port ' + listenPort); 45 logger.info('HTTP Reverse/Report server listen on port ' + listenPort);
46 });; 46 });;
47 } 47 }
48 48
49 create(); 49 create();
50 50
51 exports.setTransport = setTransport; 51 exports.setTransport = setTransport;
52 52
1 { 1 {
2 "name": "komodo-sdk", 2 "name": "komodo-sdk",
3 "version": "1.4.2", 3 "version": "1.4.3",
4 "description": "SDK for Komodo", 4 "description": "SDK for Komodo",
5 "main": "index.js", 5 "main": "index.js",
6 "scripts": { 6 "scripts": {
7 "test": "mocha", 7 "test": "mocha",
8 "postversion": "git push && git push --tags" 8 "postversion": "git push && git push --tags"
9 }, 9 },
10 "repository": { 10 "repository": {
11 "type": "git", 11 "type": "git",
12 "url": "git@gitlab.kodesumber.com:komodo/komodo-sdk.git" 12 "url": "git@gitlab.kodesumber.com:komodo/komodo-sdk.git"
13 }, 13 },
14 "keywords": [ 14 "keywords": [
15 "ppob", 15 "ppob",
16 "payment", 16 "payment",
17 "komodo" 17 "komodo"
18 ], 18 ],
19 "author": "Adhidarma Hadiwinoto <gua@adhisimon.org>", 19 "author": "Adhidarma Hadiwinoto <gua@adhisimon.org>",
20 "license": "ISC", 20 "license": "ISC",
21 "dependencies": { 21 "dependencies": {
22 "request": "^2.81.0", 22 "request": "^2.81.0",
23 "strftime": "^0.10.0", 23 "strftime": "^0.10.0",
24 "winston": "^2.3.1", 24 "winston": "^2.3.1",
25 "winston-daily-rotate-file": "^1.4.6" 25 "winston-daily-rotate-file": "^1.4.6"
26 } 26 }
27 } 27 }
28 28