enha: make how many blocks relayer fetches configurable (#1321)

cloudwalk · Jul 2, 2024 · 4984bad · 4984bad
1 parent 7a55af7
commit 4984bad
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 5 deletions.
diff --git a/...a63a16385eeef3c13a718edf714d5830ee51.json → ...d2aaa1596f4ce835dc0b3b8e450e5720bccf.json b/...a63a16385eeef3c13a718edf714d5830ee51.json → ...d2aaa1596f4ce835dc0b3b8e450e5720bccf.json
diff --git a/src/config.rs b/src/config.rs
@@ -386,6 +386,9 @@ pub struct ExternalRelayerServerConfig {
 
     #[arg(long = "signer", env = "SIGNER")]
     pub signer: String,
+
+    #[arg(long = "blocks-to-fetch", env = "BLOCKS_TO_FETCH", default_value = "3")]
+    pub blocks_to_fetch: u64,
 }
 
 impl ExternalRelayerServerConfig {

diff --git a/src/eth/relayer/external.rs b/src/eth/relayer/external.rs
@@ -126,6 +126,8 @@ pub struct ExternalRelayer {
     stratus_chain: BlockchainClient,
 
     signer: TxSigner,
+
+    blocks_to_fetch: u64,
 }
 
 impl ExternalRelayer {
@@ -148,6 +150,7 @@ impl ExternalRelayer {
             stratus_chain: BlockchainClient::new_http(&config.stratus_rpc, config.rpc_timeout).await?,
             pool,
             signer,
+            blocks_to_fetch: config.blocks_to_fetch,
         })
     }
 
@@ -265,13 +268,14 @@ impl ExternalRelayer {
                 FROM relayer_blocks
                 WHERE finished = false
                 ORDER BY number ASC
-                LIMIT 3
+                LIMIT $1
             )
             UPDATE relayer_blocks r
                 SET started = true
                 FROM cte
                 WHERE r.number = cte.number
-                RETURNING r.number, r.payload"#
+                RETURNING r.number, r.payload"#,
+            self.blocks_to_fetch as i64
         )
         .fetch_all(&self.pool)
         .await?;