chore: add scan mempool chunk delay

oraichain · Oct 3, 2024 · 66ccb84 · 66ccb84
1 parent 1dcbd11
commit 66ccb84
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/packages/orchestrator/src/constants.ts b/packages/orchestrator/src/constants.ts
@@ -1,5 +1,6 @@
 export const RELAY_HEADER_BATCH_SIZE = 250;
 export const SCAN_MEMPOOL_CHUNK_SIZE = 1000;
+export const SCAN_MEMPOOL_CHUNK_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
@@ -37,6 +37,7 @@ import {
   RELAY_DEPOSIT_BLOCKS_SIZE,
   RELAY_HEADER_BATCH_SIZE,
   RETRY_DELAY,
+  SCAN_MEMPOOL_CHUNK_INTERVAL_DELAY,
   SCAN_MEMPOOL_CHUNK_SIZE,
 } from "../../constants";
 import { chunkArray } from "../../utils/array";
@@ -335,7 +336,6 @@ class RelayerService implements RelayerInterface {
       const txChunks = chunkArray(mempoolTxs, SCAN_MEMPOOL_CHUNK_SIZE);
       let i = 0;
       for (const txChunk of txChunks) {
-        console.log("Chunk", i);
         i++;
         let detailMempoolTxs: BitcoinTransaction[] = await retry(
           async () => {
@@ -351,6 +351,11 @@ class RelayerService implements RelayerInterface {
           3,
           RETRY_DELAY
         );
+        console.log(
+          "Chunk",
+          i,
+          detailMempoolTxs.map((item) => item.hash)
+        );
 
         for (const tx of detailMempoolTxs) {
           let txid = tx.txid;
@@ -397,6 +402,8 @@ class RelayerService implements RelayerInterface {
             );
           }
         }
+
+        await setTimeout(SCAN_MEMPOOL_CHUNK_INTERVAL_DELAY);
       }
     } catch (err) {
       this.logger.error(`[SCAN_TX_FROM_MEMPOOL] ${err?.message}`);