fix http url/socket

Author: Mirko-von-Leipzig

crates/block-producer/src/server.rs

@@ -7,7 +7,7 @@ use miden_node_proto::generated::{
 use miden_node_utils::{
     errors::ApiError,
     formatting::{format_input_notes, format_output_notes},
-    tracing::grpc::{OtelInterceptor, block_producer_trace_fn},
+    tracing::grpc::{block_producer_trace_fn, OtelInterceptor},
 };
 use miden_objects::{
     block::BlockNumber, transaction::ProvenTransaction, utils::serde::Deserializable,
@@ -20,13 +20,13 @@ use tracing::{debug, info, instrument};
 use url::Url;
 
 use crate::{
-    COMPONENT, SERVER_MEMPOOL_EXPIRATION_SLACK, SERVER_MEMPOOL_STATE_RETENTION,
     batch_builder::BatchBuilder,
     block_builder::BlockBuilder,
     domain::transaction::AuthenticatedTransaction,
     errors::{AddTransactionError, BlockProducerError, VerifyTxError},
     mempool::{BatchBudget, BlockBudget, Mempool, SharedMempool},
     store::StoreClient,
+    COMPONENT, SERVER_MEMPOOL_EXPIRATION_SLACK, SERVER_MEMPOOL_STATE_RETENTION,
 };
 
 /// Represents an initialized block-producer component where the RPC connection is open,
@@ -59,7 +59,8 @@ impl BlockProducer {
     ) -> Result<Self, ApiError> {
         info!(target: COMPONENT, endpoint=?listener, store=%store_address, "Initializing server");
 
-        let channel = tonic::transport::Endpoint::try_from(store_address.to_string())
+        let store_url = format!("http://{store_address}");
+        let channel = tonic::transport::Endpoint::try_from(store_url)
             .map_err(|err| ApiError::InvalidStoreUrl(err.to_string()))?
             .connect()
             .await

crates/rpc/src/server/api.rs

@@ -22,14 +22,14 @@ use miden_node_proto::{
 };
 use miden_node_utils::tracing::grpc::OtelInterceptor;
 use miden_objects::{
-    Digest, MAX_NUM_FOREIGN_ACCOUNTS, MIN_PROOF_SECURITY_LEVEL, account::AccountId,
-    crypto::hash::rpo::RpoDigest, transaction::ProvenTransaction, utils::serde::Deserializable,
+    account::AccountId, crypto::hash::rpo::RpoDigest, transaction::ProvenTransaction,
+    utils::serde::Deserializable, Digest, MAX_NUM_FOREIGN_ACCOUNTS, MIN_PROOF_SECURITY_LEVEL,
 };
 use miden_tx::TransactionVerifier;
 use tonic::{
-    Request, Response, Status,
     service::interceptor::InterceptedService,
     transport::{Channel, Error},
+    Request, Response, Status,
 };
 use tracing::{debug, info, instrument};
 
@@ -52,15 +52,13 @@ impl RpcService {
         store_address: SocketAddr,
         block_producer_address: SocketAddr,
     ) -> Result<Self, Error> {
-        let channel = tonic::transport::Endpoint::try_from(store_address.to_string())?
-            .connect()
-            .await?;
+        let store_url = format!("http://{store_address}");
+        let channel = tonic::transport::Endpoint::try_from(store_url)?.connect().await?;
         let store = store_client::ApiClient::with_interceptor(channel, OtelInterceptor);
         info!(target: COMPONENT, store_endpoint = %store_address, "Store client initialized");
 
-        let channel = tonic::transport::Endpoint::try_from(block_producer_address.to_string())?
-            .connect()
-            .await?;
+        let block_producer_url = format!("http://{block_producer_address}");
+        let channel = tonic::transport::Endpoint::try_from(block_producer_url)?.connect().await?;
         let block_producer =
             block_producer_client::ApiClient::with_interceptor(channel, OtelInterceptor);