Komodo / Komodo HTTP GET Center a.k.a komodo-center-httpget

Download as
Browse Code ยป

Commit 8fc4b3de412ebaa8354edcd8d72ce47974b22e0a

Authored by Adhidarma Hadiwinoto
1 parent 23a61495cb
Exists in master and in 1 other branch ad2mt

buang object

Showing 1 changed file with 3 additions and 4 deletions Inline Diff

1 "use strict"; 1 "use strict";
2 2
3 process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0"; 3 process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
4 4
5 const module_name = require('path').basename(__filename); 5 const module_name = require('path').basename(__filename);
6 6
7 const http = require('http'); 7 const http = require('http');
8 const url = require('url'); 8 const url = require('url');
9 const request = require('request'); 9 const request = require('request');
10 10
11 const config = require('komodo-sdk/config') 11 const config = require('komodo-sdk/config')
12 const logger = require('komodo-sdk/logger'); 12 const logger = require('komodo-sdk/logger');
13 13
14 let _callback; 14 let _callback;
15 15
16 function createHttpServer() { 16 function createHttpServer() {
17 let listenPort = config.center_port; 17 let listenPort = config.center_port;
18 18
19 http.createServer(onRequest).listen(listenPort, function() { 19 http.createServer(onRequest).listen(listenPort, function() {
20 logger.info('Center HTTP server listen on port ' + listenPort); 20 logger.info('Center HTTP server listen on port ' + listenPort);
21 });; 21 });;
22 } 22 }
23 23
24 function onRequest(req, res) { 24 function onRequest(req, res) {
25 const method_name = 'onRequest'; 25 const method_name = 'onRequest';
26 26
27 let remote_address = req.connection.remoteAddress.replace(/^::ffff:/, ''); 27 let remote_address = req.connection.remoteAddress.replace(/^::ffff:/, '');
28 28
29 let qs = url.parse(req.url, true).query; 29 let qs = url.parse(req.url, true).query;
30 30
31 logger.verbose('Got a request', {module_name: module_name, method_name: method_name, remote_address: remote_address, url: req.url, qs: qs}); 31 logger.verbose('Got a request', {module_name: module_name, method_name: method_name, remote_address: remote_address, url: req.url, qs: qs});
32 32
33 let partner = qs.terminal_name + '@' + remote_address; 33 let partner = qs.terminal_name + '@' + remote_address;
34 let password = qs.password; 34 let password = qs.password;
35 let reverse_url = qs.reverse_url; 35 let reverse_url = qs.reverse_url;
36 36
37 let product_name = qs.product_name; 37 let product_name = qs.product_name;
38 let destination = qs.destination; 38 let destination = qs.destination;
39 let request_id = qs.request_id; 39 let request_id = qs.request_id;
40 40
41 if (!qs.terminal_name || !password || !reverse_url || ! product_name || !destination || !request_id) { 41 if (!qs.terminal_name || !password || !reverse_url || ! product_name || !destination || !request_id) {
42 res.end('INVALID REQUEST'); 42 res.end('INVALID REQUEST');
43 return; 43 return;
44 } 44 }
45 45
46 let msg = [ product_name, destination, password, request_id ].join('.'); 46 let msg = [ product_name, destination, password, request_id ].join('.');
47 47
48 _callback.onIncomingMessage( 48 _callback.onIncomingMessage(
49 { 49 {
50 me: config.username, 50 me: config.username,
51 partner: partner, 51 partner: partner,
52 msg: msg.trim(), 52 msg: msg.trim(),
53 reverse_url: reverse_url 53 reverse_url: reverse_url
54 }, 54 },
55 55
56 function(err, _result) { 56 function(err, _result) {
57 let result = cleanResponseToPartner(_result); 57 let result = cleanResponseToPartner(_result);
58 58
59 logger.verbose('Forwarding CORE response to partner', _result); 59 logger.verbose('Forwarding CORE response to partner', _result);
60 res.end(JSON.stringify(result)); 60 res.end(JSON.stringify(result));
61 } 61 }
62 ) 62 )
63 } 63 }
64 64
65 function cleanResponseToPartner(_data) { 65 function cleanResponseToPartner(_data) {
66 let data = JSON.parse(JSON.stringify(_data)); 66 let data = JSON.parse(JSON.stringify(_data));
67 67
68 delete data.origin; 68 delete data.origin;
69 delete data.origin_report_ip; 69 delete data.origin_report_ip;
70 delete data.origin_report_port; 70 delete data.origin_report_port;
71 delete data.reverse_url; 71 delete data.reverse_url;
72 delete data.misc; 72 delete data.misc;
73 delete data.inquiry_only; 73 delete data.inquiry_only;
74 74
75 for (let key in data) { 75 for (let key in data) {
76
76 if (data.hasOwnProperty(key)) { 77 if (data.hasOwnProperty(key)) {
77 //console.log(key, yourobject[key]);
78 78
79 if (key.indexOf('[') >= 0) { 79 if (key.indexOf('[') >= 0) { delete data[key]; }
80 delete data[key]; 80
81 }
82 } 81 }
83 } 82 }
84 83
85 return data; 84 return data;
86 } 85 }
87 86
88 function init(cb) { 87 function init(cb) {
89 if (!cb) { 88 if (!cb) {
90 logger.warn('Callback is not defined'); 89 logger.warn('Callback is not defined');
91 console.trace(); 90 console.trace();
92 process.exit(1); 91 process.exit(1);
93 return; 92 return;
94 } 93 }
95 94
96 _callback = cb; 95 _callback = cb;
97 96
98 createHttpServer(); 97 createHttpServer();
99 } 98 }
100 99
101 function send(partner, msg, params) { 100 function send(partner, msg, params) {
102 logger.verbose('Got response from CORE', {partner: partner, msg: msg, params: params}); 101 logger.verbose('Got response from CORE', {partner: partner, msg: msg, params: params});
103 102
104 if (!params || !params.reverse_url) { 103 if (!params || !params.reverse_url) {
105 logger.verbose('Undefined reverse_url, not forwarding message to partner'); 104 logger.verbose('Undefined reverse_url, not forwarding message to partner');
106 return; 105 return;
107 } 106 }
108 107
109 108
110 let reqOptions = { 109 let reqOptions = {
111 url: params.reverse_url, 110 url: params.reverse_url,
112 qs: cleanResponseToPartner(params) 111 qs: cleanResponseToPartner(params)
113 } 112 }
114 113
115 logger.verbose('Sending reverse report to partner', {request: reqOptions}); 114 logger.verbose('Sending reverse report to partner', {request: reqOptions});
116 request(reqOptions, function(err, res, body) { 115 request(reqOptions, function(err, res, body) {
117 if (err) { 116 if (err) {
118 logger.warn('Error sending reverse report to partner', {request: reqOptions, err: err}); 117 logger.warn('Error sending reverse report to partner', {request: reqOptions, err: err});
119 return; 118 return;
120 } 119 }
121 120
122 if (res.statusCode != 200) { 121 if (res.statusCode != 200) {
123 logger.warn('Partner not returning HTTP status code 200 on reverse report', {request: reqOptions, http_status: res.statusCode}); 122 logger.warn('Partner not returning HTTP status code 200 on reverse report', {request: reqOptions, http_status: res.statusCode});
124 return; 123 return;
125 } 124 }
126 125
127 logger.verbose('Reverse report has been sent to partner', {request: reqOptions}); 126 logger.verbose('Reverse report has been sent to partner', {request: reqOptions});
128 }) 127 })
129 } 128 }
130 129
131 exports.init = init; 130 exports.init = init;
132 exports.send = send; 131 exports.send = send;