Implement reconnects for blockchain RPC client

- Implement subscription re-establishment after WebSocket reconnect
- Add turmoil integration tests for reconnection and basic subscription

The current Arc<RwLock<HashMap>> pattern is appropriate for blockchain
RPC's simple use case (single subscription type, low concurrency),
though OKX/Bitmex use a more sophisticated SubscriptionState with
DashMaps for complex multi-parameter subscriptions. Future will extract
the common SubscriptionState pattern to the nautilus-network crate.

Author: cjdsellers

Cargo.lock

@@ -1,7 +1,6 @@
 [package]
 name = "nautilus-blockchain"
 readme = "README.md"
-publish = false # Do not publish to crates.io for now
 version.workspace = true
 edition.workspace = true
 rust-version.workspace = true
@@ -40,6 +39,7 @@ python = [
   "pyo3",
   "pyo3-stub-gen",
 ]
+turmoil = ["dep:turmoil", "nautilus-network/turmoil"]
 
 [package.metadata.docs.rs]
 features = ["python"]
@@ -84,9 +84,11 @@ hypersync-client = { workspace = true, optional = true }
 hypersync-schema = { workspace = true, optional = true }
 pyo3 = { workspace = true, optional = true }
 pyo3-stub-gen = { workspace = true, optional = true }
+turmoil = { workspace = true, optional = true }
 
 [dev-dependencies]
 rstest = { workspace = true }
+turmoil = { workspace = true }
 
 [[bin]]
 name = "node_test"

crates/adapters/blockchain/Cargo.toml

@@ -20,6 +20,7 @@ This crate provides feature flags to control source code inclusion during compil
 - `hypersync`: Enables the [HyperSync](https://envio.dev/#hypersync) client integration.
 - `python`: Enables Python bindings from [PyO3](https://pyo3.rs).
 - `extension-module`: Builds as a Python extension module (used with `python`).
+- `turmoil`: Enables integration tests with deterministic network simulation for testing reconnection logic.
 
 ## Scripts
 
@@ -74,6 +75,20 @@ This script demonstrates how to use the blockchain data client to discover and c
 cargo run --bin sync_tokens_pools --features hypersync
 ```
 
+## Testing
+
+### Running Integration Tests
+
+The blockchain adapter includes integration tests that verify reconnection logic and subscription re-establishment using the turmoil network simulator.
+
+Run all tests with the turmoil feature:
+
+```bash
+cargo nextest run -p nautilus-blockchain --features turmoil
+```
+
+**Note**: The `--features turmoil` flag is required to include integration tests that validate WebSocket reconnection, exponential backoff, and automatic subscription re-establishment under various network conditions.
+
 ## License
 
 The source code for NautilusTrader is available on GitHub under the [GNU Lesser General Public License v3.0](https://www.gnu.org/licenses/lgpl-3.0.en.html).

crates/adapters/blockchain/README.md

@@ -37,6 +37,7 @@
 //! - `hypersync`: Enables the [HyperSync](https://envio.dev/#hypersync) client integration.
 //! - `python`: Enables Python bindings from [PyO3](https://pyo3.rs).
 //! - `extension-module`: Builds as a Python extension module (used with `python`).
+//! - `turmoil`: Enables integration tests with deterministic network simulation for testing reconnection logic.
 
 #![warn(rustc::all)]
 #![deny(unsafe_code)]