Add zenoh as transport

Cargo.toml

@@ -27,7 +27,7 @@ members = [
 ]
 
 [features]
-default = ["bin", "nats", "net", "quic", "wasmtime", "web-transport"]
+default = ["bin", "nats", "net", "quic", "wasmtime", "web-transport", "zenoh-transport"]
 
 bin = ["bin-bindgen", "bin-wasmtime"]
 bin-bindgen = [
@@ -43,6 +43,7 @@ net = ["wrpc-transport/net"]
 quic = ["dep:wrpc-transport-quic"]
 wasmtime = ["dep:wrpc-runtime-wasmtime"]
 web-transport = ["dep:wrpc-transport-web"]
+zenoh-transport = ["dep:zenoh", "dep:wrpc-transport-zenoh", "wrpc-cli/zenoh-transport"]
 
 [[bin]]
 name = "wit-bindgen-wrpc"
@@ -84,6 +85,8 @@ wrpc-transport-nats = { workspace = true, optional = true }
 wrpc-transport-quic = { workspace = true, optional = true }
 wrpc-transport-web = { workspace = true, optional = true }
 wrpc-wasmtime-cli = { workspace = true, optional = true }
+wrpc-transport-zenoh = { workspace = true, optional = true }
+zenoh = { workspace = true, optional = true }
 
 [dev-dependencies]
 anyhow = { workspace = true }
@@ -114,8 +117,10 @@ wasmtime-cli-flags = { workspace = true, features = [
     "pooling-allocator",
     "threads",
 ] }
-wrpc-test = { workspace = true, features = ["nats", "quic", "web-transport"] }
+wrpc-test = { workspace = true, features = ["nats", "quic", "web-transport", "zenoh-transport"] }
 wrpc-transport = { workspace = true, features = ["net"] }
+serial_test = "*"
+
 
 [workspace.dependencies]
 anyhow = { version = "1", default-features = false }
@@ -182,8 +187,12 @@ wrpc-transport = { version = "0.29", path = "./crates/transport", default-featur
 wrpc-transport-nats = { version = "0.31", path = "./crates/transport-nats", default-features = false }
 wrpc-transport-quic = { version = "0.6", path = "./crates/transport-quic", default-features = false }
 wrpc-transport-web = { version = "0.3", path = "./crates/transport-web", default-features = false }
+wrpc-transport-zenoh = { version = "0.29", path = "./crates/transport-zenoh", default-features = false }
 wrpc-wasi-keyvalue = { version = "0.1.1", path = "./crates/wasi-keyvalue", default-features = false }
 wrpc-wasi-keyvalue-mem = { version = "0.2", path = "./crates/wasi-keyvalue-mem", default-features = false }
 wrpc-wasi-keyvalue-redis = { version = "0.2", path = "./crates/wasi-keyvalue-redis", default-features = false }
 wrpc-wasmtime-cli = { version = "0.9", path = "./crates/wasmtime-cli", default-features = false }
-wtransport = { version = "0.7.0", default-features = false }
+zenoh = {version = "=1.7.2", default-features = false}
+flume = {version = "0.11", default-features = false}
+postcard = {version = "1.1"}
+wtransport = { version = "0.7.0", default-features = false }

README.md

@@ -230,6 +230,128 @@ We will use the following two Rust wRPC applications using [NATS.io] transport:
     wrpc-wasmtime nats run --import native ./target/wasm32-wasip2/release/hello-component-client.wasm
     ```
 
+#### Using [zenoh.io] transport
+
+We will use the following two Rust wRPC applications using [zenoh.io] transport:
+- [examples/rust/hello-zenoh-client](examples/rust/hello-zenoh-client)
+- [examples/rust/hello-zenoh-server](examples/rust/hello-zenoh-server)
+
+1. Run [zenoh.io] (more thorough documentation available [here](https://docs.nats.io/running-a-nats-service/introduction/running)):
+
+    - using standalone binary:
+    ```sh
+    zenohd
+    ```
+
+    - using nix flake develop environment:
+    ```sh
+    nix develop
+    zenohd
+    ```
+
+2. Serve Wasm `hello` server via [zenoh.io]
+
+    ```sh
+    wrpc-wasmtime zenoh serve --export rust ./target/wasm32-wasip2/release/hello_component_server.wasm
+    ```
+
+    - Sample output:
+    > INFO async_nats: event: connected
+    >
+    > INFO wrpc_wasmtime_cli: serving instance function name="hello"
+
+3. Call Wasm `hello` server using a Wasm `hello` client via [zenoh.io]:
+
+    ```sh
+    wrpc-wasmtime zenoh run --import rust ./target/wasm32-wasip2/release/hello-component-client.wasm
+    ```
+
+    - Sample output in the client:
+    > INFO async_nats: event: connected
+    >
+    >hello from Rust
+
+    - Sample output in the server:
+    > INFO wrpc_wasmtime_cli: serving instance function invocation
+    >
+    > INFO wrpc_wasmtime_cli: successfully served instance function invocation
+
+4. Call the Wasm `hello` server using a native wRPC `hello` client via [zenoh.io]:
+
+    ```sh
+    cargo run -p hello-zenoh-client rust
+    ```
+
+5. Serve native wRPC `hello` server via [zenoh.io]:
+
+    ```sh
+    cargo run -p hello-zenoh-server native
+    ```
+
+6. Call both the native wRPC `hello` server and Wasm `hello` server using native wRPC `hello` client via [zenoh.io]:
+
+    ```sh
+    cargo run -p hello-zenoh-client rust native
+    ```
+
+7. Call native wRPC `hello` server using Wasm `hello` client via [zenoh.io]:
+
+    ```sh
+    wrpc-wasmtime zenoh run --import native ./target/wasm32-wasip2/release/hello-component-client.wasm
+    ```
+
+
+To test the transport-zenoh package run:
+
+    ```sh
+    cargo test zenoh -- --nocapture
+    ```
+
+    - Sample output:
+    > test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 13 filtered out; finished in 6.17s
+
+### Zenoh Configuration
+By default we set Zenoh to run in **client mode**. In this mode it behaves
+similarly to a typical NATS client: the application connects to a local
+Zenoh router (`zenohd`) that acts as the message broker. 
+
+The client attempts to connect to a `zenohd` instance running on the
+**default Zenoh port (`7447`) on the same machine**.
+
+Zenohd has been
+added to the flake nix file and is available after running nix develop in the 
+command lnine.
+
+This behavior can be altered by providing a **custom Zenoh configuration
+file** and setting the `ZENOH_CONFIG` environment variable to its path.
+
+Example:
+
+``` bash
+export ZENOH_CONFIG="/path/to/config/zenoh_conf.json5"
+```
+
+
+When this environment variable is set, Zenoh will load the configuration
+from the specified file instead of using the default settings.
+
+Example configuration:
+
+``` json
+{
+  "mode": "client",
+  "listen": {
+    "endpoints": ["tcp/0.0.0.0:7447"]
+  }
+}
+```
+
+
+More information about available configuration options and how to confige zenoh in peer mode can be found in
+the official Zenoh configuration manual:
+
+https://zenoh.io/docs/manual/configuration/
+
 ## Repository structure
 
 This repository contains (for all supported languages):
@@ -256,3 +378,4 @@ Whether you're a seasoned developer or just getting started, your contributions
 
 [Docker]: https://www.docker.com/
 [NATS.io]: https://nats.io/
+[zenoh.io]: https://zenoh.io/

benches/reactor/Cargo.toml

@@ -9,7 +9,7 @@ license.workspace = true
 repository.workspace = true
 
 [lib]
-crate-type = ["rlib", "cdylib"]
+crate-type = ["rlib"]
 
 [dependencies]
 wit-bindgen = { workspace = true, features = ["macros", "realloc"] }

crates/cli/Cargo.toml

@@ -11,8 +11,9 @@ license.workspace = true
 repository.workspace = true
 
 [features]
-default = ["nats"]
+default = ["nats", "zenoh-transport"]
 nats = ["async-nats/ring", "dep:async-nats", "dep:tokio", "tokio/sync"]
+zenoh-transport = ["dep:zenoh", "dep:tokio", "tokio/sync"]
 
 [dependencies]
 anyhow = { workspace = true, features = ["std"] }
@@ -25,3 +26,5 @@ tracing-subscriber = { workspace = true, features = [
     "smallvec",
     "tracing-log",
 ] }
+zenoh = { workspace = true, optional = true, features = ["transport_tcp"] }
+serde_json = { workspace = true, default-features = false }

crates/cli/src/lib.rs

@@ -1,3 +1,5 @@
 #[cfg(feature = "nats")]
 pub mod nats;
 pub mod tracing;
+#[cfg(feature = "zenoh-transport")]
+pub mod zenoh;

crates/cli/src/zenoh.rs

@@ -0,0 +1,26 @@
+use serde_json::json;
+use zenoh::{Config, Session};
+
+/// Open a regular Zenoh session with configs supplied by an environment variable.
+pub async fn connect() -> anyhow::Result<Session> {
+    let cfg = if let Ok(cfg) = Config::from_env() {
+        cfg
+    } else {
+        let mut config = Config::default();
+        // Set mode
+        config
+            .insert_json5("mode", &json!("client").to_string())
+            .unwrap();
+        config
+            .insert_json5(
+                "connect/endpoints",
+                &json!(["tcp/0.0.0.0:7447"]).to_string(),
+            )
+            .unwrap();
+
+        config
+    };
+
+    let session = zenoh::open(cfg).await.unwrap();
+    Ok(session)
+}

crates/test/Cargo.toml

@@ -11,7 +11,7 @@ license.workspace = true
 repository.workspace = true
 
 [features]
-default = ["nats", "quic", "web-transport"]
+default = ["nats", "quic", "web-transport", "zenoh-transport"]
 nats = ["dep:async-nats", "async-nats/ring", "wrpc-cli/nats"]
 quic = [
     "dep:quinn",
@@ -22,6 +22,7 @@ quic = [
     "quinn/rustls",
 ]
 web-transport = ["dep:wtransport", "wtransport/self-signed"]
+zenoh-transport = ["dep:zenoh", "dep:wrpc-transport-zenoh", "wrpc-cli/zenoh-transport"]
 
 [dependencies]
 anyhow = { workspace = true }
@@ -33,3 +34,6 @@ tokio = { workspace = true, features = ["net", "process", "rt-multi-thread"] }
 tracing = { workspace = true }
 wrpc-cli = { workspace = true }
 wtransport = { workspace = true, features = ["ring"], optional = true }
+wrpc-transport-zenoh = { workspace = true, optional = true }
+zenoh = { workspace = true, optional = true }
+serde_json = { workspace = true }