feat(actors): implement V2 actor system with comprehensive RPC server and supervision

This commit introduces the V2 actor system, consolidating various actor functionalities and implementing a new RPC server architecture. Key changes include:
- Added `rpc_v2.rs` for actor-based RPC server handling, enabling message-driven interactions with ChainActor, EngineActor, and StorageActor.
- Implemented `RootSupervisor` for lifecycle management and fault tolerance across all actors.
- Enhanced message passing patterns between actors, including new RPC-specific messages for block retrieval and status checks.
- Updated `app.rs` to initialize the V2 actor system and start the RPC server.
- Introduced extensive integration tests to validate cross-actor communication and end-to-end workflows.

These enhancements streamline the architecture, improve maintainability, and prepare the system for production deployment.

Author: michaelgpt

Cargo.lock

@@ -777,4 +777,39 @@ impl Handler<HealthCheck> for ChainActor {
             details,
         }
     }
-}
+}
+
+// === RPC Message Handlers ===
+
+/// Handler for GetBlockByHeight RPC message
+impl Handler<GetBlockByHeight> for ChainActor {
+    type Result = ResponseActFuture<Self, Result<Option<SignedConsensusBlock>, ChainError>>;
+    
+    fn handle(&mut self, msg: GetBlockByHeight, _: &mut Context<Self>) -> Self::Result {
+        Box::pin(async move {
+            self.get_block_by_height(msg.height).await
+        }.into_actor(self))
+    }
+}
+
+/// Handler for GetBlockByHash RPC message
+impl Handler<GetBlockByHash> for ChainActor {
+    type Result = ResponseActFuture<Self, Result<Option<SignedConsensusBlock>, ChainError>>;
+    
+    fn handle(&mut self, msg: GetBlockByHash, _: &mut Context<Self>) -> Self::Result {
+        Box::pin(async move {
+            self.get_block_by_hash(msg.hash).await
+        }.into_actor(self))
+    }
+}
+
+/// Handler for GetBlockCount RPC message  
+impl Handler<GetBlockCount> for ChainActor {
+    type Result = ResponseActFuture<Self, Result<u64, ChainError>>;
+    
+    fn handle(&mut self, msg: GetBlockCount, _: &mut Context<Self>) -> Self::Result {
+        Box::pin(async move {
+            Ok(self.chain_state.height)
+        }.into_actor(self))
+    }
+}

app/src/actors/chain/actor.rs

@@ -7,6 +7,7 @@
 use std::time::Duration;
 use actor_system::SupervisionConfig;
 use super::state::FederationConfig;
+use lighthouse_wrapper::bls::SecretKey;
 
 /// Configuration for ChainActor behavior and performance
 #[derive(Debug, Clone)]

app/src/actors/chain/config.rs

@@ -1153,4 +1153,27 @@ impl Default for ChainStatus {
             },
         }
     }
-}
+}
+
+// === RPC-specific messages ===
+
+/// Message to get a block by its height (for RPC)
+#[derive(Message, Debug, Clone)]
+#[rtype(result = "Result<Option<SignedConsensusBlock>, ChainError>")]
+pub struct GetBlockByHeight {
+    /// Block height to retrieve
+    pub height: u64,
+}
+
+/// Message to get a block by its hash (for RPC)
+#[derive(Message, Debug, Clone)]
+#[rtype(result = "Result<Option<SignedConsensusBlock>, ChainError>")]
+pub struct GetBlockByHash {
+    /// Block hash to retrieve
+    pub hash: Hash256,
+}
+
+/// Message to get the current block count (for RPC)
+#[derive(Message, Debug, Clone)]
+#[rtype(result = "Result<u64, ChainError>")]
+pub struct GetBlockCount;

app/src/actors/chain/messages.rs

@@ -23,9 +23,16 @@ pub mod bridge; // Bridge actor system
 pub mod network; // Network actor system (SyncActor, NetworkActor, PeerActor)
 pub mod sync; // Sync actor system
 pub mod storage; // Organized storage actor module
+pub mod supervisor; // Root supervisor for all actors
+pub mod shared; // Shared structures like ActorAddresses
+
+#[cfg(test)]
+pub mod tests; // V2 Actor system integration tests
 
 pub use chain::*; // Import from organized module
 pub use engine::*; // Import from organized engine module  
 pub use network::*; // New network actor system
 pub use storage::*; // Import from organized storage module
-pub use bridge::actors::stream::*; // Export new consolidated StreamActor
+pub use bridge::actors::stream::*; // Export new consolidated StreamActor
+pub use supervisor::*; // Export supervisor
+pub use shared::*; // Export shared structures