Commit 04671bba9f73e07b78f690177da56872669342e1

Authored by Adhidarma Hadiwinoto
1 parent bc5bcfea87
Exists in master

pendingLimit

Showing 1 changed file with 21 additions and 5 deletions Side-by-side Diff

partner-kospinjasa.js
... ... @@ -21,7 +21,6 @@ var logger;
21 21 var options;
22 22 var mongodb;
23 23  
24   -
25 24 function start(_config, _callbackReport, options) {
26 25 config = _config;
27 26 callbackReport = _callbackReport
... ... @@ -140,12 +139,29 @@ function isMongoReady() {
140 139 }
141 140  
142 141 function topupRequest(task, retry) {
143   - if (config && config.globals && config.globals.reject_on_pending_count && matrix && matrix.strikeStatus && matrix.strikeStatus.pending) {
144   - if (parseInt(config.globals.reject_on_pending_count) <= matrix.strikeStatus.pending) {
145   - callbackReport(task.requestId, '13', 'Reject trx karena pending terlalu banyak');
146   - return;
  142 +
  143 + try {
  144 + if (config && config.globals && config.globals.reject_on_pending_count && matrix && matrix.strikeStatus && matrix.strikeStatus.pending) {
  145 +
  146 + var pendingCount = matrix.strikeStatus.pending;
  147 + var pendingLimitCount = parseInt(config.globals.reject_on_pending_count);
  148 +
  149 + if (pendingLimitCount <= matrix.strikeStatus.pending) {
  150 +
  151 + logger.warn(
  152 + 'Reject trx karena pending terlalu banyak',
  153 + {pendingCount: pendingCount, pendingLimitCount: pendingLimitCount}
  154 + );
  155 +
  156 + callbackReport(task.requestId, '13', 'Reject trx karena pending terlalu banyak');
  157 + return;
  158 + }
147 159 }
148 160 }
  161 + catch(err) {
  162 + logger.warn("Exception saat periksa pendingLimit: " + err);
  163 + }
  164 +
149 165  
150 166 task.ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss');
151 167 task.ts_date = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD');