refactor: Remove Opts reference from historical backfill

near · Nov 6, 2023 · 099220d · 099220d
1 parent ef2573a
commit 099220d
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/indexer/queryapi_coordinator/src/historical_block_processing.rs b/indexer/queryapi_coordinator/src/historical_block_processing.rs
@@ -1,5 +1,4 @@
 use crate::indexer_types::IndexerFunction;
-use crate::opts::{Opts, Parser};
 use crate::s3;
 use anyhow::{bail, Context};
 use aws_sdk_s3::Client as S3Client;
@@ -37,7 +36,6 @@ pub fn spawn_historical_message_thread(
             process_historical_messages_or_handle_error(
                 block_height,
                 new_indexer_function_copy,
-                Opts::parse(),
                 &redis_connection_manager,
                 &s3_client,
                 &chain_id,
@@ -51,7 +49,6 @@ pub fn spawn_historical_message_thread(
 pub(crate) async fn process_historical_messages_or_handle_error(
     block_height: BlockHeight,
     indexer_function: IndexerFunction,
-    opts: Opts,
     redis_connection_manager: &storage::ConnectionManager,
     s3_client: &S3Client,
     chain_id: &ChainId,
@@ -60,7 +57,6 @@ pub(crate) async fn process_historical_messages_or_handle_error(
     match process_historical_messages(
         block_height,
         indexer_function,
-        opts,
         redis_connection_manager,
         s3_client,
         chain_id,
@@ -83,7 +79,6 @@ pub(crate) async fn process_historical_messages_or_handle_error(
 pub(crate) async fn process_historical_messages(
     block_height: BlockHeight,
     indexer_function: IndexerFunction,
-    opts: Opts,
     redis_connection_manager: &storage::ConnectionManager,
     s3_client: &S3Client,
     chain_id: &ChainId,

diff --git a/indexer/queryapi_coordinator/src/historical_block_processing_integration_tests.rs b/indexer/queryapi_coordinator/src/historical_block_processing_integration_tests.rs
@@ -95,9 +95,9 @@ mod tests {
         let result = historical_block_processing::process_historical_messages(
             fake_block_height + 1,
             indexer_function,
-            opts,
             &redis_connection_manager,
             &s3_client,
+            &opts.chain_id(),
             &json_rpc_client,
         )
         .await;