Merge branch 'main' into julien/signature-payload

Author: julienrbrt

block/manager.go

@@ -576,6 +576,11 @@ func (m *Manager) GetExecutor() coreexecutor.Executor {
 	return m.exec
 }
 
+// GetSigner returns the signer instance used by this manager
+func (m *Manager) GetSigner() (address []byte) {
+	return m.genesis.ProposerAddress
+}
+
 func (m *Manager) retrieveBatch(ctx context.Context) (*BatchData, error) {
 	m.logger.Debug().Str("chainID", m.genesis.ChainID).Interface("lastBatchData", m.lastBatchData).Msg("Attempting to retrieve next batch")
 

client/crates/client/src/config.rs

@@ -1,5 +1,7 @@
 use crate::{client::Client, error::Result};
-use ev_types::v1::{config_service_client::ConfigServiceClient, GetNamespaceResponse};
+use ev_types::v1::{
+    config_service_client::ConfigServiceClient, GetNamespaceResponse, GetSignerInfoResponse,
+};
 use tonic::Request;
 
 pub struct ConfigClient {
@@ -21,6 +23,14 @@ impl ConfigClient {
         Ok(response.into_inner())
     }
 
+    /// Get SequencerInfo
+    pub async fn get_signer_info(&self) -> Result<GetSignerInfoResponse> {
+        let request = Request::new(());
+        let response = self.inner.clone().get_signer_info(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?;

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

@@ -427,3 +427,10 @@ pub struct GetNamespaceResponse {
     #[prost(string, tag = "2")]
     pub data_namespace: ::prost::alloc::string::String,
 }
+/// GetSequencerInfoResponse returns information about the sequencer
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct GetSignerInfoResponse {
+    #[prost(bytes = "vec", tag = "1")]
+    pub address: ::prost::alloc::vec::Vec<u8>,
+}

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

@@ -2439,12 +2439,19 @@ pub struct GetNamespaceResponse {
     #[prost(string, tag = "2")]
     pub data_namespace: ::prost::alloc::string::String,
 }
+/// GetSequencerInfoResponse returns information about the sequencer
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct GetSignerInfoResponse {
+    #[prost(bytes = "vec", tag = "1")]
+    pub address: ::prost::alloc::vec::Vec<u8>,
+}
 /// Generated client implementations.
 pub mod config_service_client {
     #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
     use tonic::codegen::*;
     use tonic::codegen::http::Uri;
-    /// StoreService defines the RPC service for the store package
+    /// ConfigService defines the RPC service for configuration queries
     #[derive(Debug, Clone)]
     pub struct ConfigServiceClient<T> {
         inner: tonic::client::Grpc<T>,
@@ -2551,6 +2558,32 @@ pub mod config_service_client {
                 .insert(GrpcMethod::new("evnode.v1.ConfigService", "GetNamespace"));
             self.inner.unary(req, path, codec).await
         }
+        /// GetSequencerInfo returns information about the sequencer
+        pub async fn get_signer_info(
+            &mut self,
+            request: impl tonic::IntoRequest<()>,
+        ) -> std::result::Result<
+            tonic::Response<super::GetSignerInfoResponse>,
+            tonic::Status,
+        > {
+            self.inner
+                .ready()
+                .await
+                .map_err(|e| {
+                    tonic::Status::new(
+                        tonic::Code::Unknown,
+                        format!("Service was not ready: {}", e.into()),
+                    )
+                })?;
+            let codec = tonic::codec::ProstCodec::default();
+            let path = http::uri::PathAndQuery::from_static(
+                "/evnode.v1.ConfigService/GetSignerInfo",
+            );
+            let mut req = request.into_request();
+            req.extensions_mut()
+                .insert(GrpcMethod::new("evnode.v1.ConfigService", "GetSignerInfo"));
+            self.inner.unary(req, path, codec).await
+        }
     }
 }
 /// Generated server implementations.
@@ -2568,8 +2601,16 @@ pub mod config_service_server {
             tonic::Response<super::GetNamespaceResponse>,
             tonic::Status,
         >;
+        /// GetSequencerInfo returns information about the sequencer
+        async fn get_signer_info(
+            &self,
+            request: tonic::Request<()>,
+        ) -> std::result::Result<
+            tonic::Response<super::GetSignerInfoResponse>,
+            tonic::Status,
+        >;
     }
-    /// StoreService defines the RPC service for the store package
+    /// ConfigService defines the RPC service for configuration queries
     #[derive(Debug)]
     pub struct ConfigServiceServer<T: ConfigService> {
         inner: _Inner<T>,
@@ -2690,6 +2731,47 @@ pub mod config_service_server {
                     };
                     Box::pin(fut)
                 }
+                "/evnode.v1.ConfigService/GetSignerInfo" => {
+                    #[allow(non_camel_case_types)]
+                    struct GetSignerInfoSvc<T: ConfigService>(pub Arc<T>);
+                    impl<T: ConfigService> tonic::server::UnaryService<()>
+                    for GetSignerInfoSvc<T> {
+                        type Response = super::GetSignerInfoResponse;
+                        type Future = BoxFuture<
+                            tonic::Response<Self::Response>,
+                            tonic::Status,
+                        >;
+                        fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
+                            let inner = Arc::clone(&self.0);
+                            let fut = async move {
+                                <T as ConfigService>::get_signer_info(&inner, request).await
+                            };
+                            Box::pin(fut)
+                        }
+                    }
+                    let accept_compression_encodings = self.accept_compression_encodings;
+                    let send_compression_encodings = self.send_compression_encodings;
+                    let max_decoding_message_size = self.max_decoding_message_size;
+                    let max_encoding_message_size = self.max_encoding_message_size;
+                    let inner = self.inner.clone();
+                    let fut = async move {
+                        let inner = inner.0;
+                        let method = GetSignerInfoSvc(inner);
+                        let codec = tonic::codec::ProstCodec::default();
+                        let mut grpc = tonic::server::Grpc::new(codec)
+                            .apply_compression_config(
+                                accept_compression_encodings,
+                                send_compression_encodings,
+                            )
+                            .apply_max_message_size_config(
+                                max_decoding_message_size,
+                                max_encoding_message_size,
+                            );
+                        let res = grpc.unary(method, req).await;
+                        Ok(res)
+                    };
+                    Box::pin(fut)
+                }
                 _ => {
                     Box::pin(async move {
                         Ok(

docs/guides/create-genesis.md

@@ -118,4 +118,4 @@ gmd start --evnode.node.aggregator
 
 ## Summary
 
-By following these steps, you will set up the genesis for your chain, initialize the validator, add a genesis account, and started the chain. This guide provides a basic framework for configuring and starting your chain using the gm-world binary. Make sure you initialized your chain correctly, and use the `gmd` command for all operations.
+By following these steps, you will set up the genesis for your chain, initialize the validator, add a genesis account, and start the chain. This guide provides a basic framework for configuring and starting your chain using the gm-world binary. Make sure you initialized your chain correctly, and use the `gmd` command for all operations.

docs/guides/gm-world.md

@@ -291,4 +291,4 @@ If you run into any issues, make sure your Keplr wallet is updated and set to co
 
 ## 🎉 Next steps
 
-Congratulations! You've experienced connecting to a chain from the user side — simple and straightforward. Now, you might consider exploring how to add more application logic to your chain using the Cosmos SDK, as demonstrated in our Wordle App tutorial.
+Congratulations! You've experienced connecting to a chain from the user side — simple and straightforward. Now, you might consider exploring how to add more application logic to your chain using the Cosmos SDK, as demonstrated in our World App tutorial.

docs/learn/specs/block-manager.md

@@ -374,7 +374,7 @@ flowchart TD
    - Sends to sync goroutine for state update
    - Successful processing triggers immediate next retrieval without waiting for timer
    - Updates namespace migration status when appropriate:
-     - Marks migration complete when data found in new namespaces
+     - Marks migration complete when data is found in new namespaces
      - Persists migration state to avoid future legacy checks
 
 #### Header and Data Caching

node/full.go

@@ -328,7 +328,7 @@ func (n *FullNode) Run(parentCtx context.Context) error {
 	}
 
 	// Start RPC server
-	handler, err := rpcserver.NewServiceHandler(n.Store, n.p2pClient, n.Logger, n.nodeConfig)
+	handler, err := rpcserver.NewServiceHandler(n.Store, n.p2pClient, n.blockManager.GetSigner(), n.Logger, n.nodeConfig)
 	if err != nil {
 		return fmt.Errorf("error creating RPC handler: %w", err)
 	}

node/light.go

@@ -76,8 +76,8 @@ func (ln *LightNode) Run(parentCtx context.Context) error {
 	}()
 
 	ln.running = true
-	// Start RPC server
-	handler, err := rpcserver.NewServiceHandler(ln.Store, ln.P2P, ln.Logger, ln.nodeConfig)
+	// Start RPC server (light node doesn't have a signer)
+	handler, err := rpcserver.NewServiceHandler(ln.Store, ln.P2P, nil, ln.Logger, ln.nodeConfig)
 	if err != nil {
 		return fmt.Errorf("error creating RPC handler: %w", err)
 	}

pkg/rpc/client/client_test.go

@@ -37,7 +37,7 @@ func setupTestServer(t *testing.T, mockStore *mocks.MockStore, mockP2P *mocks.Mo
 	// Create config server with test config
 	testConfig := config.DefaultConfig
 	testConfig.DA.Namespace = "test-headers"
-	configServer := server.NewConfigServer(testConfig, logger)
+	configServer := server.NewConfigServer(testConfig, nil, logger)
 
 	// Register the store service
 	storePath, storeHandler := rpc.NewStoreServiceHandler(storeServer)