feat!(transport-quic): rework QUIC transport using transport framing

Cargo.toml

@@ -165,7 +165,7 @@ wrpc-runtime-wasmtime = { version = "0.24.1", path = "./crates/runtime-wasmtime"
 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.27.1", path = "./crates/transport-nats", default-features = false }
-wrpc-transport-quic = { version = "0.3", path = "./crates/transport-quic", default-features = false }
+wrpc-transport-quic = { version = "0.4", path = "./crates/transport-quic", default-features = false }
 wrpc-wasi-keyvalue = { version = "0.1", path = "./crates/wasi-keyvalue", default-features = false }
 wrpc-wasi-keyvalue-mem = { version = "0.1", path = "./crates/wasi-keyvalue-mem", default-features = false }
 wrpc-wasmtime-cli = { version = "0.2", path = "./crates/wasmtime-cli", default-features = false }

crates/test/src/lib.rs

@@ -79,8 +79,7 @@ where
 
 #[cfg(feature = "quic")]
 pub async fn with_quic<T, Fut>(
-    names: &[&str],
-    f: impl FnOnce(u16, quinn::Endpoint, quinn::Endpoint) -> Fut,
+    f: impl FnOnce(quinn::Connection, quinn::Connection) -> Fut,
 ) -> anyhow::Result<T>
 where
     Fut: core::future::Future<Output = anyhow::Result<T>>,
@@ -92,27 +91,18 @@ where
     use rcgen::{generate_simple_self_signed, CertifiedKey};
     use rustls::pki_types::{CertificateDer, PrivatePkcs8KeyDer};
     use rustls::version::TLS13;
+    use tokio::try_join;
 
     let CertifiedKey {
         cert: srv_crt,
         key_pair: srv_key,
-    } = generate_simple_self_signed(
-        names
-            .iter()
-            .map(|name| format!("{name}.server.wrpc"))
-            .collect::<Vec<_>>(),
-    )
-    .context("failed to generate server certificate")?;
+    } = generate_simple_self_signed(["server.wrpc".to_string()])
+        .context("failed to generate server certificate")?;
     let CertifiedKey {
         cert: clt_crt,
         key_pair: clt_key,
-    } = generate_simple_self_signed(
-        names
-            .iter()
-            .map(|name| format!("{name}.client.wrpc"))
-            .collect::<Vec<_>>(),
-    )
-    .context("failed to generate client certificate")?;
+    } = generate_simple_self_signed(["client.wrpc".to_string()])
+        .context("failed to generate client certificate")?;
     let srv_crt = CertificateDer::from(srv_crt);
 
     let mut ca = rustls::RootCertStore::empty();
@@ -149,7 +139,21 @@ where
         Arc::new(TokioRuntime),
     )
     .context("failed to create server endpoint")?;
-    f(srv_addr.port(), clt_ep, srv_ep)
-        .await
-        .context("closure failed")
+
+    let (clt, srv) = try_join!(
+        async move {
+            let conn = clt_ep
+                .connect(srv_addr, "server.wrpc")
+                .context("failed to connect to server")?;
+            conn.await.context("failed to establish client connection")
+        },
+        async move {
+            let conn = srv_ep
+                .accept()
+                .await
+                .context("failed to accept connection")?;
+            conn.await.context("failed to establish server connection")
+        }
+    )?;
+    f(clt, srv).await.context("closure failed")
 }

crates/transport-quic/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "wrpc-transport-quic"
-version = "0.3.0"
+version = "0.4.0"
 description = "wRPC QUIC transport"
 
 authors.workspace = true
@@ -12,24 +12,12 @@ repository.workspace = true
 [dependencies]
 anyhow = { workspace = true, features = ["std"] }
 bytes = { workspace = true }
-futures = { workspace = true }
-pin-project-lite = { workspace = true }
-quinn = { workspace = true, features = [
-    "log",
-    "platform-verifier",
-    "ring",
-    "runtime-tokio",
-    "rustls",
-] }
-tokio = { workspace = true, features = ["macros"] }
-tokio-stream = { workspace = true }
-tokio-util = { workspace = true, features = ["codec", "io"] }
-tracing = { workspace = true, features = ["attributes"] }
-wasm-tokio = { workspace = true }
+quinn = { workspace = true, features = ["runtime-tokio"] }
+tracing = { workspace = true }
 wrpc-transport = { workspace = true }
 
 [dev-dependencies]
-rcgen = { workspace = true, features = ["crypto", "ring", "zeroize"] }
-rustls = { workspace = true, features = ["logging", "ring"] }
+futures = { workspace = true }
 test-log = { workspace = true, features = ["color", "log", "trace"] }
 tokio = { workspace = true, features = ["rt-multi-thread"] }
+wrpc-test = { workspace = true, features = ["quic"] }