feat(rpc): add rpc call to query output at block (#102)

* add rpc call to query output at block

* rpc server added

* rpc server working

* implemented endpoint

* add message passer address

* add more fields to respose

* add correct contract for Base L2toL2MessagePasser

* cleanup and error handling

* formatting fixes

Cargo.toml

@@ -18,6 +18,7 @@ hex = "0.4.3"
 libflate = "1.2.0"
 openssl = { version = "0.10", features = ["vendored"] }
 once_cell = "1"
+jsonrpsee = {version = "0.17.0", features = ["server", "macros"]}
 
 # Logging and Metrics
 chrono = "0.4.22"

docker/docker-compose.yml

@@ -25,6 +25,7 @@ services:
       - .env
     ports:
       - 9200:9200
+      - 9545:9545
     volumes:
       - ./:/scripts
       - data:/data

src/config/mod.rs

@@ -125,6 +125,8 @@ pub struct ChainConfig {
     /// Network blocktime
     #[serde(default = "default_blocktime")]
     pub blocktime: u64,
+    /// L2 To L1 Message passer address
+    pub l2_to_l1_message_passer: Address,
 }
 
 /// Optimism system config contract values
@@ -210,6 +212,7 @@ impl ChainConfig {
             system_config_contract: addr("0xAe851f927Ee40dE99aaBb7461C00f9622ab91d60"),
             batch_inbox: addr("0xff00000000000000000000000000000000000420"),
             deposit_contract: addr("0x5b47E1A08Ea6d985D6649300584e6722Ec4B1383"),
+            l2_to_l1_message_passer: addr("0xEF2ec5A5465f075E010BE70966a8667c94BCe15a"),
             max_channel_size: 100_000_000,
             channel_timeout: 300,
             seq_window_size: 3600,
@@ -241,6 +244,7 @@ impl ChainConfig {
             system_config_contract: addr("0xb15eea247ece011c68a614e4a77ad648ff495bc1"),
             batch_inbox: addr("0x8453100000000000000000000000000000000000"),
             deposit_contract: addr("0xe93c8cd0d409341205a592f8c4ac1a5fe5585cfa"),
+            l2_to_l1_message_passer: addr("0x4200000000000000000000000000000000000016"),
             max_channel_size: 100_000_000,
             channel_timeout: 100,
             seq_window_size: 3600,

src/driver/mod.rs

@@ -18,6 +18,7 @@ use crate::{
     driver::types::HeadInfo,
     engine::{Engine, EngineApi},
     l1::{BlockUpdate, ChainWatcher},
+    rpc,
     telemetry::metrics,
 };
 
@@ -81,7 +82,9 @@ impl Driver<EngineApi> {
         )));
 
         let engine_driver = EngineDriver::new(finalized_head, finalized_epoch, provider, &config)?;
-        let pipeline = Pipeline::new(state.clone(), config)?;
+        let pipeline = Pipeline::new(state.clone(), config.clone())?;
+
+        let _addr = rpc::run_server(config).await?;
 
         Ok(Self {
             engine_driver,

src/lib.rs

@@ -18,3 +18,6 @@ pub mod engine;
 
 /// Application telemetry and logging
 pub mod telemetry;
+
+/// RPC module to host rpc server
+pub mod rpc;