diff --git a/transport.js b/transport.js index 3b3c9d5..7e666f3 100644 --- a/transport.js +++ b/transport.js @@ -107,7 +107,7 @@ function init(cb) { } async function sleepAndResend(partner, msg, params, retry) { - if ((retry || 0) > maxSendRetry) { + if (retry > maxSendRetry) { logger.verbose('Retry exceeded', { params, retry: retry || 0, @@ -120,9 +120,18 @@ async function sleepAndResend(partner, msg, params, retry) { } function send(partner, msg, params, retry) { - logger.verbose('Got response from CORE', { - partner: partner, msg: msg, params: params, retry: retry || 0, - }); + if (retry) { + logger.verbose('F39C9082: Resending', { + partner, + msg, + params, + retry, + }) + } else { + logger.verbose('Got response from CORE', { + partner: partner, msg: msg, params: params, retry: retry || 0, + }); + } if (!params || !params.reverse_url) { logger.verbose('Undefined reverse_url, not forwarding message to partner'); @@ -148,7 +157,7 @@ function send(partner, msg, params, retry) { request(reqOptions, function(err, res, body) { if (err) { logger.warn('Error sending reverse report to partner', {request: reqOptions, err: err}); - sleepAndResend(partner, msg, params, retry); + sleepAndResend(partner, msg, params, retry || 0); return; }