From fcee8086d5608308bc8d216a9ad3a29f3d7d4b95 Mon Sep 17 00:00:00 2001
From: Dzejkop <jakubtrad@gmail.com>
Date: Wed, 17 Apr 2024 10:51:36 +0200
Subject: [PATCH] Fix docker compose setup

---
 compose.yml        | 3 ++-
 src/app.rs         | 4 +++-
 src/tasks/index.rs | 2 ++
 3 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/compose.yml b/compose.yml
index 7db4896..542f069 100644
--- a/compose.yml
+++ b/compose.yml
@@ -41,4 +41,5 @@ services:
     image: ghcr.io/foundry-rs/foundry:latest
     ports:
       - "8545:8545"
-    command: ["anvil --block-time 2"]
+    command: ["anvil --block-time 2 --host 0.0.0.0"]
+
diff --git a/src/app.rs b/src/app.rs
index f3a1c49..3ef353f 100644
--- a/src/app.rs
+++ b/src/app.rs
@@ -50,7 +50,9 @@ impl App {
     ) -> eyre::Result<Provider<Ws>> {
         let url = self.db.get_network_rpc(chain_id, RpcKind::Ws).await?;
 
-        let ws = Ws::connect(url.as_str()).await?;
+        let ws = Ws::connect(url.as_str())
+            .await
+            .context("Connecting to WS provider")?;
         let provider = Provider::new(ws);
 
         Ok(provider)
diff --git a/src/tasks/index.rs b/src/tasks/index.rs
index 49eaa8b..440542b 100644
--- a/src/tasks/index.rs
+++ b/src/tasks/index.rs
@@ -25,10 +25,12 @@ pub async fn index_chain(app: Arc<App>, chain_id: u64) -> eyre::Result<()> {
         let ws_rpc = app.ws_provider(chain_id).await?;
         let rpc = app.http_provider(chain_id).await?;
 
+        tracing::info!("Subscribing to new blocks");
         // Subscribe to new block with the WS client which uses an unbounded receiver, buffering the stream
         let mut blocks_stream = ws_rpc.subscribe_blocks().await?;
 
         // Get the first block from the stream, backfilling any missing blocks from the latest block in the db to the chain head
+        tracing::info!("Backfilling blocks");
         if let Some(latest_block) = blocks_stream.next().await {
             backfill_to_block(app.clone(), chain_id, &rpc, latest_block)
                 .await?;