Skip to content

Commit

Permalink
Fix docker compose setup
Browse files Browse the repository at this point in the history
  • Loading branch information
Dzejkop committed Apr 17, 2024
1 parent f2bd5bf commit fcee808
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 2 deletions.
3 changes: 2 additions & 1 deletion compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -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"]

4 changes: 3 additions & 1 deletion src/app.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
2 changes: 2 additions & 0 deletions src/tasks/index.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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?;
Expand Down

0 comments on commit fcee808

Please sign in to comment.