[scramjet/bootstrap] write bootstrap logic

Author: velzie

packages/scramjet/packages/bootstrap/package.json

@@ -3,9 +3,16 @@
 	"version": "0.0.1",
 	"type": "module",
 	"packageManager": "pnpm@10.12.1",
-	"main": "./dist/bootstrap.js",
+	"main": "./dist/bootstrap-server.js",
+	"types": "./dist/types/server.d.ts",
 	"dependencies": {
 		"server": "link:@mercuryworkshop/wisp-js/server",
 		"tar": "^7.5.1"
+	},
+	"devDependencies": {
+		"@mercuryworkshop/epoxy-transport": "catalog:",
+		"@mercuryworkshop/libcurl-transport": "catalog:",
+		"@mercuryworkshop/proxy-transports": "catalog:",
+		"@mercuryworkshop/scramjet-controller": "workspace:*"
 	}
 }

packages/scramjet/packages/bootstrap/src/client.ts

@@ -0,0 +1,45 @@
+import { loadScript, registerSw } from "./clientcommon";
+import { BootstrapOptions } from "./common";
+import type { ProxyTransport } from "@mercuryworkshop/proxy-transports";
+import type EpoxyClient from "@mercuryworkshop/epoxy-transport";
+import type LibcurlClient from "@mercuryworkshop/libcurl-transport";
+import * as ControllerApi from "@mercuryworkshop/scramjet-controller";
+
+export async function init(cfg: BootstrapOptions) {
+	let sw = await registerSw(cfg.swPath);
+	loadRest(sw, cfg);
+}
+
+export async function loadRest(sw: ServiceWorker, cfg: BootstrapOptions) {
+	await loadScript(cfg.scramjetBundlePath);
+	await loadScript(cfg.scramjetControllerApiPath);
+
+	let transport!: ProxyTransport;
+	if (cfg.transport === "epoxy") {
+		await loadScript(cfg.epoxyClientPath);
+		let EpoxyCtor: typeof EpoxyClient = (window as any).EpoxyTransport
+			.EpoxyClient;
+		transport = new EpoxyCtor({ wisp: cfg.wispPath });
+	} else if (cfg.transport === "libcurl") {
+		await loadScript(cfg.libcurlClientPath);
+		const LibcurlCtor: typeof LibcurlClient = (window as any).LibcurlTransport
+			.LibcurlClient;
+		transport = new LibcurlCtor({ wisp: cfg.wispPath });
+	} else if (cfg.transport === "bare") {
+		throw new Error("Bare transport not implemented yet");
+		//...
+	}
+	let { Controller, config } = (window as any)
+		.$scramjetController as typeof ControllerApi;
+	config.injectPath = cfg.scramjetControllerInjectPath;
+	config.wasmPath = cfg.scramjetWasmPath;
+	config.scramjetPath = cfg.scramjetBundlePath;
+
+	let controller = new Controller({
+		serviceworker: sw,
+		transport,
+	});
+	console.log(">?/");
+
+	return controller;
+}

packages/scramjet/packages/bootstrap/src/clientcommon.ts

@@ -0,0 +1,62 @@
+export async function registerSw(path: string): Promise<ServiceWorker> {
+	const registration = await navigator.serviceWorker.register(path, {
+		type: "classic",
+		updateViaCache: "none",
+	});
+
+	// Wait for the service worker to be ready
+	await navigator.serviceWorker.ready;
+
+	// If there's an active service worker, use it
+	if (registration.active) {
+		return registration.active;
+	}
+
+	// If there's an installing service worker, wait for it
+	if (registration.installing) {
+		await new Promise<void>((resolve) => {
+			const sw = registration.installing!;
+			if (sw.state === "activated") {
+				resolve();
+			} else {
+				sw.addEventListener("statechange", function onChange() {
+					if (sw.state === "activated") {
+						sw.removeEventListener("statechange", onChange);
+						resolve();
+					}
+				});
+			}
+		});
+
+		return registration.active!;
+	}
+
+	// If there's a waiting service worker, skip waiting and activate it
+	if (registration.waiting) {
+		registration.waiting.postMessage({ type: "SKIP_WAITING" });
+
+		await new Promise<void>((resolve) => {
+			navigator.serviceWorker.addEventListener(
+				"controllerchange",
+				() => {
+					resolve();
+				},
+				{ once: true }
+			);
+		});
+
+		return navigator.serviceWorker.controller!;
+	}
+
+	throw new Error("No service worker found in registration");
+}
+
+export function loadScript(url: string): Promise<void> {
+	return new Promise((resolve, reject) => {
+		const script = document.createElement("script");
+		script.src = url;
+		script.onload = () => resolve();
+		script.onerror = () => reject(new Error("Failed to load script " + url));
+		document.head.appendChild(script);
+	});
+}

packages/scramjet/packages/bootstrap/src/common.ts

@@ -0,0 +1,58 @@
+export const REGISTRY_URL = "https://registry.npmjs.org/";
+export const SCRAMJET_PACKAGE_NAME = "@mercuryworkshop/scramjet";
+
+export const SCRAMJET_CONTROLLER_PACKAGE_NAME =
+	"@mercuryworkshop/scramjet-controller";
+export const SCRAMJET_CONTROLLER_PINNED_MAJOR_VERSION = "0";
+
+export const EPOXY_TRANSPORT_PACKAGE_NAME = "@mercuryworkshop/epoxy-transport";
+export const EPOXY_TRANSPORT_PINNED_MAJOR_VERSION = "3";
+
+export const LIBCURL_TRANSPORT_PACKAGE_NAME =
+	"@mercuryworkshop/libcurl-transport";
+export const LIBCURL_TRANSPORT_PINNED_MAJOR_VERSION = "2";
+
+export type TransportOptions = "epoxy" | "libcurl" | "bare";
+
+export type BootstrapOptions = {
+	transport: TransportOptions;
+	swPath: string;
+
+	wispPath: string;
+
+	scramjetBundlePath: string;
+	scramjetWasmPath: string;
+
+	epoxyClientPath: string;
+	libcurlClientPath: string;
+	bareClientPath: string;
+	scramjetControllerApiPath: string;
+	scramjetControllerInjectPath: string;
+	scramjetControllerSwPath: string;
+
+	bootstrapApiPath: string;
+	bootstrapInitPath: string;
+
+	scramjetVersionPin?: string;
+	scramjetControllerVersionPin?: string;
+	epoxyTransportVersionPin?: string;
+	libcurlTransportVersionPin?: string;
+	bareTransportVersionPin?: string;
+};
+
+export const defaultConfig: Partial<BootstrapOptions> = {
+	transport: "libcurl",
+	swPath: "/sw.js",
+	wispPath: "/wisp/",
+
+	epoxyClientPath: "/clients/epoxy-client.js",
+	libcurlClientPath: "/clients/libcurl-client.js",
+	bareClientPath: "/clients/bare-client.js",
+	bootstrapInitPath: "/bootstrap-init.js",
+
+	scramjetControllerApiPath: "/controller/controller.api.js",
+	scramjetControllerInjectPath: "/controller/controller.inject.js",
+	scramjetControllerSwPath: "/controller/controller.sw.js",
+	scramjetBundlePath: "/scram/scramjet.js",
+	scramjetWasmPath: "/scram/scramjet.wasm",
+};