update rpc with config server

Author: tac0turtle

apps/evm/single/cmd/run.go

@@ -6,7 +6,7 @@ import (
 	"fmt"
 	"path/filepath"
 
-	"github.com/evstack/ev-node/da"
+	"github.com/evstack/ev-node/core/da"
 	"github.com/evstack/ev-node/da/jsonrpc"
 	"github.com/evstack/ev-node/node"
 	"github.com/evstack/ev-node/sequencers/single"

apps/grpc/single/cmd/run.go

@@ -7,8 +7,8 @@ import (
 
 	"github.com/spf13/cobra"
 
+	coreda "github.com/evstack/ev-node/core/da"
 	"github.com/evstack/ev-node/core/execution"
-	"github.com/evstack/ev-node/da"
 	"github.com/evstack/ev-node/da/jsonrpc"
 	executiongrpc "github.com/evstack/ev-node/execution/grpc"
 	"github.com/evstack/ev-node/node"
@@ -47,8 +47,8 @@ The execution client must implement the Evolve execution gRPC interface.`,
 
 		logger := rollcmd.SetupLogger(nodeConfig.Log)
 
-		headerNamespace := da.PrepareNamespace([]byte(nodeConfig.DA.HeaderNamespace))
-		dataNamespace := da.PrepareNamespace([]byte(nodeConfig.DA.DataNamespace))
+		headerNamespace := coreda.PrepareNamespace([]byte(nodeConfig.DA.HeaderNamespace))
+		dataNamespace := coreda.PrepareNamespace([]byte(nodeConfig.DA.DataNamespace))
 
 		logger.Info().Str("headerNamespace", hex.EncodeToString(headerNamespace)).Str("dataNamespace", hex.EncodeToString(dataNamespace)).Msg("namespaces")
 

apps/testapp/cmd/run.go

@@ -9,7 +9,7 @@ import (
 	"github.com/spf13/cobra"
 
 	kvexecutor "github.com/evstack/ev-node/apps/testapp/kv"
-	"github.com/evstack/ev-node/da"
+	"github.com/evstack/ev-node/core/da"
 	"github.com/evstack/ev-node/da/jsonrpc"
 	"github.com/evstack/ev-node/node"
 	rollcmd "github.com/evstack/ev-node/pkg/cmd"

apps/testapp/go.mod

@@ -11,6 +11,7 @@ replace (
 
 require (
 	github.com/evstack/ev-node v0.0.0-00010101000000-000000000000
+	github.com/evstack/ev-node/core v0.0.0-20250312114929-104787ba1a4c
 	github.com/evstack/ev-node/da v0.0.0-00010101000000-000000000000
 	github.com/evstack/ev-node/sequencers/single v0.0.0-00010101000000-000000000000
 	github.com/ipfs/go-datastore v0.8.2
@@ -36,7 +37,6 @@ require (
 	github.com/docker/go-units v0.5.0 // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
 	github.com/elastic/gosigar v0.14.3 // indirect
-	github.com/evstack/ev-node/core v0.0.0-20250312114929-104787ba1a4c // indirect
 	github.com/filecoin-project/go-jsonrpc v0.7.1 // indirect
 	github.com/flynn/noise v1.1.0 // indirect
 	github.com/francoispqt/gojay v1.2.13 // indirect

client/crates/client/src/config.rs

@@ -0,0 +1,35 @@
+use crate::{client::Client, error::Result};
+use ev_types::v1::{config_service_client::ConfigServiceClient, GetNamespaceResponse};
+use tonic::Request;
+
+pub struct ConfigClient {
+    inner: ConfigServiceClient<tonic::transport::Channel>,
+}
+
+impl ConfigClient {
+    /// Create a new ConfigClient from a Client
+    pub fn new(client: &Client) -> Self {
+        let inner = ConfigServiceClient::new(client.channel().clone());
+        Self { inner }
+    }
+
+    /// Get the namespace for this network
+    pub async fn get_namespace(&self) -> Result<GetNamespaceResponse> {
+        let request = Request::new(());
+        let response = self.inner.clone().get_namespace(request).await?;
+
+        Ok(response.into_inner())
+    }
+
+    /// Get the header namespace
+    pub async fn get_header_namespace(&self) -> Result<String> {
+        let response = self.get_namespace().await?;
+        Ok(response.header_namespace)
+    }
+
+    /// Get the data namespace
+    pub async fn get_data_namespace(&self) -> Result<String> {
+        let response = self.get_namespace().await?;
+        Ok(response.data_namespace)
+    }
+}

client/crates/client/src/lib.rs

@@ -5,7 +5,7 @@
 //! # Example
 //!
 //! ```no_run
-//! use ev_client::{Client, HealthClient};
+//! use ev_client::{Client, HealthClient, ConfigClient};
 //!
 //! #[tokio::main]
 //! async fn main() -> Result<(), Box<dyn std::error::Error>> {
@@ -17,6 +17,12 @@
 //!     let is_healthy = health.is_healthy().await?;
 //!     println!("Node healthy: {}", is_healthy);
 //!     
+//!     // Get namespace configuration
+//!     let config = ConfigClient::new(&client);
+//!     let namespace = config.get_namespace().await?;
+//!     println!("Header namespace: {}", namespace.header_namespace);
+//!     println!("Data namespace: {}", namespace.data_namespace);
+//!     
 //!     Ok(())
 //! }
 //! ```
@@ -71,6 +77,7 @@
 //! ```
 
 pub mod client;
+pub mod config;
 pub mod error;
 pub mod health;
 pub mod p2p;
@@ -79,6 +86,7 @@ pub mod store;
 
 // Re-export main types for convenience
 pub use client::{Client, ClientBuilder};
+pub use config::ConfigClient;
 pub use error::{ClientError, Result};
 pub use health::HealthClient;
 pub use p2p::P2PClient;

client/crates/types/src/proto/evnode.v1.messages.rs

@@ -418,3 +418,12 @@ pub struct GetMetadataResponse {
     #[prost(bytes = "vec", tag = "1")]
     pub value: ::prost::alloc::vec::Vec<u8>,
 }
+/// GetNamespaceResponse returns the namespace for this network
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct GetNamespaceResponse {
+    #[prost(string, tag = "1")]
+    pub header_namespace: ::prost::alloc::string::String,
+    #[prost(string, tag = "2")]
+    pub data_namespace: ::prost::alloc::string::String,
+}