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 @ 67984df
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 module_name = require('path').basename(__filename);
11
10 const module_name = require('path').basename(__filename); 12 const http = require('http');
11 13 const url = require('url');
12 const http = require('http'); 14
13 const url = require('url'); 15 const config = require('../config');
14 16 const logger = require('../logger');
15 const config = require('../config'); 17
16 const logger = require('../logger'); 18 let transport;
17 19
18 let transport; 20 function onRequest(request, response) {
21 const method_name = 'onRequest';
22
19 23 response.end('OK');
20 function onRequest(request, response) { 24
21 const method_name = 'onRequest'; 25 const qs = url.parse(request.url, true).query;
22 26
27 logger.verbose('Got reverse report from CORE', {module_name: module_name, method_name: method_name, url: request.url, qs: qs});
23 response.end('OK'); 28
24 29 if (!transport || !transport.send) {
25 const qs = url.parse(request.url, true).query; 30 logger.warn('UNDEFINED TRANSPORT, not forwarding message from CORE');
26 31 return;
27 logger.verbose('Got reverse report from CORE', {module_name: module_name, method_name: method_name, url: request.url, qs: qs}); 32 }
28 33
29 if (!transport || !transport.send) { 34 if (!qs.terminal_name || !qs.message) {
30 logger.warn('UNDEFINED TRANSPORT, not forwarding message from CORE'); 35 return;
31 return; 36 }
32 } 37
33 38 transport.send(qs.terminal_name, qs.message, qs);
34 if (!qs.terminal_name || !qs.message) { 39 }
35 return; 40
36 } 41 function setTransport(newTransport) {
37 42 transport = newTransport;
38 transport.send(qs.terminal_name, qs.message, qs); 43 }
39 } 44
40 45 function create() {
41 function setTransport(newTransport) { 46 let listenPort = config.listen_port;
42 transport = newTransport; 47
43 } 48 http.createServer(onRequest).listen(listenPort, function() {
44 49 logger.info('HTTP Reverse/Report server listen on port ' + listenPort + ' to process CORE message');
45 function create() { 50 });;
46 let listenPort = config.listen_port; 51 }
47 52
48 http.createServer(onRequest).listen(listenPort, function() { 53 create();
49 logger.info('HTTP Reverse/Report server listen on port ' + listenPort + ' to process CORE message'); 54
50 });; 55 exports.setTransport = setTransport;
51 } 56
1 { 1 {
2 "name": "komodo-sdk", 2 "name": "komodo-sdk",
3 "version": "1.14.2", 3 "version": "1.14.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 "basic-auth": "^2.0.0", 22 "basic-auth": "^2.0.0",
23 "body-parser": "^1.18.2", 23 "body-parser": "^1.18.2",
24 "express": "^4.16.2", 24 "express": "^4.16.2",
25 "express-session": "^1.15.6", 25 "express-session": "^1.15.6",
26 "lru-cache": "^4.1.1", 26 "lru-cache": "^4.1.1",
27 "moment": "^2.19.1", 27 "moment": "^2.19.1",
28 "numeral": "^2.0.6", 28 "numeral": "^2.0.6",
29 "nunjucks": "^3.0.1", 29 "nunjucks": "^3.0.1",
30 "redis": "^2.8.0", 30 "redis": "^2.8.0",
31 "request": "^2.81.0", 31 "request": "^2.81.0",
32 "simple-git": "^1.80.1", 32 "simple-git": "^1.80.1",
33 "strftime": "^0.10.0", 33 "strftime": "^0.10.0",
34 "uniqid": "^4.1.1", 34 "uniqid": "^4.1.1",
35 "uuid": "^3.1.0", 35 "uuid": "^3.1.0",
36 "winston": "^2.3.1", 36 "winston": "^2.3.1",
37 "winston-circular-buffer": "^1.0.0", 37 "winston-circular-buffer": "^1.0.0",
38 "winston-daily-rotate-file": "^1.4.6" 38 "winston-daily-rotate-file": "^1.4.6"
39 } 39 }
40 } 40 }
41 41