Blame view
partner-kospinjasa.js
3.11 KB
1f837fd31
|
1 2 |
var winston = require('winston'); var soap = require('soap'); |
5a947e400
|
3 4 |
var crypto = require('crypto'); var strftime = require('strftime'); |
1f837fd31
|
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
var max_retry = 10; var sleep_before_retry = 5000; var config; var callbackReport; var aaa; var logger; var options; function start(_config, _callbackReport, options) { config = _config; callbackReport = _callbackReport if (options && options.aaa) { aaa = options.aaa; } if (options && options.logger) { logger = options.logger; } else { logger = new winston.Logger({ transports: [ new (winston.transports.Console)() ] }); } } function topupRequest(task, retry) { if (retry === undefined) { retry = max_retry; } |
5a947e400
|
38 |
var remoteProduct = task.remoteProduct.split(','); |
b6b185202
|
39 |
var params = { |
7f796c813
|
40 41 42 43 44 45 46 47 |
userName: config.h2h_out.userid, productCode: remoteProduct[0] , terminal: 'terminal0', transactionType: '50', billNumber: createBillNumber(task.destination), amount: remoteProduct[1], bit61: createBillNumber(task.destination), reff: task.requestId, |
b6b185202
|
48 |
timeStamp: strftime('%d-%m-%Y %H:%M:%S', new Date()) |
7f796c813
|
49 |
} |
b6b185202
|
50 51 |
var signature = createSignature(params, config.h2h_out.password); params.signature = signature; |
7f796c813
|
52 |
|
b6b185202
|
53 |
topupRequestSoap(task, params, retry); |
7f796c813
|
54 |
} |
b6b185202
|
55 |
function topupRequestSoap(task, params, retry) { |
5a947e400
|
56 |
|
777c49c56
|
57 |
soap.createClient(config.h2h_out.partner, function(err, soapClient) { |
35d3e5057
|
58 |
|
b6b185202
|
59 |
logger.info('Requesting to service', {url: config.h2h_out.partner, params: params}); |
6cca23303
|
60 |
soapClient.apih2h.apih2hPort.billpayment({ inputCheck: params }, function(err, result) { |
3899d9816
|
61 62 |
logger.info('Got response', {lastRequest: soapClient.lastRequest}); |
5a947e400
|
63 64 65 66 67 |
if (err) { logger.warn('Error requesting service', {err: err}); callbackReport(task.requestId, '68', 'something wrong'); return; } |
73c4fa043
|
68 69 70 71 72 |
var responseMessageToST24 = result.outputParameter.resultCode.$value + ' - ' + result.outputParameter.resultDesc.$value; logger.info('Got result: ' + responseMessageToST24, {result: result}); callbackReport(task.requestId, '68', responseMessageToST24); |
1f837fd31
|
73 74 75 |
}); }); } |
7f796c813
|
76 |
|
b6b185202
|
77 |
function createSignature(params, password) { |
5a947e400
|
78 |
var passwordHash = crypto.createHash('sha256').update(password).digest().toString('hex'); |
dfcc535b5
|
79 |
var plain = |
b6b185202
|
80 |
params.userName |
5a947e400
|
81 |
+ passwordHash |
b6b185202
|
82 83 84 85 86 87 88 |
+ params.productCode + params.terminal + params.transactionType + params.billNumber + params.amount + params.reff + params.timeStamp; |
dfcc535b5
|
89 90 |
var result = crypto.createHash('sha1').update(plain).digest().toString('hex'); |
5a947e400
|
91 |
|
371375d72
|
92 |
if (logger) { |
b6b185202
|
93 |
logger.verbose('Calculating signature', {plain: plain, result: result, params: params, password: password}); |
371375d72
|
94 |
} |
5a947e400
|
95 96 97 98 99 |
return result; } function createBillNumber(destination) { return ("0000000000000" + destination).slice(-13); |
1f837fd31
|
100 101 102 103 |
} exports.start = start; exports.topupRequest = topupRequest; |
5a947e400
|
104 105 |
exports.createSignature = createSignature; exports.createBillNumber = createBillNumber; |