fix: check for legacy_scalar field

edgeandnode · Nov 5, 2024 · ca61e47 · ca61e47
1 parent 674ae61
commit ca61e47
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/bin/main.rs b/src/bin/main.rs
@@ -183,6 +183,9 @@ async fn handle_source_msg(
         } => {
             if aggregation_timestamp >= start_timestamp {
                 for indexer_query in &data.indexer_queries {
+                    if indexer_query.legacy_scalar.unwrap_or(false) {
+                        continue;
+                    }
                     let key = IndexerFeesKey {
                         signer: Address::from_slice(&data.receipt_signer)?,
                         receiver: Address::from_slice(&indexer_query.indexer)?,

diff --git a/src/messages.rs b/src/messages.rs
@@ -49,8 +49,8 @@ pub struct IndexerQueryProtobuf {
     pub indexer_errors: String,
     #[prost(uint64, tag = "11")]
     pub blocks_behind: u64,
-    #[prost(bool, tag = "12")]
-    pub legacy_scalar: bool,
+    #[prost(bool, optional, tag = "12")]
+    pub legacy_scalar: Option<bool>,
 }
 
 #[derive(prost::Message)]