fix(class/eventManagement/dispatcher): return a promise in interval ctx

MyUnisoft · May 30, 2024 · 044028b · 044028b
1 parent eebe283
commit 044028b
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 19 deletions.
diff --git a/src/class/eventManagement/dispatcher.class.ts b/src/class/eventManagement/dispatcher.class.ts
@@ -263,30 +263,26 @@ export class Dispatcher<T extends GenericEvent = GenericEvent> extends EventEmit
         }
       });
 
-    this.resolveTransactionsInterval = setInterval(async() => {
+    this.resolveTransactionsInterval = setInterval(() => {
       if (!this.isWorking) {
         return;
       }
 
-      try {
-        await this.transactionHandler.resolveTransactions();
-      }
-      catch (error) {
-        this.logger.error({ error: error.stack }, "Failed at resolving transactions");
-      }
+      new Promise(() => {
+        this.transactionHandler.resolveTransactions()
+          .catch((error) => this.logger.error({ error: error.stack }, "Failed at resolving transactions"));
+      });
     }, options.checkTransactionInterval ?? RESOLVE_TRANSACTION_INTERVAL).unref();
 
-    this.pingIntervalTimer = setInterval(async() => {
-      try {
-        if (!this.isWorking) {
-          return;
-        }
-
-        await this.ping();
-      }
-      catch (error) {
-        this.logger.error({ error: error.stack }, "Failed sending pings");
+    this.pingIntervalTimer = setInterval(() => {
+      if (!this.isWorking) {
+        return;
       }
+
+      new Promise(() => {
+        this.ping()
+          .catch((error) => this.logger.error({ error: error.stack }, "Failed sending pings"));
+      });
     }, this.pingInterval).unref();
 
     this.checkLastActivityIntervalTimer = setInterval(async() => {

diff --git a/src/class/eventManagement/dispatcher/transaction-handler.class.ts b/src/class/eventManagement/dispatcher/transaction-handler.class.ts
@@ -643,7 +643,6 @@ export class TransactionHandler<T extends GenericEvent = GenericEvent> {
       this.backupIncomerTransactionStore.getTransactions()
     ]);
 
-
     const toResolve = [];
     const incomerStateToUpdate = new Set<string>();
     for (const incomer of incomers) {

diff --git a/src/class/eventManagement/incomer.class.ts b/src/class/eventManagement/incomer.class.ts
@@ -8,7 +8,7 @@ import {
   getRedis,
   Channel
 } from "@myunisoft/redis";
-import { Logger, pino } from "pino";
+import { pino } from "pino";
 import { P, match } from "ts-pattern";
 import { ValidateFunction } from "ajv";