From c8e05bce84aa568e5c3d0999d0f4b2723cde36b3 Mon Sep 17 00:00:00 2001 From: javiersuweijie Date: Tue, 13 Aug 2024 14:38:05 +0800 Subject: [PATCH] chore: add start from block --- eth/.env_example | 1 + eth/src/Shuttle.ts | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/eth/.env_example b/eth/.env_example index 8d69882..3c62db3 100644 --- a/eth/.env_example +++ b/eth/.env_example @@ -12,6 +12,7 @@ ETH_URL="https://ropsten.infura.io/v3/{API_KEY}" ETH_BLOCK_CONFIRMATION="7" ETH_BLOCK_LOAD_UNIT="10" ETH_BLOCK_SECOND="10" +ETH_START_FROM="0" FEE_RATE="0.001" REDIS_URL="redis://127.0.0.1:6379" diff --git a/eth/src/Shuttle.ts b/eth/src/Shuttle.ts index 8655c48..ab19d6f 100644 --- a/eth/src/Shuttle.ts +++ b/eth/src/Shuttle.ts @@ -25,6 +25,7 @@ const KEY_QUEUE_MISSING_TX = 'queue_missing_tx'; const REDIS_URL = process.env.REDIS_URL as string; const ETH_BLOCK_SECOND = parseInt(process.env.ETH_BLOCK_SECOND as string); const ETH_BLOCK_LOAD_UNIT = parseInt(process.env.ETH_BLOCK_LOAD_UNIT as string); +const ETH_START_FROM = (process.env.ETH_START_FROM as string) || '0'; const SLACK_NOTI_NETWORK = process.env.SLACK_NOTI_NETWORK; const SLACK_NOTI_ETH_ASSET = process.env.SLACK_NOTI_ETH_ASSET; @@ -155,7 +156,9 @@ class Shuttle { // rebroadcast the tx with same sequence. await this.checkTxQueue(); - const lastHeight = parseInt((await this.getAsync(KEY_LAST_HEIGHT)) || '0'); + const lastHeight = parseInt( + (await this.getAsync(KEY_LAST_HEIGHT)) || ETH_START_FROM + ); const missingTxHashes = await this.loadMissingTxHashes(); const [newLastHeight, monitoringDatas] = await this.monitoring.load( lastHeight,