From 100c53ac75a5fdb6b234face9e727b1e64264d61 Mon Sep 17 00:00:00 2001 From: Tobi Adeyemi Date: Sat, 30 May 2026 01:26:34 +0100 Subject: [PATCH 1/2] fix(grpc): set tls_config on manual endpoint connect --- ark-grpc/src/client.rs | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/ark-grpc/src/client.rs b/ark-grpc/src/client.rs index f2cbf29..35e726e 100644 --- a/ark-grpc/src/client.rs +++ b/ark-grpc/src/client.rs @@ -117,12 +117,21 @@ impl Client { } pub async fn connect(&mut self) -> Result<(), Error> { - let channel = tonic::transport::Endpoint::from_shared(self.url.clone()) - .map_err(Error::connect)? - .connect() - .await + let endpoint = tonic::transport::Endpoint::from_shared(self.url.clone()) .map_err(Error::connect)?; + #[cfg(any(feature = "tls-webpki-roots", feature = "tls-native-roots"))] + let endpoint = { + let tls = tonic::transport::ClientTlsConfig::new(); + #[cfg(feature = "tls-webpki-roots")] + let tls = tls.with_webpki_roots(); + #[cfg(feature = "tls-native-roots")] + let tls = tls.with_native_roots(); + endpoint.tls_config(tls).map_err(Error::connect)? + }; + + let channel = endpoint.connect().await.map_err(Error::connect)?; + let ark_service_client = ArkServiceClient::with_interceptor(channel.clone(), VersionInterceptor); let indexer_client = IndexerServiceClient::with_interceptor(channel, VersionInterceptor); From 2e9bbb392f323f0198f7cb1e8c5a9acb3924316d Mon Sep 17 00:00:00 2001 From: Tobi Adeyemi Date: Sat, 30 May 2026 13:21:48 +0100 Subject: [PATCH 2/2] fix formatting --- ark-grpc/src/client.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ark-grpc/src/client.rs b/ark-grpc/src/client.rs index 35e726e..efa0754 100644 --- a/ark-grpc/src/client.rs +++ b/ark-grpc/src/client.rs @@ -117,8 +117,8 @@ impl Client { } pub async fn connect(&mut self) -> Result<(), Error> { - let endpoint = tonic::transport::Endpoint::from_shared(self.url.clone()) - .map_err(Error::connect)?; + let endpoint = + tonic::transport::Endpoint::from_shared(self.url.clone()).map_err(Error::connect)?; #[cfg(any(feature = "tls-webpki-roots", feature = "tls-native-roots"))] let endpoint = {