feat(unstable): WebTransport

ext/net/03_quic.js

@@ -34,6 +34,8 @@ import {
   op_quic_send_stream_get_id,
   op_quic_send_stream_get_priority,
   op_quic_send_stream_set_priority,
+  op_webtransport_accept,
+  op_webtransport_connect,
 } from "ext:core/ops";
 import {
   getReadableStreamResourceBacking,
@@ -50,6 +52,7 @@ const {
 const {
   ObjectPrototypeIsPrototypeOf,
   PromisePrototypeThen,
+  ReflectConstruct,
   Symbol,
   SymbolAsyncIterator,
   SafePromisePrototypeFinally,
@@ -205,6 +208,9 @@ class QuicIncoming {
   }
 }
 
+let webtransportConnect;
+let webtransportAccept;
+
 class QuicConn {
   #resource;
   #bidiStream = null;
@@ -309,6 +315,43 @@ class QuicConn {
   close({ closeCode = 0, reason = "" } = { __proto__: null }) {
     op_quic_connection_close(this.#resource, closeCode, reason);
   }
+
+  static {
+    webtransportConnect = async function webtransportConnect(conn, url) {
+      const {
+        0: connectTxRid,
+        1: connectRxRid,
+        2: settingsTxRid,
+        3: settingsRxRid,
+      } = await op_webtransport_connect(conn.#resource, url);
+      const connect = new QuicBidirectionalStream(
+        connectTxRid,
+        connectRxRid,
+        conn.closed,
+      );
+      const settingsTx = writableStream(settingsTxRid, conn.closed);
+      const settingsRx = readableStream(settingsRxRid, conn.closed);
+      return { connect, settingsTx, settingsRx };
+    };
+
+    webtransportAccept = async function webtransportAccept(conn) {
+      const {
+        0: url,
+        1: connectTxRid,
+        2: connectRxRid,
+        3: settingsTxRid,
+        4: settingsRxRid,
+      } = await op_webtransport_accept(conn.#resource);
+      const connect = new QuicBidirectionalStream(
+        connectTxRid,
+        connectRxRid,
+        conn.closed,
+      );
+      const settingsTx = writableStream(settingsTxRid, conn.closed);
+      const settingsRx = readableStream(settingsRxRid, conn.closed);
+      return { url, connect, settingsTx, settingsRx };
+    };
+  }
 }
 
 class QuicSendStream extends WritableStream {
@@ -345,15 +388,23 @@ function readableStream(rid, closed) {
   SafePromisePrototypeFinally(closed, () => {
     core.tryClose(rid);
   });
-  return readableStreamForRid(rid, true, QuicReceiveStream);
+  return readableStreamForRid(
+    rid,
+    true,
+    (...args) => ReflectConstruct(QuicReceiveStream, args),
+  );
 }
 
 function writableStream(rid, closed) {
   // stream can be indirectly closed by closing connection.
   SafePromisePrototypeFinally(closed, () => {
     core.tryClose(rid);
   });
-  return writableStreamForRid(rid, true, QuicSendStream);
+  return writableStreamForRid(
+    rid,
+    true,
+    (...args) => ReflectConstruct(QuicSendStream, args),
+  );
 }
 
 class QuicBidirectionalStream {
@@ -421,6 +472,7 @@ function connectQuic(options) {
       caCerts: options.caCerts,
       alpnProtocols: options.alpnProtocols,
       serverName: options.serverName,
+      serverCertificateHashes: options.serverCertificateHashes,
     },
     transportOptions(options),
     keyPair,
@@ -448,4 +500,6 @@ export {
   QuicListener,
   QuicReceiveStream,
   QuicSendStream,
+  webtransportAccept,
+  webtransportConnect,
 };

ext/net/Cargo.toml

@@ -24,6 +24,9 @@ pin-project.workspace = true
 quinn = { version = "0.11.6", default-features = false, features = ["runtime-tokio", "rustls", "ring"] }
 rustls-tokio-stream.workspace = true
 serde.workspace = true
+sha2.workspace = true
 socket2.workspace = true
 thiserror.workspace = true
 tokio.workspace = true
+url.workspace = true
+web-transport-proto = "0.2.3"

ext/net/lib.deno_net.d.ts

@@ -851,5 +851,17 @@ declare namespace Deno {
     options: ConnectQuicOptions<ZRTT>,
   ): ZRTT extends true ? (QuicConn | Promise<QuicConn>) : Promise<QuicConn>;
 
+  /**
+   * **UNSTABLE**: New API, yet to be vetted.
+   *
+   * Upgrade a QUIC connection into a WebTransport instance.
+   *
+   * @category Network
+   * @experimental
+   */
+  export function upgradeWebTransport(
+    conn: QuicConn,
+  ): Promise<WebTransport & { url: string }>;
+
   export {}; // only export exports
 }

ext/net/lib.rs

@@ -196,6 +196,8 @@ deno_core::extension!(deno_net,
     quic::op_quic_send_stream_get_id,
     quic::op_quic_send_stream_get_priority,
     quic::op_quic_send_stream_set_priority,
+    quic::webtransport::op_webtransport_accept,
+    quic::webtransport::op_webtransport_connect,
   ],
   esm = [ "01_net.js", "02_tls.js" ],
   lazy_loaded_esm = [ "03_quic.js" ],