feat(wrpc-test): extract wrpc-test crate

Signed-off-by: Roman Volosatovs <[email protected]>

Author: rvolosatovs

.github/workflows/wrpc.yml

@@ -15,6 +15,8 @@ on:
       - 'crates/pack/v[0-9].[0-9]+.[0-9]+-*'
       - 'crates/runtime-wasmtime/v[0-9].[0-9]+.[0-9]+'
       - 'crates/runtime-wasmtime/v[0-9].[0-9]+.[0-9]+-*'
+      - 'crates/test/v[0-9].[0-9]+.[0-9]+'
+      - 'crates/test/v[0-9].[0-9]+.[0-9]+-*'
       - 'crates/transport-nats/v[0-9].[0-9]+.[0-9]+'
       - 'crates/transport-nats/v[0-9].[0-9]+.[0-9]+-*'
       - 'crates/transport-quic/v[0-9].[0-9]+.[0-9]+'
@@ -206,6 +208,9 @@ jobs:
           - crate: pack
             workspace-dependencies: true
 
+          - crate: test
+            workspace-dependencies: true
+
           - crate: runtime-wasmtime
             workspace-dependencies: true
 

Cargo.lock

@@ -50,6 +50,10 @@ required-features = ["bin"]
 name = "wrpc-wasmtime"
 required-features = ["bin", "nats", "wasmtime"]
 
+[[bench]]
+name = "bench"
+harness = false
+
 [dependencies]
 anyhow = { workspace = true, features = ["std"] }
 async-nats = { workspace = true, optional = true }
@@ -80,28 +84,21 @@ wrpc-wasmtime-cli = { workspace = true, optional = true }
 [dev-dependencies]
 anyhow = { workspace = true }
 bytes = { workspace = true }
-futures = { workspace = true, features = ["async-await"] }
-quinn = { workspace = true, features = [
-    "log",
-    "platform-verifier",
-    "ring",
-    "runtime-tokio",
-    "rustls",
-] }
-rcgen = { workspace = true, features = ["crypto", "ring", "zeroize"] }
-rustls = { workspace = true, features = ["logging", "ring"] }
+criterion = { workspace = true, features = ["async_tokio"] }
+futures = { workspace = true }
 tempfile = { workspace = true }
 test-log = { workspace = true, features = ["color", "log", "trace"] }
 tokio = { workspace = true, features = ["process", "rt-multi-thread"] }
-wrpc-cli = { workspace = true }
-wrpc-transport = { workspace = true }
+wrpc-test = { workspace = true, features = ["nats", "quic"] }
+wrpc-transport = { workspace = true, features = ["net"] }
 
 [workspace.dependencies]
 anyhow = { version = "1", default-features = false }
 async-nats = { version = "0.37", default-features = false }
 bitflags = { version = "2", default-features = false }
 bytes = { version = "1", default-features = false }
 clap = { version = "4", default-features = false }
+criterion = { version = "0.5", default-features = false }
 futures = { version = "0.3", default-features = false }
 heck = { version = "0.5", default-features = false }
 humantime = { version = "2.1", default-features = false }
@@ -144,6 +141,7 @@ wit-parser = { version = "0.218", default-features = false }
 wrpc-cli = { version = "0.4", path = "./crates/cli", default-features = false }
 wrpc-introspect = { version = "0.5", default-features = false, path = "./crates/introspect" }
 wrpc-runtime-wasmtime = { version = "0.24.1", path = "./crates/runtime-wasmtime", default-features = false }
+wrpc-test = { path = "./crates/test", default-features = false }
 wrpc-transport = { version = "0.28.2", path = "./crates/transport", default-features = false }
 wrpc-transport-nats = { version = "0.25", path = "./crates/transport-nats", default-features = false }
 wrpc-transport-quic = { version = "0.3", path = "./crates/transport-quic", default-features = false }

Cargo.toml

@@ -0,0 +1,19 @@
+use criterion::Criterion;
+
+#[cfg(feature = "nats")]
+#[test_log::test(tokio::test(flavor = "multi_thread"))]
+async fn nats_rtt(c: &mut Criterion) {
+    common::with_nats(|_, nats_client| async {
+        let clt = wrpc_transport_nats::Client::new(
+            nats_client,
+            "rust-bindgen-sync",
+            Some("rust-bindgen-sync".into()),
+        );
+        let clt = Arc::new(clt);
+        assert_bindgen_sync(Arc::clone(&clt), clt).await
+    })
+    .await
+}
+
+criterion_group!(benches, from_elem);
+criterion_main!(benches);