add detection job

rosen-bridge · Nov 11, 2024 · 7383baa · 7383baa
1 parent eb5293e
commit 7383baa
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 0 deletions.
diff --git a/src/configs/Configs.ts b/src/configs/Configs.ts
@@ -204,6 +204,7 @@ class Configs {
   static multiSigCleanUpInterval = 120; // seconds
   static tssInstanceRestartGap = 5; // seconds
   static tssUpdateInterval = 10; // seconds
+  static detectionUpdateInterval = 10; // seconds
   static timeoutProcessorInterval = getConfigIntKeyOrDefault(
     'intervals.timeoutProcessorInterval',
     3600

diff --git a/src/jobs/runProcessors.ts b/src/jobs/runProcessors.ts
@@ -7,6 +7,10 @@ import ColdStorageConfig from '../coldStorage/ColdStorageConfig';
 import TxAgreement from '../agreement/TxAgreement';
 import ArbitraryProcessor from '../arbitrary/ArbitraryProcessor';
 import EventSynchronization from '../synchronization/EventSynchronization';
+import DetectionHandler from '../handlers/DetectionHandler';
+import { DefaultLoggerFactory } from '@rosen-bridge/abstract-logger';
+
+const logger = DefaultLoggerFactory.getInstance().getLogger(import.meta.url);
 
 /**
  * sends generated tx to agreement
@@ -119,6 +123,21 @@ const eventSyncJob = async () => {
   setTimeout(eventSyncJob, Configs.eventSyncInterval * 1000);
 };
 
+/**
+ * runs Detection update job
+ */
+const detectionUpdateJob = () => {
+  DetectionHandler.getInstance()
+    .update()
+    .then(() =>
+      setTimeout(detectionUpdateJob, Configs.detectionUpdateInterval * 1000)
+    )
+    .catch((e) => {
+      logger.error(`Detection update job failed with error: ${e}`);
+      setTimeout(detectionUpdateJob, Configs.detectionUpdateInterval * 1000);
+    });
+};
+
 /**
  * runs all processors and their related jobs
  */
@@ -133,6 +152,7 @@ const runProcessors = () => {
     Configs.requeueWaitingEventsInterval * 1000
   );
   setTimeout(eventSyncJob, Configs.eventSyncInterval * 1000);
+  setTimeout(detectionUpdateJob, Configs.detectionUpdateInterval * 1000);
 };
 
 export { runProcessors };