Commit fdf5cd24dcb6195245f81d94420bc9a32536a5af
1 parent
bb5f193914
Exists in
master
disable resend delay
Showing 1 changed file with 6 additions and 4 deletions Side-by-side Diff
partner-komodo.js
... | ... | @@ -59,6 +59,7 @@ function start(options) { |
59 | 59 | function callbackReport(requestId, rc, message, options) { |
60 | 60 | aaa.callbackReportWithPushToMongoDb(requestId, rc, message); |
61 | 61 | |
62 | + /* | |
62 | 63 | if (!options.task) { |
63 | 64 | return; |
64 | 65 | } |
... | ... | @@ -68,6 +69,7 @@ function callbackReport(requestId, rc, message, options) { |
68 | 69 | } else { |
69 | 70 | resendDelay.cancel(options.task) |
70 | 71 | } |
72 | + */ | |
71 | 73 | |
72 | 74 | } |
73 | 75 | |
... | ... | @@ -94,14 +96,14 @@ function topupRequest(task, pendingOnConnectError) { |
94 | 96 | if (err.syscall == 'connect' && !pendingOnConnectError) { |
95 | 97 | rc = '91'; |
96 | 98 | } |
97 | - callbackReport(task.requestId, rc, 'Error requesting to partner: ' + err); | |
99 | + callbackReport(task.requestId, rc, 'Error requesting to partner: ' + err, {task: task}); | |
98 | 100 | return; |
99 | 101 | } |
100 | 102 | |
101 | 103 | if (response.statusCode != 200) { |
102 | 104 | let rc = '68'; |
103 | 105 | |
104 | - callbackReport(task.requestId, rc, 'Partner returning HTTP status code ' + response.statusCode + ', not 200'); | |
106 | + callbackReport(task.requestId, rc, 'Partner returning HTTP status code ' + response.statusCode + ', not 200', {task: task}); | |
105 | 107 | return; |
106 | 108 | } |
107 | 109 | |
... | ... | @@ -119,7 +121,7 @@ function processPartnerResponse(resObj, task) { |
119 | 121 | if (!resObj) { |
120 | 122 | |
121 | 123 | if (task.requestId) { |
122 | - callbackReport(task.requestId, '40', 'Error parsing response from partner. Partner response: ' + body); | |
124 | + callbackReport(task.requestId, '40', 'Error parsing response from partner. Partner response: ' + body, {task: task}); | |
123 | 125 | } |
124 | 126 | else { |
125 | 127 | logger.warn('UNDEFINED REQUEST ID'); |
... | ... | @@ -139,7 +141,7 @@ function processPartnerResponse(resObj, task) { |
139 | 141 | st24Message = 'SN=' + resObj.sn + '; ' + st24Message; |
140 | 142 | } |
141 | 143 | |
142 | - callbackReport(resObj.request_id, st24Rc, st24Message); | |
144 | + callbackReport(resObj.request_id, st24Rc, st24Message, {task: task}); | |
143 | 145 | } |
144 | 146 | |
145 | 147 | function parsePartnerMessage(partner_message) { |