chain, graph, store: Add automocks for store traits

This required `ChainStore::upsert_blocks` to use a `'static` lifetime
for its input stream and output error types. The only place where
`upsert_blocks` is used is in `BlockIngestor`, which can safely use
`'static`, as operates on a static reference of itself.

Author: Jannis

chain/ethereum/src/block_ingestor.rs

@@ -146,7 +146,7 @@ where
             })
     }
 
-    fn do_poll<'a>(&'a self) -> impl Future<Item = (), Error = EthereumAdapterError> + 'a {
+    fn do_poll(&'static self) -> impl Future<Item = (), Error = EthereumAdapterError> + 'static {
         trace!(self.logger, "BlockIngestor::do_poll");
         let network_name = self.network_name.clone();
         // Get chain head ptr from store
@@ -248,12 +248,11 @@ where
     /// head block pointer. If missing blocks prevent such an update, return a Vec with at least
     /// one of the missing blocks' hashes.
     fn ingest_blocks<
-        'a,
-        B: Stream<Item = EthereumBlock, Error = EthereumAdapterError> + Send + 'a,
+        B: Stream<Item = EthereumBlock, Error = EthereumAdapterError> + Send + 'static,
     >(
-        &'a self,
+        &'static self,
         blocks: B,
-    ) -> impl Future<Item = Vec<H256>, Error = EthereumAdapterError> + Send + 'a {
+    ) -> impl Future<Item = Vec<H256>, Error = EthereumAdapterError> + Send + 'static {
         self.chain_store.upsert_blocks(blocks).and_then(move |()| {
             self.chain_store
                 .attempt_chain_head_update(self.ancestor_count)
@@ -266,10 +265,10 @@ where
 
     /// Requests the specified blocks via web3, returning them in a stream (potentially out of
     /// order).
-    fn get_blocks<'a>(
-        &'a self,
+    fn get_blocks(
+        &'static self,
         block_hashes: &[H256],
-    ) -> Box<dyn Stream<Item = EthereumBlock, Error = EthereumAdapterError> + Send + 'a> {
+    ) -> Box<dyn Stream<Item = EthereumBlock, Error = EthereumAdapterError> + Send + 'static> {
         let logger = self.logger.clone();
         let eth_adapter = self.eth_adapter.clone();
 

graph/src/components/store.rs

@@ -1172,6 +1172,7 @@ pub trait Store: Send + Sync + 'static {
     ) -> Result<Option<BlockNumber>, StoreError>;
 }
 
+#[automock]
 pub trait SubgraphDeploymentStore: Send + Sync + 'static {
     /// Return the GraphQL schema supplied by the user
     fn input_schema(&self, subgraph_id: &SubgraphDeploymentId) -> Result<Arc<Schema>, Error>;
@@ -1188,15 +1189,19 @@ pub trait SubgraphDeploymentStore: Send + Sync + 'static {
 }
 
 /// Common trait for blockchain store implementations.
+#[automock]
 pub trait ChainStore: Send + Sync + 'static {
     /// Get a pointer to this blockchain's genesis block.
     fn genesis_block_ptr(&self) -> Result<EthereumBlockPointer, Error>;
 
     /// Insert blocks into the store (or update if they are already present).
-    fn upsert_blocks<'a, B, E>(&self, _: B) -> Box<dyn Future<Item = (), Error = E> + Send + 'a>
+    fn upsert_blocks<B, E>(
+        &self,
+        _blocks: B,
+    ) -> Box<dyn Future<Item = (), Error = E> + Send + 'static>
     where
-        B: Stream<Item = EthereumBlock, Error = E> + Send + 'a,
-        E: From<Error> + Send + 'a,
+        B: Stream<Item = EthereumBlock, Error = E> + Send + 'static,
+        E: From<Error> + Send + 'static,
         Self: Sized,
     {
         unimplemented!()

store/postgres/src/store.rs

@@ -1116,13 +1116,13 @@ impl ChainStore for Store {
         Ok(self.genesis_block_ptr)
     }
 
-    fn upsert_blocks<'a, B, E>(
+    fn upsert_blocks<B, E>(
         &self,
         blocks: B,
-    ) -> Box<dyn Future<Item = (), Error = E> + Send + 'a>
+    ) -> Box<dyn Future<Item = (), Error = E> + Send + 'static>
     where
-        B: Stream<Item = EthereumBlock, Error = E> + Send + 'a,
-        E: From<Error> + Send + 'a,
+        B: Stream<Item = EthereumBlock, Error = E> + Send + 'static,
+        E: From<Error> + Send + 'static,
     {
         use crate::db_schema::ethereum_blocks::dsl::*;