From 63d9ca8e87d22b47b1a4136553d44ce6b4a2de7a Mon Sep 17 00:00:00 2001
From: Vladimir Voronkov <vsvoronkov@gmail.com>
Date: Wed, 4 Sep 2024 17:19:11 +0300
Subject: [PATCH] Improve interruption for tax report

---
 workers/loc.api/helpers/get-data-from-api.js | 43 +++++++++++++-------
 1 file changed, 28 insertions(+), 15 deletions(-)

diff --git a/workers/loc.api/helpers/get-data-from-api.js b/workers/loc.api/helpers/get-data-from-api.js
index f2fee277..0f5f8b00 100644
--- a/workers/loc.api/helpers/get-data-from-api.js
+++ b/workers/loc.api/helpers/get-data-from-api.js
@@ -13,6 +13,10 @@ const {
 } = require('./api-errors-testers')
 
 const _delay = (mc = 80000, interrupter) => {
+  if (_isInterrupted(interrupter)) {
+    return Promise.resolve({ isInterrupted: true })
+  }
+
   return new Promise((resolve) => {
     const hasInterrupter = interrupter instanceof Interrupter
     const timeout = setTimeout(() => {
@@ -20,7 +24,7 @@ const _delay = (mc = 80000, interrupter) => {
         interrupter.offInterrupt(onceInterruptHandler)
       }
 
-      resolve()
+      resolve({ isInterrupted: false })
     }, mc)
     const onceInterruptHandler = () => {
       if (!timeout.hasRef()) {
@@ -28,7 +32,7 @@ const _delay = (mc = 80000, interrupter) => {
       }
 
       clearTimeout(timeout)
-      resolve()
+      resolve({ isInterrupted: true })
     }
 
     if (hasInterrupter) {
@@ -116,11 +120,12 @@ module.exports = (
         if (countRateLimitError > 100) {
           throw err
         }
-        if (_isInterrupted(_interrupter)) {
-          return { isInterrupted: true }
-        }
 
-        await _delay(ms, _interrupter)
+        const { isInterrupted } = await _delay(ms, _interrupter)
+
+        if (isInterrupted) {
+          return { isInterrupted }
+        }
 
         continue
       }
@@ -130,11 +135,12 @@ module.exports = (
         if (countNonceSmallError > 20) {
           throw err
         }
-        if (_isInterrupted(_interrupter)) {
-          return { isInterrupted: true }
-        }
 
-        await _delay(1000, _interrupter)
+        const { isInterrupted } = await _delay(1000, _interrupter)
+
+        if (isInterrupted) {
+          return { isInterrupted }
+        }
 
         continue
       }
@@ -156,7 +162,13 @@ module.exports = (
           await wsEventEmitter.emitENetError(callerName)
         }
 
-        await _delay(eNetErrorAttemptsTimeoutMs, _interrupter)
+        const {
+          isInterrupted
+        } = await _delay(eNetErrorAttemptsTimeoutMs, _interrupter)
+
+        if (isInterrupted) {
+          return { isInterrupted }
+        }
 
         continue
       }
@@ -170,11 +182,12 @@ module.exports = (
       ) {
         throw err
       }
-      if (_isInterrupted(_interrupter)) {
-        return { isInterrupted: true }
-      }
 
-      await _delay(10000, _interrupter)
+      const { isInterrupted } = await _delay(10000, _interrupter)
+
+      if (isInterrupted) {
+        return { isInterrupted }
+      }
     }
   }