Improvement: chainsync asynchronism

[gsegatti]

• Like Improvement: concurrent node invitation #294 and Improvement: more orchestrator asynchronism #295.

[Copilot]

Pull Request Overview

This PR improves the asynchronism in the chainsync functionality and related contract interactions by refining error types, enhancing error handling, and introducing concurrent processing for node synchronization.

• Updated error return types in compute registry and compute pool contracts to include Send + Sync.
• Enhanced error handling in the compute pool’s is_node_blacklisted function.
• Refactored chainsync code to perform concurrent node syncing using futures::stream::iter.
• Added the futures dependency in Cargo.toml.

Reviewed Changes

Copilot reviewed 5 out of 5 changed files in this pull request and generated no comments.

File	Description
crates/shared/src/web3/contracts/implementations/compute_registry_contract.rs	Updated error return type to enforce thread-safety with Send + Sync.
crates/shared/src/web3/contracts/implementations/compute_pool_contract.rs	Improved error handling for node blacklist checks.
crates/discovery/src/chainsync/sync.rs	Refactored sync_single_node to use async join and concurrent processing with for_each_concurrent.
crates/discovery/Cargo.toml	Included futures dependency to support asynchronous stream operations.

Comments suppressed due to low confidence (3)

crates/shared/src/web3/contracts/implementations/compute_pool_contract.rs:187

• Consider using a consistent error conversion helper to wrap these string errors with more contextual information.

let first_value = result.first().ok_or("Empty response when checking if node is blacklisted")?;

crates/discovery/src/chainsync/sync.rs:65

• Consider using the log crate (e.g., error!) for error reporting instead of eprintln, in order to maintain consistent logging throughout the code.

eprintln!("Error retrieving node info: {}", e);

crates/discovery/src/chainsync/sync.rs:110

• [nitpick] It may be beneficial to include additional context (e.g., node identifier) in the error logs within the concurrent stream to improve debugging clarity.

futures::stream::iter(nodes).for_each_concurrent(10, |node| {