make provided non sticky for firehose

Author: mangas

chain/arweave/src/chain.rs

@@ -126,7 +126,6 @@ impl Blockchain for Chain {
             )
             .unwrap_or_else(|_| panic!("no adapter for network {}", self.name));
 
-        let firehose_endpoint = self.client.firehose_endpoint()?;
         let logger = self
             .logger_factory
             .subgraph_logger(&deployment)
@@ -136,7 +135,7 @@ impl Blockchain for Chain {
 
         Ok(Box::new(FirehoseBlockStream::new(
             deployment.hash,
-            firehose_endpoint,
+            self.chain_client(),
             store.block_ptr(),
             store.block_cursor(),
             firehose_mapper,

chain/cosmos/src/chain.rs

@@ -123,8 +123,6 @@ impl Blockchain for Chain {
             )
             .unwrap_or_else(|_| panic!("no adapter for network {}", self.name));
 
-        let firehose_endpoint = self.client.firehose_endpoint()?;
-
         let logger = self
             .logger_factory
             .subgraph_logger(&deployment)
@@ -134,7 +132,7 @@ impl Blockchain for Chain {
 
         Ok(Box::new(FirehoseBlockStream::new(
             deployment.hash,
-            firehose_endpoint,
+            self.chain_client(),
             store.block_ptr(),
             store.block_cursor(),
             firehose_mapper,

chain/ethereum/src/chain.rs

@@ -81,8 +81,6 @@ impl BlockStreamBuilder<Chain> for EthereumStreamBuilder {
                 )
             });
 
-        let firehose_endpoint = chain.chain_client().firehose_endpoint()?;
-
         let logger = chain
             .logger_factory
             .subgraph_logger(&deployment)
@@ -92,7 +90,7 @@ impl BlockStreamBuilder<Chain> for EthereumStreamBuilder {
 
         Ok(Box::new(FirehoseBlockStream::new(
             deployment.hash,
-            firehose_endpoint,
+            chain.chain_client(),
             subgraph_current_block,
             block_cursor,
             firehose_mapper,

chain/near/src/chain.rs

@@ -57,8 +57,6 @@ impl BlockStreamBuilder<Chain> for NearStreamBuilder {
             )
             .unwrap_or_else(|_| panic!("no adapter for network {}", chain.name));
 
-        let firehose_endpoint = chain.chain_client().firehose_endpoint()?;
-
         let logger = chain
             .logger_factory
             .subgraph_logger(&deployment)
@@ -68,7 +66,7 @@ impl BlockStreamBuilder<Chain> for NearStreamBuilder {
 
         Ok(Box::new(FirehoseBlockStream::new(
             deployment.hash,
-            firehose_endpoint,
+            chain.chain_client(),
             subgraph_current_block,
             block_cursor,
             firehose_mapper,