WIP: feat(wasm): make Beerus buildable against wasm32 target

.github/workflows/check.yml

@@ -26,7 +26,6 @@ jobs:
       - run: cargo test --features skip-zero-root-validation
 
   wasm-check:
-    if: false ## disabled until wasm effort is in progress
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v3

Cargo.toml

@@ -5,8 +5,9 @@ name = "beerus"
 version = "0.5.0"
 
 [features]
-default = ["rpc"]
+default = ["rpc", "blockifier"]
 rpc = ["dep:axum"]
+blockifier = ["dep:blockifier", "dep:cairo-vm", "dep:ureq"]
 
 ## FOR TESTING ONLY
 ## skip proof validation of state root is 0x0
@@ -17,11 +18,6 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 serde_with = "2.3.3"
 async-trait = "0.1.80"
-reqwest = { version = "0.12.3", default-features = false, features = [
-    "json",
-    "blocking",
-    "rustls-tls",
-] }
 ## Tokio WASM support: https://docs.rs/tokio/latest/tokio/#wasm-support
 tokio = { version = "1", features = [
     "sync",
@@ -46,14 +42,14 @@ ethers = { git = "https://github.com/gakonst/ethers-rs", rev = "3bf1a9e0d698e9fd
 helios = { git = "https://github.com/a16z/helios", rev = "1572a24" }
 
 starknet-crypto = "0.6.2"
-blockifier = "0.5.0"
+blockifier = { version = "0.5.0", optional = true }
 starknet_api = "0.10.0"
-cairo-vm = "0.9.2"
+cairo-vm = { version = "0.9.2", optional = true }
 
 base64 = "0.22.0"
 flate2 = "1.0.28"
 cairo-lang-starknet-classes = "2.6.3"
-ureq = { version = "2.9.6", features = ["json"] }
+ureq = { version = "2.9.6", features = ["json"], optional = true }
 hex = "0.4.3"
 bitvec = "1.0.1"
 validator = { version = "0.18.1", features = ["derive"] }
@@ -63,3 +59,17 @@ clap = { version = "4.5.7", features = ["derive"] }
 
 [dev-dependencies]
 wiremock = "0.6.0"
+
+[target.'cfg(target_arch = "wasm32")'.dependencies]
+wasm-bindgen-futures = "0.4.37"
+reqwest = { version = "0.12.3", default-features = false, features = [
+    "json",
+    "blocking",
+] }
+
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
+reqwest = { version = "0.12.3", default-features = false, features = [
+    "json",
+    "blocking",
+    "rustls-tls",
+] }

src/bin/beerus.rs

@@ -1,11 +1,49 @@
-use std::{sync::Arc, time::Duration};
+use clap::Parser;
 
 use beerus::config::Config;
-use clap::Parser;
-use tokio::sync::RwLock;
 
-#[tokio::main]
-async fn main() -> eyre::Result<()> {
+fn main() -> eyre::Result<()> {
+    // TODO: expose Beerus with ctor and get_proven_state & get_recent_state methods
+    // TODO: make a web page that calls those methods periodically (via setTimeout)
+    // TODO: expose Ethereum methods (via Helios) and Starknet methods (via client)
+    #[cfg(target_arch = "wasm32")]
+    {
+        let _ = wasm_bindgen_futures::spawn_local(async {
+            tracing_subscriber::fmt::init();
+
+            let config = get_config(Args::parse()).expect("config missing");
+            config.validate_params().await.expect("config invalid");
+
+            let beerus = beerus::client::Client::new(&config)
+                .await
+                .expect("client failed");
+            beerus.start().await.expect("start failed");
+
+            let state = beerus.get_state().await.expect("get_state failed");
+            tracing::info!(?state, "initialized");
+        });
+
+        return Ok(());
+    }
+
+    #[cfg(not(target_arch = "wasm32"))]
+    {
+        tokio::runtime::Builder::new_multi_thread()
+            .enable_all()
+            .build()?
+            .block_on(async {
+                let _ = run().await;
+            });
+
+        Ok(())
+    }
+}
+
+#[cfg(not(target_arch = "wasm32"))]
+async fn run() -> eyre::Result<()> {
+    use std::{sync::Arc, time::Duration};
+    use tokio::sync::RwLock;
+
     tracing_subscriber::fmt::init();
 
     let config = get_config(Args::parse())?;
@@ -39,12 +77,15 @@ async fn main() -> eyre::Result<()> {
         });
     }
 
-    let server =
-        beerus::rpc::serve(&config.starknet_rpc, &config.rpc_addr, state)
-            .await?;
+    #[cfg(not(target_arch = "wasm32"))]
+    {
+        let server =
+            beerus::rpc::serve(&config.starknet_rpc, &config.rpc_addr, state)
+                .await?;
 
-    tracing::info!(port = server.port(), "rpc server started");
-    server.done().await;
+        tracing::info!(port = server.port(), "rpc server started");
+        server.done().await;
+    }
 
     Ok(())
 }
@@ -56,6 +97,7 @@ struct Args {
     config: Option<String>,
 }
 
+// #[cfg(not(target_arch = "wasm32"))]
 fn get_config(args: Args) -> eyre::Result<Config> {
     Ok(if let Some(path) = args.config.as_ref() {
         Config::from_file(path)?

src/client.rs

@@ -1,6 +1,9 @@
+use std::sync::Arc;
+
 use eyre::{Context, Result};
+use tokio::sync::RwLock;
 
-use crate::eth::EthereumClient;
+use crate::eth::{EthereumClient, Helios};
 use crate::gen::client::Client as StarknetClient;
 use crate::gen::{BlockId, Felt, Rpc};
 use crate::{config::Config, gen::FunctionCall};
@@ -28,6 +31,14 @@ impl Client {
         self.ethereum.start().await
     }
 
+    pub fn ethereum(&self) -> Arc<RwLock<Helios>> {
+        self.ethereum.helios()
+    }
+
+    pub fn starknet(&self) -> &StarknetClient {
+        &self.starknet
+    }
+
     pub async fn call_starknet(
         &self,
         request: FunctionCall,

src/eth.rs

@@ -25,6 +25,8 @@ const SEPOLIA_CONSENSUS_RPC: &str =
     "http://unstable.sepolia.beacon-api.nimbus.team";
 const SEPOLIA_FALLBACK_RPC: &str = "https://sync-sepolia.beaconcha.in";
 
+pub type Helios = Client<DB>;
+
 pub struct EthereumClient {
     helios: Arc<RwLock<Client<DB>>>,
     starknet_core_contract_address: Address,
@@ -53,6 +55,10 @@ impl EthereumClient {
         Ok(())
     }
 
+    pub fn helios(&self) -> Arc<RwLock<Helios>> {
+        self.helios.clone()
+    }
+
     pub async fn latest(&self) -> Result<(u64, H256)> {
         let block_number = self
             .helios

src/gen.rs

@@ -2224,7 +2224,8 @@ pub mod gen {
         }
     }
 
-    #[async_trait::async_trait]
+    #[cfg_attr(target_arch = "wasm32", async_trait::async_trait(?Send))]
+    #[cfg_attr(not(target_arch = "wasm32"), async_trait::async_trait)]
     pub trait Rpc {
         /// Returns merkle proofs of a contract's storage state
         async fn getProof(
@@ -3712,6 +3713,7 @@ pub mod gen {
         };
     }
 
+    #[cfg(not(target_arch = "wasm32"))]
     pub mod blocking {
         use super::*;
         pub trait Rpc {
@@ -5303,7 +5305,8 @@ pub mod gen {
             }
         }
 
-        #[async_trait::async_trait]
+        #[cfg_attr(target_arch = "wasm32", async_trait::async_trait(?Send))]
+        #[cfg_attr(not(target_arch = "wasm32"), async_trait::async_trait)]
         impl super::Rpc for Client {
             async fn getProof(
                 &self,
@@ -7456,6 +7459,7 @@ pub mod gen {
             }
         }
 
+        #[cfg(not(target_arch = "wasm32"))]
         pub mod blocking {
             use super::*;
 

src/lib.rs

@@ -1,6 +1,8 @@
 pub mod client;
 pub mod config;
 pub mod eth;
+
+#[cfg(not(target_arch = "wasm32"))]
 pub mod exe;
 pub mod gen;
 pub mod proof;