add submit relay checkpoint interval delay

oraichain · Oct 3, 2024 · 356b42d · 356b42d
1 parent 360b712
commit 356b42d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/packages/orchestrator/src/constants.ts b/packages/orchestrator/src/constants.ts
@@ -2,6 +2,7 @@ export const RELAY_HEADER_BATCH_SIZE = 250;
 export const SCAN_MEMPOOL_CHUNK_SIZE = 1000;
 export const SCAN_MEMPOOL_CHUNK_INTERVAL_DELAY = 100;
 export const SCAN_BLOCK_TXS_INTERVAL_DELAY = 100;
+export const SUBMIT_RELAY_CHECKPOINT_INTERVAL_DELAY = 100;
 export const RELAY_DEPOSIT_BLOCKS_SIZE = 200; // 10 blocks
 export const RETRY_DELAY = 1000; // 1 second
 export const ITERATION_DELAY = {

diff --git a/packages/orchestrator/src/services/relayer/index.ts b/packages/orchestrator/src/services/relayer/index.ts
@@ -40,6 +40,7 @@ import {
   SCAN_BLOCK_TXS_INTERVAL_DELAY,
   SCAN_MEMPOOL_CHUNK_INTERVAL_DELAY,
   SCAN_MEMPOOL_CHUNK_SIZE,
+  SUBMIT_RELAY_CHECKPOINT_INTERVAL_DELAY,
 } from "../../constants";
 import { chunkArray } from "../../utils/array";
 import {
@@ -585,6 +586,8 @@ class RelayerService implements RelayerInterface {
             relayed[checkpoint] = true;
             console.log(`Relayed checkpoint tx ${tx}`);
           } catch (err) {}
+
+          await setTimeout(SUBMIT_RELAY_CHECKPOINT_INTERVAL_DELAY);
         }
       } catch (err) {
         this.logger.error(`[RELAY_CHECKPOINT] ${err?.message}`);