fix(coprocessor): host-listener, timeout slow reconnection for catchup

[rudy-6-4]

No description provided.

[rudy-6-4]

#1988

[rudy-6-4]

@claude /pr-review

[claude]

Claude finished @rudy-6-4's task in 2m 21s —— View job

---

[AUTOMATED]

PR Review: fix(coprocessor): host-listener, timeout slow reconnection for catchup

• Pre-review validation
• Gather context (PR diff, guidelines)
• Run parallel review agents
• Post final review

---

Summary

This PR adds a tokio::time::timeout wrapper around the ProviderBuilder::new().connect_ws(ws) call in get_blocks_logs_range_no_retry(), preventing the catchup path from hanging indefinitely when WebSocket connection establishment is slow. This is a targeted, well-scoped fix.

Findings

No bugs found. All four review agents (2× bug hunter, error handling auditor, guideline compliance) confirmed the code is correct:

• ✅ Type handling — The nested Result<Result<Provider, Error>, Elapsed> from the timeout wrapper is correctly handled with three exhaustive match arms
• ✅ Error propagation — All errors are properly propagated via anyhow::bail! to consume_catchup_blocks(), which has appropriate retry logic
• ✅ Resource safety — When the timeout fires, the dropped connect_ws future cleans up the in-progress TCP/WebSocket connection
• ✅ Timeout value — Uses self.timeout_request_websocket (default 15s), consistent with all other RPC timeouts in the file
• ✅ Improved error messages — The old code discarded the connection error (Err(_) => bail!("Cannot get a provider")); the new code preserves it ("Cannot get provider for logs range due to {err}")

Nit: Minor style inconsistency

The new code splits the timeout creation and .await into two separate statements:

let provider = tokio::time::timeout(
    Duration::from_secs(self.timeout_request_websocket),
    ProviderBuilder::new().connect_ws(ws),
);
let provider = match provider.await { ... };

The get_logs timeout in the same function (line 348) chains .await directly:

match tokio::time::timeout(
    Duration::from_secs(self.timeout_request_websocket),
    provider.get_logs(&filter),
)
.await
{
    ...
}

Nit: Consider matching the existing pattern for consistency. Not blocking — both forms are functionally identical.

Pre-existing observation (not introduced by this PR)

new_log_stream_no_retry() (line 768) and get_chain_id() (line 260) also call connect_ws without a timeout. These are pre-existing and outside the scope of this fix, but could benefit from the same treatment in a follow-up.

Verdict

LGTM ✅ — Clean, well-targeted fix that prevents slow WebSocket reconnections from blocking the catchup loop. The error handling is correct and the error messages are improved.

---

[rudy-6-4]

This has been observed on mainnet that connection for catchup could take up to 1min at bad times.

[mergify]

🧪 CI Insights

Here's what we observed from your CI run for 8ce6f26.

🟢 All jobs passed!

But CI Insights is watching 👀

[rudy-6-4]

@Mergifyio queue

[mergify]

Merge Queue Status

Rule: main

---

• ✅ Entered queue — 2026-02-16 13:52 UTC
• ✅ Checks passed · on draft merge queue: embarking main (7eb8bb9) and [#1996 + #1989] together #1997
• ✅ Merged — 2026-02-16 15:51 UTC · at 8ce6f26d0308e1d86ee4c9c8380a940b2168cc2f

This pull request spent 1 hour 58 minutes 42 seconds in the queue, including 1 hour 48 minutes 44 seconds running CI.

Required conditions to merge

• #approved-reviews-by >= 1 [🛡 GitHub branch protection]
  • fix(common): fix broken readme #1996
  • fix(coprocessor): host-listener, timeout slow reconnection for catchup #1989
• #changes-requested-reviews-by = 0 [🛡 GitHub branch protection]
  • fix(common): fix broken readme #1996
  • fix(coprocessor): host-listener, timeout slow reconnection for catchup #1989
• #review-threads-unresolved = 0 [🛡 GitHub branch protection]
  • fix(common): fix broken readme #1996
  • fix(coprocessor): host-listener, timeout slow reconnection for catchup #1989
• branch-protection-review-decision = APPROVED [🛡 GitHub branch protection]
  • fix(common): fix broken readme #1996
  • fix(coprocessor): host-listener, timeout slow reconnection for catchup #1989
• check-success = run-e2e-tests / fhevm-e2e-test
• any of [🛡 GitHub branch protection]:
  • check-success = common-pull-request/lint (bpr)
  • check-neutral = common-pull-request/lint (bpr)
  • check-skipped = common-pull-request/lint (bpr)
• any of [🛡 GitHub branch protection]:
  • check-skipped = coprocessor-cargo-listener-tests/cargo-tests (bpr)
  • check-neutral = coprocessor-cargo-listener-tests/cargo-tests (bpr)
  • check-success = coprocessor-cargo-listener-tests/cargo-tests (bpr)
• any of [🛡 GitHub branch protection]:
  • check-success = coprocessor-cargo-test/cargo-tests (bpr)
  • check-neutral = coprocessor-cargo-test/cargo-tests (bpr)
  • check-skipped = coprocessor-cargo-test/cargo-tests (bpr)
• any of [🛡 GitHub branch protection]:
  • check-success = coprocessor-dependency-analysis/dependencies-check (bpr)
  • check-neutral = coprocessor-dependency-analysis/dependencies-check (bpr)
  • check-skipped = coprocessor-dependency-analysis/dependencies-check (bpr)
• any of [🛡 GitHub branch protection]:
  • check-skipped = gateway-contracts-deployment-tests/sc-deploy (bpr)
  • check-neutral = gateway-contracts-deployment-tests/sc-deploy (bpr)
  • check-success = gateway-contracts-deployment-tests/sc-deploy (bpr)
• any of [🛡 GitHub branch protection]:
  • check-skipped = kms-connector-tests/test-connector (bpr)
  • check-neutral = kms-connector-tests/test-connector (bpr)
  • check-success = kms-connector-tests/test-connector (bpr)