Commit 409a7030fd1f05e3fc4eceebe10a017d76805c81
1 parent
106c376a0c
Exists in
master
pushResponse ketika gagal konek
Showing 1 changed file with 20 additions and 3 deletions Inline Diff
partner-irs.js
1 | var winston = require('winston'); | 1 | var winston = require('winston'); |
2 | var request = require('request'); | 2 | var request = require('request'); |
3 | var xmlrpc = require('xmlrpc'); | 3 | var xmlrpc = require('xmlrpc'); |
4 | var url = require('url'); | 4 | var url = require('url'); |
5 | var http = require('http'); | 5 | var http = require('http'); |
6 | var mongoClient = require('mongodb').MongoClient; | 6 | var mongoClient = require('mongodb').MongoClient; |
7 | var strftime = require('strftime'); | 7 | var strftime = require('strftime'); |
8 | var moment = require('moment'); | 8 | var moment = require('moment'); |
9 | 9 | ||
10 | var max_retry = 3; | 10 | var max_retry = 3; |
11 | var sleep_before_retry = 2000; | 11 | var sleep_before_retry = 2000; |
12 | 12 | ||
13 | process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; | 13 | process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; |
14 | 14 | ||
15 | var config; | 15 | var config; |
16 | var callbackReport; | 16 | var callbackReport; |
17 | var aaa; | 17 | var aaa; |
18 | var logger; | 18 | var logger; |
19 | var options; | 19 | var options; |
20 | var mongodb; | 20 | var mongodb; |
21 | 21 | ||
22 | function start(_config, _callbackReport, options) { | 22 | function start(_config, _callbackReport, options) { |
23 | config = _config; | 23 | config = _config; |
24 | callbackReport = _callbackReport | 24 | callbackReport = _callbackReport |
25 | 25 | ||
26 | if (options && options.aaa) { | 26 | if (options && options.aaa) { |
27 | aaa = options.aaa; | 27 | aaa = options.aaa; |
28 | } | 28 | } |
29 | 29 | ||
30 | if (options && options.logger) { | 30 | if (options && options.logger) { |
31 | logger = options.logger; | 31 | logger = options.logger; |
32 | } else { | 32 | } else { |
33 | logger = new winston.Logger({ | 33 | logger = new winston.Logger({ |
34 | transports: [ | 34 | transports: [ |
35 | new (winston.transports.Console)() | 35 | new (winston.transports.Console)() |
36 | ] | 36 | ] |
37 | }); | 37 | }); |
38 | } | 38 | } |
39 | 39 | ||
40 | createXMLRPCServer(); | 40 | createXMLRPCServer(); |
41 | initMongoClient(); | 41 | initMongoClient(); |
42 | } | 42 | } |
43 | 43 | ||
44 | function createXMLRPCServer() { | 44 | function createXMLRPCServer() { |
45 | 45 | ||
46 | logger.info('Creating XML-RPC server on port ' + config.h2h_out.listen_port); | 46 | logger.info('Creating XML-RPC server on port ' + config.h2h_out.listen_port); |
47 | var serverOptions = { | 47 | var serverOptions = { |
48 | port: config.h2h_out.listen_port | 48 | port: config.h2h_out.listen_port |
49 | }; | 49 | }; |
50 | 50 | ||
51 | var server = xmlrpc.createServer(serverOptions); | 51 | var server = xmlrpc.createServer(serverOptions); |
52 | 52 | ||
53 | server.on('NotFound', function (method, params) { | 53 | server.on('NotFound', function (method, params) { |
54 | logger.warn('Unknown method recevied on XMLRPC server', {xmlrpc_method: method, xmlrpc_params: params}); | 54 | logger.warn('Unknown method recevied on XMLRPC server', {xmlrpc_method: method, xmlrpc_params: params}); |
55 | }); | 55 | }); |
56 | 56 | ||
57 | server.on('topUpReport', function (err, params, callback) { | 57 | server.on('topUpReport', function (err, params, callback) { |
58 | 58 | ||
59 | logger.info('Got XMLRPC topUpReport request from partner', {xmlrpc_method: 'topUpReport', xmlrpc_params: params}); | 59 | logger.info('Got XMLRPC topUpReport request from partner', {xmlrpc_method: 'topUpReport', xmlrpc_params: params}); |
60 | 60 | ||
61 | var paramscount = params.length; | 61 | var paramscount = params.length; |
62 | for (var i = 0; i < paramscount; i++) { | 62 | for (var i = 0; i < paramscount; i++) { |
63 | var value = params[i]; | 63 | var value = params[i]; |
64 | 64 | ||
65 | var responseTs = strftime('%Y-%m-%d %H:%M:%S', new Date()); | 65 | var responseTs = strftime('%Y-%m-%d %H:%M:%S', new Date()); |
66 | var dummyTask = { requestId: value.REQUESTID }; | 66 | var dummyTask = { requestId: value.REQUESTID }; |
67 | 67 | ||
68 | if (value['RESPONSECODE'] == '00' && config.h2h_out.parse_sn == 'YES') { | 68 | if (value['RESPONSECODE'] == '00' && config.h2h_out.parse_sn == 'YES') { |
69 | value['MESSAGE'] = 'SN=' + parseSN(value['MESSAGE']) + '; ' + value['MESSAGE']; | 69 | value['MESSAGE'] = 'SN=' + parseSN(value['MESSAGE']) + '; ' + value['MESSAGE']; |
70 | } | 70 | } |
71 | 71 | ||
72 | if (value['RESPONSECODE'] != '00' && value['RESPONSECODE'] != '68') { | 72 | if (value['RESPONSECODE'] != '00' && value['RESPONSECODE'] != '68') { |
73 | value['RESPONSECODE'] = '40'; | 73 | value['RESPONSECODE'] = '40'; |
74 | } | 74 | } |
75 | 75 | ||
76 | pushResponseToMongoDb(dummyTask, {ts: responseTs, supplier: config.globals.gateway_name, raw: JSON.stringify(value), parsed: value}, value['RESPONSECODE']); | 76 | pushResponseToMongoDb(dummyTask, {ts: responseTs, supplier: config.globals.gateway_name, raw: JSON.stringify(value), parsed: value}, value['RESPONSECODE']); |
77 | 77 | ||
78 | callbackReport(value['REQUESTID'], value['RESPONSECODE'], value['MESSAGE']); | 78 | callbackReport(value['REQUESTID'], value['RESPONSECODE'], value['MESSAGE']); |
79 | } | 79 | } |
80 | 80 | ||
81 | callback(null, 'ACK REPORT OK'); | 81 | callback(null, 'ACK REPORT OK'); |
82 | }) | 82 | }) |
83 | } | 83 | } |
84 | 84 | ||
85 | function topupRequestHttpGet(task, retry) { | 85 | function topupRequestHttpGet(task, retry) { |
86 | 86 | ||
87 | var options = { | 87 | var options = { |
88 | method: 'GET', | 88 | method: 'GET', |
89 | url: config.h2h_out.partner, | 89 | url: config.h2h_out.partner, |
90 | qs: { | 90 | qs: { |
91 | id: config.h2h_out.userid, | 91 | id: config.h2h_out.userid, |
92 | pin: config.h2h_out.pin, | 92 | pin: config.h2h_out.pin, |
93 | user: config.h2h_out.user, | 93 | user: config.h2h_out.user, |
94 | pass: config.h2h_put.password, | 94 | pass: config.h2h_put.password, |
95 | kodeproduk: task.remoteProduct, | 95 | kodeproduk: task.remoteProduct, |
96 | tujuan: task.destination, | 96 | tujuan: task.destination, |
97 | idtrx: task.requestId | 97 | idtrx: task.requestId |
98 | } | 98 | } |
99 | } | 99 | } |
100 | 100 | ||
101 | request(options, function(err, res, body) { | 101 | request(options, function(err, res, body) { |
102 | }); | 102 | }); |
103 | } | 103 | } |
104 | 104 | ||
105 | function topupRequestXMLRPC(task, retry) { | 105 | function topupRequestXMLRPC(task, retry) { |
106 | var partnerUrl = url.parse(config.h2h_out.partner); | 106 | var partnerUrl = url.parse(config.h2h_out.partner); |
107 | var clientOptions = { | 107 | var clientOptions = { |
108 | host: partnerUrl.hostname | 108 | host: partnerUrl.hostname |
109 | , port: partnerUrl.port | 109 | , port: partnerUrl.port |
110 | , path: partnerUrl.pathname | 110 | , path: partnerUrl.pathname |
111 | }; | 111 | }; |
112 | logger.info('Preparing XMLRPC client options', {options: clientOptions}); | 112 | logger.info('Preparing XMLRPC client options', {options: clientOptions}); |
113 | 113 | ||
114 | var client; | 114 | var client; |
115 | if (partnerUrl.protocol == 'https:') { | 115 | if (partnerUrl.protocol == 'https:') { |
116 | client = xmlrpc.createSecureClient(clientOptions); | 116 | client = xmlrpc.createSecureClient(clientOptions); |
117 | } else { | 117 | } else { |
118 | client = xmlrpc.createClient(clientOptions); | 118 | client = xmlrpc.createClient(clientOptions); |
119 | } | 119 | } |
120 | 120 | ||
121 | var params = { | 121 | var params = { |
122 | MSISDN: config.h2h_out.userid, | 122 | MSISDN: config.h2h_out.userid, |
123 | REQUESTID: task.requestId, | 123 | REQUESTID: task.requestId, |
124 | PIN: config.h2h_out.password, | 124 | PIN: config.h2h_out.password, |
125 | NOHP: task.destination, | 125 | NOHP: task.destination, |
126 | NOM: task.remoteProduct | 126 | NOM: task.remoteProduct |
127 | }; | 127 | }; |
128 | 128 | ||
129 | var methodName = 'topUpRequest'; | 129 | var methodName = 'topUpRequest'; |
130 | logger.info('Preparing XMLRPC client method', {methodname: methodName, params: params}); | 130 | logger.info('Preparing XMLRPC client method', {methodname: methodName, params: params}); |
131 | 131 | ||
132 | client.methodCall(methodName, [ params ], function (error, value) { | 132 | client.methodCall(methodName, [ params ], function (error, value) { |
133 | // Results of the method response | 133 | // Results of the method response |
134 | if (error) { | 134 | if (error) { |
135 | 135 | ||
136 | logger.warn('XMLRPC Client Error', {requestId: task['requestId'], errorMessage: error}); | 136 | logger.warn('XMLRPC Client Error', {requestId: task['requestId'], errorMessage: error}); |
137 | var responseTs = strftime('%Y-%m-%d %H:%M:%S', new Date()); | ||
138 | var dummyValue = { | ||
139 | MESSAGE: 'GENERATED: XMLRPC Client Error: ' + error, | ||
140 | RESPONSECODE: '68', | ||
141 | } | ||
137 | 142 | ||
138 | if (retry) { | 143 | if (retry) { |
139 | 144 | ||
140 | logger.info('Retrying topUpRequest (' + retry + ')'); | 145 | dummyValue.MESSAGE = dummyValue.MESSAGE + '. Retrying (' + retry + ')'; |
146 | logger.info(dummyValue.MESSAGE); | ||
141 | setTimeout(function() { | 147 | setTimeout(function() { |
142 | topupRequest(task, retry - 1); | 148 | topupRequest(task, retry - 1); |
143 | }, sleep_before_retry); | 149 | }, sleep_before_retry); |
144 | 150 | ||
145 | } else { | 151 | } else { |
146 | callbackReport(task['requestId'], '68', 'Silahkan resend. Gangguan koneksi ke suplier: ' + error); | 152 | callbackReport(task['requestId'], '68', 'GENERATED: Silahkan resend. Gangguan koneksi ke suplier: ' + error); |
147 | } | 153 | } |
154 | |||
155 | pushResponseToMongoDb( | ||
156 | task, | ||
157 | { | ||
158 | ts: responseTs, | ||
159 | supplier: config.globals.gateway_name, | ||
160 | raw: JSON.stringify(dummyValue), | ||
161 | parsed: dummyValue | ||
162 | }, | ||
163 | '68' | ||
164 | ); | ||
148 | return; | 165 | return; |
149 | } | 166 | } |
150 | 167 | ||
151 | logger.info('Got XMLRPC response from partner for', {response_method: methodName, response_message: value}); | 168 | logger.info('Got XMLRPC response from partner for', {response_method: methodName, response_message: value}); |
152 | 169 | ||
153 | var responseTs = strftime('%Y-%m-%d %H:%M:%S', new Date()); | 170 | var responseTs = strftime('%Y-%m-%d %H:%M:%S', new Date()); |
154 | 171 | ||
155 | if (value['RESPONSECODE'] == '00' && config.h2h_out.parse_sn == 'YES') { | 172 | if (value['RESPONSECODE'] == '00' && config.h2h_out.parse_sn == 'YES') { |
156 | value['MESSAGE'] = 'SN=' + parseSN(value['MESSAGE']) + '; ' + value['MESSAGE']; | 173 | value['MESSAGE'] = 'SN=' + parseSN(value['MESSAGE']) + '; ' + value['MESSAGE']; |
157 | } | 174 | } |
158 | 175 | ||
159 | if (value['RESPONSECODE'] != '00' && value['RESPONSECODE'] != '68') { | 176 | if (value['RESPONSECODE'] != '00' && value['RESPONSECODE'] != '68') { |
160 | 177 | ||
161 | if (value['MESSAGE'].indexOf("Trx XL-AXIS NO SALAH") >= 0) { | 178 | if (value['MESSAGE'].indexOf("Trx XL-AXIS NO SALAH") >= 0) { |
162 | value['RESPONSECODE'] = '14'; | 179 | value['RESPONSECODE'] = '14'; |
163 | } | 180 | } |
164 | else { | 181 | else { |
165 | value['RESPONSECODE'] = '40'; | 182 | value['RESPONSECODE'] = '40'; |
166 | } | 183 | } |
167 | 184 | ||
168 | } | 185 | } |
169 | 186 | ||
170 | pushResponseToMongoDb(task, {ts: responseTs, supplier: config.globals.gateway_name, raw: JSON.stringify(value), parsed: value}, value['RESPONSECODE']); | 187 | pushResponseToMongoDb(task, {ts: responseTs, supplier: config.globals.gateway_name, raw: JSON.stringify(value), parsed: value}, value['RESPONSECODE']); |
171 | 188 | ||
172 | callbackReport(value['REQUESTID'], value['RESPONSECODE'], value['MESSAGE']); | 189 | callbackReport(value['REQUESTID'], value['RESPONSECODE'], value['MESSAGE']); |
173 | }); | 190 | }); |
174 | } | 191 | } |
175 | 192 | ||
176 | function topupRequest(task, retry) { | 193 | function topupRequest(task, retry) { |
177 | if (retry === undefined) { | 194 | if (retry === undefined) { |
178 | task.ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss'); | 195 | task.ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss'); |
179 | task.ts_date = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD'); | 196 | task.ts_date = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD'); |
180 | 197 | ||
181 | insertTaskToMongoDb(task); | 198 | insertTaskToMongoDb(task); |
182 | } | 199 | } |
183 | 200 | ||
184 | topupRequestXMLRPC(task, retry); | 201 | topupRequestXMLRPC(task, retry); |
185 | } | 202 | } |
186 | 203 | ||
187 | function initMongoClient() { | 204 | function initMongoClient() { |
188 | if (!config.mongodb || !config.mongodb.url) { | 205 | if (!config.mongodb || !config.mongodb.url) { |
189 | return; | 206 | return; |
190 | } | 207 | } |
191 | 208 | ||
192 | try { | 209 | try { |
193 | var url = config.mongodb.url; | 210 | var url = config.mongodb.url; |
194 | 211 | ||
195 | mongoClient.connect(url, function(err, db) { | 212 | mongoClient.connect(url, function(err, db) { |
196 | if (err) { | 213 | if (err) { |
197 | logger.warn('Failed to connect to mongodb', {err: err}); | 214 | logger.warn('Failed to connect to mongodb', {err: err}); |
198 | return; | 215 | return; |
199 | } | 216 | } |
200 | mongodb = db; | 217 | mongodb = db; |
201 | logger.info('MongoDB connected'); | 218 | logger.info('MongoDB connected'); |
202 | }); | 219 | }); |
203 | } | 220 | } |
204 | catch(err) { | 221 | catch(err) { |
205 | logger.warn('Exception when connecting to mongodb', {err: err, url: url}); | 222 | logger.warn('Exception when connecting to mongodb', {err: err, url: url}); |
206 | } | 223 | } |
207 | } | 224 | } |
208 | 225 | ||
209 | function isMongoReady() { | 226 | function isMongoReady() { |
210 | if (!config.mongodb) { return; } | 227 | if (!config.mongodb) { return; } |
211 | if (!config.mongodb.collection) { return; } | 228 | if (!config.mongodb.collection) { return; } |
212 | if (!mongodb) { return; } | 229 | if (!mongodb) { return; } |
213 | 230 | ||
214 | return true; | 231 | return true; |
215 | } | 232 | } |
216 | 233 | ||
217 | function insertTaskToMongoDb(task) { | 234 | function insertTaskToMongoDb(task) { |
218 | if (!isMongoReady()) { return; } | 235 | if (!isMongoReady()) { return; } |
219 | 236 | ||
220 | task.supplier = config.globals.gateway_name; | 237 | task.supplier = config.globals.gateway_name; |
221 | task.rc = '68'; | 238 | task.rc = '68'; |
222 | 239 | ||
223 | try { | 240 | try { |
224 | mongodb.collection(config.mongodb.collection).insertOne(task); | 241 | mongodb.collection(config.mongodb.collection).insertOne(task); |
225 | } | 242 | } |
226 | catch(err) { | 243 | catch(err) { |
227 | //logger.warn('Exception when inserting document to mongodb', {err: err, task: task}); | 244 | //logger.warn('Exception when inserting document to mongodb', {err: err, task: task}); |
228 | } | 245 | } |
229 | } | 246 | } |
230 | 247 | ||
231 | function pushResponseToMongoDb(task, response, rc) { | 248 | function pushResponseToMongoDb(task, response, rc) { |
232 | if (!isMongoReady()) { return; } | 249 | if (!isMongoReady()) { return; } |
233 | 250 | ||
234 | try { | 251 | try { |
235 | mongodb.collection(config.mongodb.collection).updateOne( | 252 | mongodb.collection(config.mongodb.collection).updateOne( |
236 | {requestId: task.requestId}, | 253 | {requestId: task.requestId}, |
237 | { | 254 | { |
238 | $set: { | 255 | $set: { |
239 | lastResponse: response, | 256 | lastResponse: response, |
240 | supplier: config.globals.gateway_name, | 257 | supplier: config.globals.gateway_name, |
241 | rc: rc | 258 | rc: rc |
242 | }, | 259 | }, |
243 | $push: { | 260 | $push: { |
244 | responses: response | 261 | responses: response |
245 | } | 262 | } |
246 | }, | 263 | }, |
247 | function(err, result) { | 264 | function(err, result) { |
248 | if (err) { | 265 | if (err) { |
249 | logger.warn('Error when pushing response to mongodb', {err: err, task: task, response: response}); | 266 | logger.warn('Error when pushing response to mongodb', {err: err, task: task, response: response}); |
250 | return; | 267 | return; |
251 | } | 268 | } |
252 | } | 269 | } |
253 | ); | 270 | ); |
254 | } | 271 | } |
255 | catch(err) { | 272 | catch(err) { |
256 | logger.warn('Exception when pushing response to mongodb', {err: err, task: task, response: response}); | 273 | logger.warn('Exception when pushing response to mongodb', {err: err, task: task, response: response}); |
257 | } | 274 | } |
258 | } | 275 | } |
259 | 276 | ||
260 | exports.start = start; | 277 | exports.start = start; |
261 | exports.topupRequest = topupRequest; | 278 | exports.topupRequest = topupRequest; |
262 | 279 |