implement recursive auto sync for grafts

Author: dwerner

Cargo.lock

@@ -298,7 +298,7 @@ pub struct Chain {
     reorg_threshold: BlockNumber,
     polling_ingestor_interval: Duration,
     pub is_ingestible: bool,
-    block_stream_builder: Arc<dyn BlockStreamBuilder<Self>>,
+    pub block_stream_builder: Arc<dyn BlockStreamBuilder<Self>>,
     block_refetcher: Arc<dyn BlockRefetcher<Self>>,
     adapter_selector: Arc<dyn TriggersAdapterSelector<Self>>,
     runtime_adapter_builder: Arc<dyn RuntimeAdapterBuilder>,

chain/ethereum/src/chain.rs

@@ -19,7 +19,8 @@ pub use buffered_call_cache::BufferedCallCache;
 
 // ETHDEP: These concrete types should probably not be exposed.
 pub use data_source::{
-    BlockHandlerFilter, DataSource, DataSourceTemplate, Mapping, MappingABI, TemplateSource,
+    BlockHandlerFilter, DataSource, DataSourceTemplate, DecoderHook, Mapping, MappingABI,
+    TemplateSource,
 };
 
 pub mod chain;

chain/ethereum/src/lib.rs

@@ -3,6 +3,6 @@ pub mod polling_monitor;
 mod subgraph;
 
 pub use crate::subgraph::{
-    SubgraphAssignmentProvider, SubgraphInstanceManager, SubgraphRegistrar, SubgraphRunner,
-    SubgraphTriggerProcessor,
+    create_subgraph_version, SubgraphAssignmentProvider, SubgraphInstanceManager,
+    SubgraphRegistrar, SubgraphRunner, SubgraphTriggerProcessor,
 };

core/src/lib.rs

@@ -63,7 +63,7 @@ impl<S: SubgraphStore> SubgraphInstanceManagerTrait for SubgraphInstanceManager<
                         )
                         .await?;
 
-                    self.start_subgraph_inner(logger, loc, runner).await
+                    self.start_subgraph_thread(logger, loc, runner).await
                 }
                 BlockchainKind::Ethereum => {
                     let runner = instance_manager
@@ -77,7 +77,7 @@ impl<S: SubgraphStore> SubgraphInstanceManagerTrait for SubgraphInstanceManager<
                         )
                         .await?;
 
-                    self.start_subgraph_inner(logger, loc, runner).await
+                    self.start_subgraph_thread(logger, loc, runner).await
                 }
                 BlockchainKind::Near => {
                     let runner = instance_manager
@@ -91,7 +91,7 @@ impl<S: SubgraphStore> SubgraphInstanceManagerTrait for SubgraphInstanceManager<
                         )
                         .await?;
 
-                    self.start_subgraph_inner(logger, loc, runner).await
+                    self.start_subgraph_thread(logger, loc, runner).await
                 }
                 BlockchainKind::Cosmos => {
                     let runner = instance_manager
@@ -105,7 +105,7 @@ impl<S: SubgraphStore> SubgraphInstanceManagerTrait for SubgraphInstanceManager<
                         )
                         .await?;
 
-                    self.start_subgraph_inner(logger, loc, runner).await
+                    self.start_subgraph_thread(logger, loc, runner).await
                 }
                 BlockchainKind::Substreams => {
                     let runner = instance_manager
@@ -119,7 +119,7 @@ impl<S: SubgraphStore> SubgraphInstanceManagerTrait for SubgraphInstanceManager<
                         )
                         .await?;
 
-                    self.start_subgraph_inner(logger, loc, runner).await
+                    self.start_subgraph_thread(logger, loc, runner).await
                 }
                 BlockchainKind::Starknet => {
                     let runner = instance_manager
@@ -133,7 +133,7 @@ impl<S: SubgraphStore> SubgraphInstanceManagerTrait for SubgraphInstanceManager<
                         )
                         .await?;
 
-                    self.start_subgraph_inner(logger, loc, runner).await
+                    self.start_subgraph_thread(logger, loc, runner).await
                 }
             }
         };
@@ -466,7 +466,7 @@ impl<S: SubgraphStore> SubgraphInstanceManager<S> {
         ))
     }
 
-    async fn start_subgraph_inner<C: Blockchain>(
+    pub async fn start_subgraph_thread<C: Blockchain>(
         &self,
         logger: Logger,
         deployment: DeploymentLocator,
@@ -504,4 +504,12 @@ impl<S: SubgraphStore> SubgraphInstanceManager<S> {
 
         Ok(())
     }
+
+    pub fn subgraph_logger(&self, loc: &DeploymentLocator) -> Logger {
+        self.logger_factory.subgraph_logger(loc)
+    }
+
+    pub fn get_env_vars(&self) -> Arc<EnvVars> {
+        self.env_vars.cheap_clone()
+    }
 }

core/src/subgraph/instance_manager.rs

@@ -12,6 +12,6 @@ mod trigger_processor;
 
 pub use self::instance_manager::SubgraphInstanceManager;
 pub use self::provider::SubgraphAssignmentProvider;
-pub use self::registrar::SubgraphRegistrar;
+pub use self::registrar::{create_subgraph_version, SubgraphRegistrar};
 pub use self::runner::SubgraphRunner;
 pub use self::trigger_processor::*;