datasource/ethereum: Slightly improve block stream step logging
@@ -209,6 +209,8 @@ where
) -> impl Future<Item = ReconciliationStep, Error = Error> + Send {
let ctx = self.clone();
+ debug!(ctx.logger, "Identify next step");
+
// Get pointers from database for comparison
let head_ptr_opt = ctx.chain_store.chain_head_ptr().unwrap();
let subgraph_ptr = ctx
@@ -225,8 +227,16 @@ where
let head_ptr = head_ptr_opt.unwrap();
- debug!(ctx.logger, "head_ptr = {:?}", head_ptr);
- debug!(ctx.logger, "subgraph_ptr = {:?}", subgraph_ptr);
+ debug!(
+ ctx.logger, "Chain head pointer";
+ "hash" => format!("{:?}", head_ptr.hash),
+ "number" => &head_ptr.number
+ );
+ debug!(
+ ctx.logger, "Subgraph pointer";
+ "hash" => format!("{:?}", subgraph_ptr.hash),
+ "number" => &subgraph_ptr.number
+ );
// Only continue if the subgraph block ptr is behind the head block ptr.
// subgraph_ptr > head_ptr shouldn't happen, but if it does, it's safest to just stop.
