Commit fbf26836c9641dc3b2512aa2d63c6b5e61f2a57c

Authored by Adhidarma Hadiwinoto
1 parent 570783a390
Exists in master

cleanup

Showing 1 changed file with 6 additions and 7 deletions Side-by-side Diff

... ... @@ -2,8 +2,8 @@
2 2  
3 3 var LRU = require('lru-cache');
4 4  
5   -const config = require('../config');
6   -const logger = require('../logger');
  5 +const config = require('./config');
  6 +const logger = require('./logger');
7 7  
8 8 var topupRequest;
9 9 var resendHandlers = LRU({max: 2000, maxAge: 1000 * 3600 * 36});
... ... @@ -55,11 +55,11 @@ function register(task) {
55 55 return;
56 56 }
57 57  
58   - if (!config || !config.globals || !Number(config.globals.auto_resend_delay_secs) || !Number(config.globals.auto_resend_delay_max)) {
  58 + if (!config || !config.auto_resend_delay || !Number(config.auto_resend_delay.delay_ms) || !Number(config.auto_resend_delay.resend_max)) {
59 59 return;
60 60 }
61 61  
62   - var retry = config.globals.auto_resend_delay_max;
  62 + var retry = config.auto_resend_delay.resend_max;
63 63 var oldHandler = resendHandlers.get(task.requestId);
64 64 if (oldHandler) {
65 65 retry = oldHandler.retry - 1;
... ... @@ -72,9 +72,9 @@ function register(task) {
72 72 return;
73 73 }
74 74  
75   - logger.verbose('Registering resend delay task request', {task: task, delay: config.globals.auto_resend_delay_secs, retry: retry});
  75 + logger.verbose('Registering resend delay task request', {task: task, delay_ms: config.auto_resend_delay.delay_ms, retry: retry});
76 76 var handlerData = {
77   - handler: setTimeout(request, config.globals.auto_resend_delay_secs * 1000, task),
  77 + handler: setTimeout(request, config.auto_resend_delay.delay_ms, task),
78 78 task: task,
79 79 retry: retry
80 80 }
... ... @@ -82,7 +82,6 @@ function register(task) {
82 82 resendHandlers.set(task.requestId, handlerData);
83 83 }
84 84  
85   -
86 85 exports.init = init;
87 86 exports.cancel = cancel;
88 87 exports.register = register;