feat: Add "StartBlock::Continue" to registry contract/types

block-streamer/src/block_stream.rs

@@ -294,7 +294,7 @@ mod tests {
             )
             .unwrap(),
             function_name: "test".to_string(),
-            indexer_rule: registry_types::IndexerRule {
+            indexer_rule: registry_types::OldIndexerRule {
                 indexer_rule_kind: registry_types::IndexerRuleKind::Action,
                 matching_rule: registry_types::MatchingRule::ActionAny {
                     affected_account_id: "queryapi.dataplatform.near".to_string(),

block-streamer/src/indexer_config.rs

@@ -2,7 +2,7 @@ use near_lake_framework::near_indexer_primitives::types::AccountId;
 use std::collections::hash_map::DefaultHasher;
 use std::hash::{Hash, Hasher};
 
-use registry_types::IndexerRule;
+use registry_types::OldIndexerRule as IndexerRule;
 
 #[derive(serde::Serialize, serde::Deserialize, Clone, Debug)]
 pub struct IndexerConfig {

block-streamer/src/rules/mod.rs

@@ -3,7 +3,7 @@ pub mod outcomes_reducer;
 pub mod types;
 
 use near_lake_framework::near_indexer_primitives::StreamerMessage;
-use registry_types::{IndexerRule, MatchingRule};
+use registry_types::{MatchingRule, OldIndexerRule as IndexerRule};
 
 use types::{ChainId, IndexerRuleMatch};
 

block-streamer/src/rules/outcomes_reducer.rs

@@ -115,7 +115,7 @@ fn build_indexer_rule_match_payload(
 
 #[cfg(test)]
 mod tests {
-    use registry_types::{IndexerRule, IndexerRuleKind, MatchingRule, Status};
+    use registry_types::{IndexerRuleKind, MatchingRule, OldIndexerRule as IndexerRule, Status};
 
     use crate::rules::outcomes_reducer::reduce_indexer_rule_matches_from_outcomes;
     use crate::rules::types::{ChainId, IndexerRuleMatch};

block-streamer/src/server/block_streamer_service.rs

@@ -6,7 +6,7 @@ use tonic::{Request, Response, Status};
 
 use crate::indexer_config::IndexerConfig;
 use crate::rules::types::ChainId;
-use registry_types::{IndexerRule, IndexerRuleKind, MatchingRule};
+use registry_types::{IndexerRuleKind, MatchingRule, OldIndexerRule as IndexerRule};
 
 use crate::block_stream;
 use crate::server::blockstreamer;

coordinator/src/main.rs

@@ -255,7 +255,7 @@ mod tests {
     use mockall::predicate;
     use std::collections::HashMap;
 
-    use registry_types::{IndexerRule, IndexerRuleKind, MatchingRule, Status};
+    use registry_types::{IndexerRuleKind, MatchingRule, OldIndexerRule as IndexerRule, Status};
 
     use crate::registry::IndexerConfig;
 

coordinator/src/migration.rs

@@ -281,7 +281,7 @@ mod tests {
     use std::collections::HashMap;
 
     use mockall::predicate;
-    use registry_types::{IndexerRule, IndexerRuleKind, MatchingRule, Status};
+    use registry_types::{IndexerRuleKind, MatchingRule, OldIndexerRule, Status};
 
     use crate::registry::IndexerConfig;
 
@@ -296,7 +296,7 @@ mod tests {
                     function_name: "test".to_string(),
                     code: String::new(),
                     schema: Some(String::new()),
-                    filter: IndexerRule {
+                    filter: OldIndexerRule {
                         id: None,
                         name: None,
                         indexer_rule_kind: IndexerRuleKind::Action,
@@ -369,7 +369,7 @@ mod tests {
                     function_name: "test".to_string(),
                     code: String::new(),
                     schema: Some(String::new()),
-                    filter: IndexerRule {
+                    filter: OldIndexerRule {
                         id: None,
                         name: None,
                         indexer_rule_kind: IndexerRuleKind::Action,

coordinator/src/registry.rs

@@ -8,7 +8,9 @@ use near_jsonrpc_client::JsonRpcClient;
 use near_jsonrpc_primitives::types::query::QueryResponseKind;
 use near_primitives::types::{AccountId, BlockReference, Finality, FunctionArgs};
 use near_primitives::views::QueryRequest;
-use registry_types::{AccountOrAllIndexers, IndexerRule};
+use registry_types::{
+    OldAccountOrAllIndexers as AccountOrAllIndexers, OldIndexerRule as IndexerRule,
+};
 
 use crate::utils::exponential_retry;
 
@@ -69,7 +71,7 @@ impl RegistryImpl {
 
     fn enrich_indexer_registry(
         &self,
-        registry: HashMap<AccountId, HashMap<String, registry_types::IndexerConfig>>,
+        registry: HashMap<AccountId, HashMap<String, registry_types::OldIndexerConfig>>,
     ) -> IndexerRegistry {
         registry
             .into_iter()