address comments

Cargo.lock

@@ -3915,6 +3915,7 @@ dependencies = [
  "indexer_ffi",
  "indexer_service",
  "indexer_service_rpc",
+ "jsonrpsee",
  "key_protocol",
  "log",
  "nssa",
@@ -8372,7 +8373,6 @@ dependencies = [
  "common",
  "futures",
  "humantime-serde",
- "jsonrpsee",
  "log",
  "logos-blockchain-core",
  "logos-blockchain-key-management-system-service",

integration_tests/Cargo.toml

@@ -21,6 +21,7 @@ token_core.workspace = true
 ata_core.workspace = true
 indexer_service_rpc = { workspace = true, features = ["client"] }
 sequencer_service_rpc = { workspace = true, features = ["client"] }
+jsonrpsee = { workspace = true, features = ["ws-client"] }
 wallet-ffi.workspace = true
 indexer_ffi.workspace = true
 testnet_initial_state.workspace = true

integration_tests/src/lib.rs

@@ -9,16 +9,19 @@ use indexer_service::IndexerHandle;
 use log::{debug, error};
 use nssa::{AccountId, PrivacyPreservingTransaction};
 use nssa_core::Commitment;
-use sequencer_core::indexer_client::{IndexerClient, IndexerClientTrait as _};
 use sequencer_service::SequencerHandle;
 use sequencer_service_rpc::{RpcClient as _, SequencerClient, SequencerClientBuilder};
 use tempfile::TempDir;
 use testcontainers::compose::DockerCompose;
 use wallet::WalletCore;
 
-use crate::setup::{setup_bedrock_node, setup_indexer, setup_sequencer, setup_wallet};
+use crate::{
+    indexer_client::IndexerClient,
+    setup::{setup_bedrock_node, setup_indexer, setup_sequencer, setup_wallet},
+};
 
 pub mod config;
+pub mod indexer_client;
 pub mod setup;
 pub mod test_context_ffi;
 

integration_tests/src/test_context_ffi.rs

@@ -6,7 +6,6 @@ use indexer_ffi::IndexerServiceFFI;
 use indexer_service_rpc::RpcClient as _;
 use log::{debug, error};
 use nssa::AccountId;
-use sequencer_core::indexer_client::{IndexerClient, IndexerClientTrait as _};
 use sequencer_service::SequencerHandle;
 use sequencer_service_rpc::{RpcClient as _, SequencerClient, SequencerClientBuilder};
 use tempfile::TempDir;
@@ -15,6 +14,7 @@ use wallet::WalletCore;
 
 use crate::{
     BEDROCK_SERVICE_WITH_OPEN_PORT, LOGGER, TestContextBuilder, config,
+    indexer_client::IndexerClient,
     setup::{setup_bedrock_node, setup_indexer_ffi, setup_sequencer, setup_wallet},
 };
 

sequencer/core/Cargo.toml

@@ -30,7 +30,6 @@ rand.workspace = true
 borsh.workspace = true
 bytesize.workspace = true
 url.workspace = true
-jsonrpsee = { workspace = true, features = ["ws-client"] }
 
 [features]
 default = []

sequencer/core/src/indexer_client.rs

@@ -1,34 +0,0 @@
-use std::{ops::Deref, sync::Arc};
-
-use anyhow::{Context as _, Result};
-use log::info;
-pub use url::Url;
-
-#[expect(async_fn_in_trait, reason = "We don't care about Send/Sync here")]
-pub trait IndexerClientTrait: Clone {
-    async fn new(indexer_url: &Url) -> Result<Self>;
-}
-
-#[derive(Clone)]
-pub struct IndexerClient(Arc<jsonrpsee::ws_client::WsClient>);
-
-impl IndexerClientTrait for IndexerClient {
-    async fn new(indexer_url: &Url) -> Result<Self> {
-        info!("Connecting to Indexer at {indexer_url}");
-
-        let client = jsonrpsee::ws_client::WsClientBuilder::default()
-            .build(indexer_url)
-            .await
-            .context("Failed to create websocket client")?;
-
-        Ok(Self(Arc::new(client)))
-    }
-}
-
-impl Deref for IndexerClient {
-    type Target = jsonrpsee::ws_client::WsClient;
-
-    fn deref(&self) -> &Self::Target {
-        &self.0
-    }
-}

sequencer/core/src/lib.rs

@@ -26,10 +26,6 @@ use crate::{
 pub mod block_publisher;
 pub mod block_store;
 pub mod config;
-// Kept as a thin client lib for callers that want to query the indexer
-// directly (e.g. integration tests). The sequencer no longer depends on the
-// indexer at runtime — finalization comes from zone-sdk events.
-pub mod indexer_client;
 
 #[cfg(feature = "mock")]
 pub mod mock;