From e54de6da037292b3f6b66f38bf42a7be0f9ff8d5 Mon Sep 17 00:00:00 2001
From: Adhidarma Hadiwinoto <gua@adhisimon.org>
Date: Thu, 19 Apr 2018 18:53:23 +0700
Subject: [PATCH] perbaikan dan debug resend delay
---
lib/partner.js | 19 +++++++++++++++----
1 file changed, 15 insertions(+), 4 deletions(-)
diff --git a/lib/partner.js b/lib/partner.js
index a7707f7..fb2b141 100644
--- a/lib/partner.js
+++ b/lib/partner.js
@@ -185,13 +185,24 @@ function report(data) {
matrix.last_report_to_core = data;
pull.report(data);
- if (!resendDelay.isEnabled()) return;
+ if (!data.task) {
+ return;
+ }
+
+ const task = data.task;
+
+ if (!resendDelay.isEnabled()) {
+ logger.verbose('Skipping resend delay because resend delay has not configured yet', {trx_id: task.trx_id, destination: task.destination, product: task.product});
+ return;
+ }
- if (data.task && data.rc && data.rc === '68') {
- resendDelay.register(data.task, advice);
+ if (data.rc && data.rc === '68') {
+ logger.verbose('Registering resend delay', {trx_id: task.trx_id, destination: task.destination, product: task.product})
+ resendDelay.register(task, advice);
}
else {
- resendDelay.cancel(data.trx_id);
+ logger.verbose('Canceling resend delay', {trx_id: task.trx_id, destination: task.destination, product: task.product})
+ resendDelay.cancel(task.trx_id);
}
}
--
1.9.0