Initial web-transport-quiche support (#118)

* Don't use a newer Rust method.

* WIP

* Initial web-transport-quiche work.

* Move some stuff.

* WIP

* More WIP

* Client echo works.

* More tweaks.

* Fix some bugs and dramatically improve the DriverState.

* Documentation.

* Fix CI maybe.

* More CI stuff.

* Try using the boring crate to see if it fixes CI.

Author: kixelated

Cargo.toml

@@ -2,6 +2,7 @@
 members = [
     "web-transport",
     "web-transport-proto",
+    "web-transport-quiche",
     "web-transport-quinn",
     "web-transport-trait",
     "web-transport-wasm",

web-transport-quinn/cert/.gitignore renamed to dev/.gitignore

@@ -30,11 +30,17 @@
           pkgs.pkg-config
           pkgs.glib
           pkgs.gtk3
+          # Required to compile boringssl (via bindgen loading libclang)
+          pkgs.llvmPackages.libclang.lib
         ];
       in
       {
         devShells.default = pkgs.mkShell {
           packages = tools;
+
+          shellHook = ''
+            export LD_LIBRARY_PATH=${pkgs.lib.makeLibraryPath [pkgs.llvmPackages.libclang.lib]}:$LD_LIBRARY_PATH
+          '';
         };
       }
     );

web-transport-quinn/cert/localhost.conf renamed to dev/localhost.conf

@@ -0,0 +1,75 @@
+// @ts-expect-error embed the certificate fingerprint using bundler
+import fingerprintHex from "bundle-text:../dev/localhost.hex";
+
+// Convert the hex to binary.
+const fingerprint = [];
+for (let c = 0; c < fingerprintHex.length - 1; c += 2) {
+	fingerprint.push(parseInt(fingerprintHex.substring(c, c + 2), 16));
+}
+
+const params = new URLSearchParams(window.location.search);
+
+const url = params.get("url") || "https://localhost:4443";
+const datagram = params.get("datagram") || false;
+
+function log(msg) {
+	const element = document.createElement("div");
+	element.innerText = msg;
+
+	document.body.appendChild(element);
+}
+
+async function run() {
+	// Connect using the hex fingerprint in the cert folder.
+	const transport = new WebTransport(url, {
+		serverCertificateHashes: [
+			{
+				algorithm: "sha-256",
+				value: new Uint8Array(fingerprint),
+			},
+		],
+	});
+	await transport.ready;
+
+	log("connected");
+
+	let writer;
+	let reader;
+
+	if (!datagram) {
+		// Create a bidirectional stream
+		const stream = await transport.createBidirectionalStream();
+		log("created stream");
+
+		writer = stream.writable.getWriter();
+		reader = stream.readable.getReader();
+	} else {
+		log("using datagram");
+
+		// Create a datagram
+		writer = transport.datagrams.writable.getWriter();
+		reader = transport.datagrams.readable.getReader();
+	}
+
+	// Create a message
+	const msg = "Hello, world!";
+	const encoded = new TextEncoder().encode(msg);
+
+	await writer.write(encoded);
+	await writer.close();
+	writer.releaseLock();
+
+	log("send: " + msg);
+
+	// Read a message from it
+	// TODO handle partial reads
+	const { value } = await reader.read();
+
+	const recv = new TextDecoder().decode(value);
+	log("recv: " + recv);
+
+	transport.close();
+	log("closed");
+}
+
+run();