feat: compile on wasm32-unknown-unknown

Author: Frando

.cargo/config.toml

@@ -0,0 +1,3 @@
+[target.wasm32-unknown-unknown]
+runner = "wasm-bindgen-test-runner"
+rustflags = ['--cfg', 'getrandom_backend="wasm_js"']

Cargo.lock

@@ -17,14 +17,13 @@ bao-tree = { version = "0.15.1", features = ["experimental-mixed", "tokio_fsm",
 bytes = { version = "1", features = ["serde"] }
 derive_more = { version = "2.0.1", features = ["from", "try_from", "into", "debug", "display", "deref", "deref_mut"] }
 futures-lite = "2.6.0"
-quinn = { package = "iroh-quinn", version = "0.14.0" }
+quinn = { package = "iroh-quinn", version = "0.14.0", optional = true }
 n0-future = "0.2.0"
 n0-snafu = "0.2.2"
 range-collections = { version = "0.4.6", features = ["serde"] }
 smallvec = { version = "1", features = ["serde", "const_new"] }
 snafu = "0.8.5"
-tokio = { version = "1.43.0", features = ["full"] }
-tokio-util = { version = "0.7.13", features = ["full"] }
+tokio = { version = "1.43.0", default-features = false, features = ["sync"] }
 tracing = "0.1.41"
 iroh-io = "0.6.1"
 rand = "0.9.2"
@@ -69,8 +68,11 @@ hide-proto-docs = []
 metrics = []
 default = ["hide-proto-docs", "fs-store", "rpc"]
 fs-store = ["dep:redb", "dep:reflink-copy"]
-rpc = ["irpc/rpc", "irpc/quinn_endpoint_setup"]
+rpc = ["dep:quinn", "irpc/rpc", "irpc/quinn_endpoint_setup"]
 
 [patch.crates-io]
-# irpc = { git = "https://github.com/n0-computer/irpc", branch = "Frando/varint-feature" }
-irpc = { path = "../irpc" }
+irpc = { git = "https://github.com/n0-computer/irpc", branch = "Frando/varint-feature" }
+bao-tree = { git = "https://github.com/n0-computer/bao-tree.git", branch = "Frando/wasm" }
+
+[build-dependencies]
+cfg_aliases = "0.2.1"

Cargo.toml

@@ -308,8 +308,9 @@ impl Store {
     /// Listen on a quinn endpoint for incoming rpc connections.
     #[cfg(feature = "rpc")]
     pub async fn listen(self, endpoint: quinn::Endpoint) {
-        use self::proto::Request;
         use irpc::rpc::RemoteService;
+
+        use self::proto::Request;
         let local = self.client.as_local().unwrap().clone();
         let handler = Request::remote_handler(local);
         irpc::rpc::listen::<Request>(endpoint, handler).await

src/api.rs

@@ -12,10 +12,9 @@ use std::{
 
 use anyhow::Result;
 use bao_tree::ChunkRanges;
-use iroh::endpoint::{self, VarInt};
+use iroh::endpoint::{self, ConnectionError, VarInt};
 use iroh_io::{AsyncStreamReader, AsyncStreamWriter};
 use n0_future::StreamExt;
-use quinn::ConnectionError;
 use serde::{Deserialize, Serialize};
 use snafu::Snafu;
 use tokio::select;

src/provider.rs

@@ -1,5 +1,6 @@
 use std::{fmt::Debug, io, ops::Deref};
 
+use iroh::endpoint::VarInt;
 use irpc::{
     channel::{mpsc, none::NoSender, oneshot},
     rpc_requests, Channels, WithChannels,
@@ -106,11 +107,11 @@ impl From<ProgressError> for io::Error {
 }
 
 pub trait HasErrorCode {
-    fn code(&self) -> quinn::VarInt;
+    fn code(&self) -> VarInt;
 }
 
 impl HasErrorCode for ProgressError {
-    fn code(&self) -> quinn::VarInt {
+    fn code(&self) -> VarInt {
         match self {
             ProgressError::Limit => ERR_LIMIT,
             ProgressError::Permission => ERR_PERMISSION,

src/provider/events.rs

@@ -32,7 +32,6 @@ use irpc::channel::mpsc;
 use n0_future::future::yield_now;
 use range_collections::range_set::RangeSetRange;
 use tokio::{
-    io::AsyncReadExt,
     sync::watch,
     task::{JoinError, JoinSet},
 };
@@ -755,8 +754,18 @@ async fn import_byte_stream(
     import_bytes(res.into(), scope, format, tx).await
 }
 
+#[cfg(wasm_browser)]
+async fn import_path(cmd: ImportPathMsg) -> anyhow::Result<ImportEntry> {
+    let _: ImportPathRequest = cmd.inner;
+    Err(anyhow::anyhow!(
+        "import_path is not supported in the browser"
+    ))
+}
+
 #[instrument(skip_all, fields(path = %cmd.path.display()))]
+#[cfg(not(wasm_browser))]
 async fn import_path(cmd: ImportPathMsg) -> anyhow::Result<ImportEntry> {
+    use tokio::io::AsyncReadExt;
     let ImportPathMsg {
         inner:
             ImportPathRequest {

src/store/mem.rs

@@ -32,7 +32,6 @@ use tokio::sync::{
     mpsc::{self, error::SendError as TokioSendError},
     oneshot, Notify,
 };
-use tokio_util::time::FutureExt as TimeFutureExt;
 use tracing::{debug, error, info, trace};
 
 pub type OnConnected =
@@ -194,8 +193,7 @@ impl Context {
         };
 
         // Connect to the node
-        let state = conn_fut
-            .timeout(context.options.connect_timeout)
+        let state = n0_future::time::timeout(context.options.connect_timeout, conn_fut)
             .await
             .map_err(|_| PoolConnectError::Timeout)
             .and_then(|r| r);