chain,graph : use chain_head_ptr method from adapter

Author: incrypto32

chain/arweave/src/chain.rs

@@ -203,6 +203,10 @@ impl TriggersAdapterTrait<Chain> for TriggersAdapter {
         panic!("Should never be called since not used by FirehoseBlockStream")
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        unimplemented!()
+    }
+
     async fn triggers_in_block(
         &self,
         logger: &Logger,

chain/cosmos/src/chain.rs

@@ -197,6 +197,10 @@ impl TriggersAdapterTrait<Chain> for TriggersAdapter {
         panic!("Should never be called since not used by FirehoseBlockStream")
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        unimplemented!()
+    }
+
     async fn scan_triggers(
         &self,
         _from: BlockNumber,

chain/ethereum/src/chain.rs

@@ -776,6 +776,11 @@ impl TriggersAdapterTrait<Chain> for TriggersAdapter {
         .await
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        let chain_store = self.chain_store.clone();
+        chain_store.chain_head_ptr().await
+    }
+
     async fn triggers_in_block(
         &self,
         logger: &Logger,

chain/near/src/chain.rs

@@ -336,6 +336,10 @@ impl TriggersAdapterTrait<Chain> for TriggersAdapter {
         panic!("Should never be called since not used by FirehoseBlockStream")
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        unimplemented!()
+    }
+
     async fn triggers_in_block(
         &self,
         logger: &Logger,

chain/starknet/src/chain.rs

@@ -383,6 +383,10 @@ impl TriggersAdapterTrait<Chain> for TriggersAdapter {
         panic!("Should never be called since FirehoseBlockStream cannot resolve it")
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        unimplemented!()
+    }
+
     // Returns a sequence of blocks in increasing order of block number.
     // Each block will include all of its triggers that match the given `filter`.
     // The sequence may omit blocks that contain no triggers,

chain/substreams/src/trigger.rs

@@ -137,6 +137,10 @@ impl blockchain::TriggersAdapter<Chain> for TriggersAdapter {
         unimplemented!()
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        unimplemented!()
+    }
+
     async fn scan_triggers(
         &self,
         _from: BlockNumber,

graph/src/blockchain/block_stream.rs

@@ -353,31 +353,11 @@ impl<C: Blockchain> TriggersAdapter<C> for TriggersAdapterWrapper<C> {
     async fn parent_ptr(&self, block: &BlockPtr) -> Result<Option<BlockPtr>, Error> {
         self.adapter.parent_ptr(block).await
     }
-}
 
-// fn create_mock_trigger<C: Blockchain>() -> Trigger<C> {
-//     let entity = create_mock_entity();
-//     Trigger::Subgraph(subgraph::TriggerData {
-//         source: DeploymentHash::new("test").unwrap(),
-//         entity,
-//         entity_type: "User".to_string(),
-//     })
-// }
-
-// fn create_mock_entity() -> Entity {
-//     let schema = InputSchema::parse_latest(
-//         "type User @entity { id: String!, val: String! }",
-//         DeploymentHash::new("test").unwrap(),
-//     )
-//     .unwrap();
-
-//     schema
-//         .make_entity(vec![
-//             ("id".into(), Value::String("id".to_owned())),
-//             ("val".into(), Value::String("content".to_owned())),
-//         ])
-//         .unwrap()
-// }
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        self.adapter.chain_head_ptr().await
+    }
+}
 
 #[async_trait]
 pub trait TriggersAdapter<C: Blockchain>: Send + Sync {
@@ -419,6 +399,9 @@ pub trait TriggersAdapter<C: Blockchain>: Send + Sync {
 
     /// Get pointer to parent of `block`. This is called when reverting `block`.
     async fn parent_ptr(&self, block: &BlockPtr) -> Result<Option<BlockPtr>, Error>;
+
+    /// Get pointer to parent of `block`. This is called when reverting `block`.
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error>;
 }
 
 #[async_trait]

graph/src/blockchain/mock.rs

@@ -228,6 +228,11 @@ impl TriggersAdapter<MockBlockchain> for MockTriggersAdapter {
         todo!()
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        unimplemented!()
+    }
+    
+
     async fn scan_triggers(
         &self,
         from: crate::components::store::BlockNumber,

graph/src/blockchain/polling_block_stream.rs

@@ -218,7 +218,7 @@ where
         let max_block_range_size = self.max_block_range_size;
 
         // Get pointers from database for comparison
-        let head_ptr_opt = ctx.chain_store.chain_head_ptr().await?;
+        let head_ptr_opt = ctx.adapter.chain_head_ptr().await?;
         let subgraph_ptr = self.current_block.clone();
 
         // If chain head ptr is not set yet

tests/src/fixture/mod.rs

@@ -1002,6 +1002,10 @@ impl<C: Blockchain> TriggersAdapter<C> for MockTriggersAdapter<C> {
         todo!()
     }
 
+    async fn chain_head_ptr(&self) -> Result<Option<BlockPtr>, Error> {
+        todo!()
+    }
+
     async fn scan_triggers(
         &self,
         _from: BlockNumber,