wip

Author: benluelo

Cargo.lock

@@ -165,6 +165,7 @@ members = [
   "voyager/modules/client/state-lens/ics23-smt",
   "voyager/modules/client/sui",
   "voyager/modules/client/trusted-mpt",
+  "voyager/modules/client/attested",
 
   "voyager/modules/client-bootstrap/base",
   "voyager/modules/client-bootstrap/bob",
@@ -180,6 +181,7 @@ members = [
   "voyager/modules/client-bootstrap/state-lens/ics23-smt",
   "voyager/modules/client-bootstrap/state-lens/ics23-ics23",
   "voyager/modules/client-bootstrap/sui",
+  "voyager/modules/client-bootstrap/attested",
 
   "voyager/modules/finality/base",
   "voyager/modules/finality/bob",

Cargo.toml

@@ -3,7 +3,7 @@ use std::{env::VarError, time::Duration};
 use opentelemetry::KeyValue;
 use opentelemetry_otlp::WithExportConfig;
 use serde::de::DeserializeOwned;
-use tracing::{Instrument, debug_span, instrument};
+use tracing::{Instrument, debug_span, error, instrument};
 use tracing_subscriber::{EnvFilter, Layer, layer::SubscriberExt, util::SubscriberInitExt};
 use unionlabs::ErrorReporter;
 pub use voyager_plugin_protocol as protocol;
@@ -344,12 +344,12 @@ fn init(metrics_endpoint: Option<String>) {
     }
 }
 
-#[instrument(level = "debug", fields(%config_str))]
+#[instrument(level = "info", fields(%config_str, current_exe = ?std::env::current_exe().unwrap_or_default()))]
 fn must_parse<T: DeserializeOwned>(config_str: &str) -> T {
     match serde_json::from_str::<T>(config_str) {
         Ok(ok) => ok,
         Err(err) => {
-            eprintln!("invalid config: {}", ErrorReporter(err));
+            error!("invalid config: {}", ErrorReporter(err));
             std::process::exit(INVALID_CONFIG_EXIT_CODE as i32);
         }
     }

lib/voyager-plugin/src/lib.rs

@@ -0,0 +1,29 @@
+[package]
+name    = "voyager-client-bootstrap-module-attested"
+version = "0.0.0"
+
+authors      = { workspace = true }
+edition      = { workspace = true }
+license-file = { workspace = true }
+publish      = { workspace = true }
+repository   = { workspace = true }
+
+[lints]
+workspace = true
+
+[dependencies]
+alloy                       = { workspace = true, features = ["rpc", "rpc-types", "transports", "transport-http", "transport-ws", "reqwest", "reqwest-rustls-tls", "provider-ws"] }
+attested-light-client       = { workspace = true }
+attested-light-client-types = { workspace = true, features = ["serde"] }
+embed-commit                = { workspace = true }
+ibc-union-spec              = { workspace = true, features = ["serde"] }
+jsonrpsee                   = { workspace = true, features = ["macros", "server", "tracing"] }
+prost                       = { workspace = true }
+protos                      = { workspace = true }
+serde                       = { workspace = true, features = ["derive"] }
+serde_json                  = { workspace = true }
+thiserror                   = { workspace = true }
+tokio                       = { workspace = true }
+tracing                     = { workspace = true }
+unionlabs                   = { workspace = true }
+voyager-sdk                 = { workspace = true }

voyager/modules/client-bootstrap/attested/Cargo.toml

@@ -0,0 +1,101 @@
+use alloy::{
+    network::AnyNetwork,
+    providers::{DynProvider, Provider, ProviderBuilder},
+};
+use attested_light_client_types::{ClientState, ClientStateV1, ConsensusState};
+use ibc_union_spec::Timestamp;
+use jsonrpsee::{
+    Extensions,
+    core::{RpcResult, async_trait},
+};
+use serde::{Deserialize, Serialize};
+use serde_json::Value;
+use tracing::instrument;
+use unionlabs::ibc::core::client::height::Height;
+use voyager_sdk::{
+    anyhow, ensure_null, into_value,
+    plugin::ClientBootstrapModule,
+    primitives::ChainId,
+    rpc::{ClientBootstrapModuleServer, types::ClientBootstrapModuleInfo},
+};
+
+#[tokio::main(flavor = "multi_thread")]
+async fn main() {
+    Module::run().await;
+}
+
+#[derive(Debug, Clone)]
+pub struct Module {
+    pub chain_id: ChainId,
+    pub provider: DynProvider<AnyNetwork>,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(deny_unknown_fields)]
+pub struct Config {
+    pub rpc_url: String,
+}
+
+impl ClientBootstrapModule for Module {
+    type Config = Config;
+
+    async fn new(config: Self::Config, info: ClientBootstrapModuleInfo) -> anyhow::Result<Self> {
+        let provider = DynProvider::new(
+            ProviderBuilder::new()
+                .network::<AnyNetwork>()
+                .connect(&config.rpc_url)
+                .await?,
+        );
+
+        let chain_id = provider.get_chain_id().await?.to_string();
+
+        info.ensure_chain_id(&chain_id)?;
+
+        Ok(Self {
+            chain_id: ChainId::new(chain_id),
+            provider,
+        })
+    }
+}
+
+#[async_trait]
+impl ClientBootstrapModuleServer for Module {
+    #[instrument(skip_all, fields(chain_id = %self.chain_id, %height))]
+    async fn self_client_state(
+        &self,
+        _: &Extensions,
+        height: Height,
+        config: Value,
+    ) -> RpcResult<Value> {
+        ensure_null(config)?;
+
+        Ok(serde_json::to_value(ClientState::V1(ClientStateV1 {
+            chain_id: self.chain_id.to_string(),
+            latest_height: height.height(),
+        }))
+        .expect("infallible"))
+    }
+
+    #[instrument(skip_all, fields(chain_id = %self.chain_id, %height))]
+    async fn self_consensus_state(
+        &self,
+        _: &Extensions,
+        height: Height,
+        config: Value,
+    ) -> RpcResult<Value> {
+        ensure_null(config)?;
+
+        let timestamp = self
+            .provider
+            .get_block_by_number(height.height().into())
+            .await
+            .unwrap()
+            .unwrap()
+            .header
+            .timestamp;
+
+        Ok(into_value(ConsensusState {
+            timestamp: Timestamp::from_secs(timestamp),
+        }))
+    }
+}

voyager/modules/client-bootstrap/attested/src/main.rs

@@ -0,0 +1,23 @@
+[package]
+name    = "voyager-client-module-attested"
+version = "0.0.0"
+
+authors      = { workspace = true }
+edition      = { workspace = true }
+license-file = { workspace = true }
+publish      = { workspace = true }
+repository   = { workspace = true }
+
+[lints]
+workspace = true
+
+[dependencies]
+attested-light-client-types = { workspace = true, features = ["serde", "bincode", "ethabi"] }
+embed-commit                = { workspace = true }
+jsonrpsee                   = { workspace = true, features = ["macros", "server", "tracing"] }
+serde                       = { workspace = true, features = ["derive"] }
+serde_json                  = { workspace = true }
+tokio                       = { workspace = true }
+tracing                     = { workspace = true }
+unionlabs                   = { workspace = true, features = ["bincode"] }
+voyager-sdk                 = { workspace = true }