format

aptos-labs · Feb 7, 2025 · 895aced · 895aced
1 parent ca61095
commit 895aced
Show file tree

Hide file tree

Showing 22 changed files with 254 additions and 68 deletions.
diff --git a/rust/sdk-processor/src/parquet_processors/parquet_account_transactions_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_account_transactions_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -110,8 +111,16 @@ impl ProcessorTrait for ParquetAccountTransactionsProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_ans_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_ans_processor.rs
@@ -123,8 +123,16 @@ impl ProcessorTrait for ParquetAnsProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_default_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_default_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -117,8 +118,16 @@ impl ProcessorTrait for ParquetDefaultProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_events_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_events_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -108,8 +109,16 @@ impl ProcessorTrait for ParquetEventsProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_fungible_asset_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_fungible_asset_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -115,8 +116,16 @@ impl ProcessorTrait for ParquetFungibleAssetProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_objects_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_objects_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -108,8 +109,16 @@ impl ProcessorTrait for ParquetObjectsProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_stake_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_stake_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -113,8 +114,16 @@ impl ProcessorTrait for ParquetStakeProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_token_v2_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_token_v2_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -117,8 +118,16 @@ impl ProcessorTrait for ParquetTokenV2Processor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_transaction_metadata_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_transaction_metadata_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -109,8 +110,16 @@ impl ProcessorTrait for ParquetTransactionMetadataProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/parquet_processors/parquet_user_transaction_processor.rs b/rust/sdk-processor/src/parquet_processors/parquet_user_transaction_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     parquet_processors::{
@@ -109,8 +110,16 @@ impl ProcessorTrait for ParquetUserTransactionsProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/processors/account_restoration_processor.rs b/rust/sdk-processor/src/processors/account_restoration_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     steps::{
@@ -101,8 +102,16 @@ impl ProcessorTrait for AccountRestorationProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/processors/account_transactions_processor.rs b/rust/sdk-processor/src/processors/account_transactions_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     steps::{
@@ -100,8 +101,16 @@ impl ProcessorTrait for AccountTransactionsProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/processors/ans_processor.rs b/rust/sdk-processor/src/processors/ans_processor.rs
@@ -115,8 +115,16 @@ impl ProcessorTrait for AnsProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })

diff --git a/rust/sdk-processor/src/processors/default_processor.rs b/rust/sdk-processor/src/processors/default_processor.rs
@@ -1,6 +1,7 @@
 use crate::{
     config::{
-        db_config::DbConfig, indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
+        db_config::DbConfig,
+        indexer_processor_config::{IndexerProcessorConfig, ProcessorMode},
         processor_config::ProcessorConfig,
     },
     steps::{
@@ -103,8 +104,16 @@ impl ProcessorTrait for DefaultProcessor {
             starting_version: Some(starting_version),
             request_ending_version: match self.config.mode {
                 ProcessorMode::Default => None,
-                ProcessorMode::Backfill => self.config.backfill_config.as_ref().map(|c| c.ending_version),
-                ProcessorMode::Testing => self.config.testing_config.as_ref().map(|c| c.ending_version),
+                ProcessorMode::Backfill => self
+                    .config
+                    .backfill_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
+                ProcessorMode::Testing => self
+                    .config
+                    .testing_config
+                    .as_ref()
+                    .map(|c| c.ending_version),
             },
             ..self.config.transaction_stream_config.clone()
         })