Add initial webui
This commit is contained in:
104
webui/src/lib/runner.ts
Normal file
104
webui/src/lib/runner.ts
Normal file
@@ -0,0 +1,104 @@
|
||||
"use client";
|
||||
|
||||
let worker: Worker | null = null;
|
||||
|
||||
export function sendDataToScript(data: String) {
|
||||
if (worker) {
|
||||
worker.postMessage({ type: "data", data });
|
||||
}
|
||||
}
|
||||
|
||||
export async function startScript(
|
||||
script: string,
|
||||
appendOutput: (line: string) => void,
|
||||
appendTerminal: (line: string) => void
|
||||
): Promise<void> {
|
||||
return new Promise((resolve, reject) => {
|
||||
if (worker) {
|
||||
worker.terminate();
|
||||
}
|
||||
|
||||
worker = new Worker(new URL("./worker_human.ts", import.meta.url));
|
||||
|
||||
worker.onmessage = (event) => {
|
||||
const { type, line, error } = event.data;
|
||||
|
||||
if (type === "output") {
|
||||
appendOutput(line);
|
||||
} else if (type === "terminal") {
|
||||
appendTerminal(line);
|
||||
} else if (type === "complete") {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
resolve();
|
||||
} else if (type === "error") {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
reject(new Error(error));
|
||||
} else if (type === "stopped") {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
resolve();
|
||||
}
|
||||
};
|
||||
|
||||
worker.onerror = (error) => {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
reject(error);
|
||||
};
|
||||
|
||||
worker.postMessage({ type: "run", script });
|
||||
});
|
||||
}
|
||||
|
||||
export async function startScriptBulk(
|
||||
script: string,
|
||||
appendOutput: (line: string) => void,
|
||||
appendTerminal: (line: string) => void,
|
||||
rounds: number = 1000
|
||||
): Promise<void> {
|
||||
return new Promise((resolve, reject) => {
|
||||
if (worker) {
|
||||
worker.terminate();
|
||||
}
|
||||
|
||||
worker = new Worker(new URL("./worker_bulk.ts", import.meta.url));
|
||||
|
||||
worker.onmessage = (event) => {
|
||||
const { type, line, error } = event.data;
|
||||
|
||||
if (type === "output") {
|
||||
appendOutput(line);
|
||||
} else if (type === "terminal") {
|
||||
appendTerminal(line);
|
||||
} else if (type === "complete") {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
resolve();
|
||||
} else if (type === "error") {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
reject(new Error(error));
|
||||
} else if (type === "stopped") {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
resolve();
|
||||
}
|
||||
};
|
||||
|
||||
worker.onerror = (error) => {
|
||||
worker?.terminate();
|
||||
worker = null;
|
||||
reject(error);
|
||||
};
|
||||
|
||||
worker.postMessage({ type: "run", script, rounds });
|
||||
});
|
||||
}
|
||||
|
||||
export function stopScript(): void {
|
||||
if (worker) {
|
||||
worker.postMessage({ type: "stop" });
|
||||
}
|
||||
}
|
||||
113
webui/src/lib/worker_bulk.ts
Normal file
113
webui/src/lib/worker_bulk.ts
Normal file
@@ -0,0 +1,113 @@
|
||||
import init, { MinMaxGame } from "../wasm/runner";
|
||||
|
||||
let wasmReady = false;
|
||||
let wasmInitPromise: Promise<void> | null = null;
|
||||
let currentGame: MinMaxGame | null = null;
|
||||
|
||||
async function initWasm(): Promise<void> {
|
||||
if (wasmReady) return;
|
||||
|
||||
if (wasmInitPromise) {
|
||||
return wasmInitPromise;
|
||||
}
|
||||
|
||||
wasmInitPromise = (async () => {
|
||||
await init();
|
||||
wasmReady = true;
|
||||
})();
|
||||
|
||||
return wasmInitPromise;
|
||||
}
|
||||
|
||||
self.onmessage = async (event) => {
|
||||
const { type, ...event_data } = event.data;
|
||||
|
||||
if (type === "init") {
|
||||
try {
|
||||
await initWasm();
|
||||
self.postMessage({ type: "ready" });
|
||||
} catch (error) {
|
||||
self.postMessage({ type: "error", error: String(error) });
|
||||
}
|
||||
} else if (type === "run") {
|
||||
try {
|
||||
await initWasm();
|
||||
|
||||
self.postMessage({
|
||||
type: "output",
|
||||
line: "Output is disabled during bulk runs.",
|
||||
});
|
||||
|
||||
const appendTerminal = (line: string) => {
|
||||
self.postMessage({ type: "terminal", line });
|
||||
};
|
||||
|
||||
const n_rounds = event_data.rounds || 1000;
|
||||
const start = performance.now();
|
||||
let red_wins = 0;
|
||||
let blue_wins = 0;
|
||||
let draw_score = 0;
|
||||
let draw_invalid = 0;
|
||||
|
||||
for (var i = 0; i < n_rounds; i++) {
|
||||
appendTerminal(`\n\r`);
|
||||
appendTerminal(`============\n\r`);
|
||||
appendTerminal(`= Round ${i + 1}\n\r`);
|
||||
appendTerminal(`============\n\n\r`);
|
||||
|
||||
currentGame = new MinMaxGame(
|
||||
event_data.script,
|
||||
() => {},
|
||||
() => {},
|
||||
|
||||
event_data.script,
|
||||
() => {},
|
||||
() => {},
|
||||
|
||||
appendTerminal
|
||||
);
|
||||
|
||||
while (currentGame && !currentGame.is_done()) {
|
||||
currentGame.step();
|
||||
}
|
||||
|
||||
appendTerminal("\r\n");
|
||||
|
||||
if (currentGame.is_error()) {
|
||||
break;
|
||||
}
|
||||
|
||||
if (currentGame.red_won() === true) {
|
||||
red_wins += 1;
|
||||
} else if (currentGame.blue_won() === true) {
|
||||
blue_wins += 1;
|
||||
} else if (currentGame.is_draw_invalid() === true) {
|
||||
draw_invalid += 1;
|
||||
} else if (currentGame.is_draw_score() === true) {
|
||||
draw_score += 1;
|
||||
}
|
||||
}
|
||||
|
||||
const elapsed = Math.round((performance.now() - start) / 100) / 10;
|
||||
const r_winrate = Math.round((red_wins / n_rounds) * 1000) / 10
|
||||
const b_winrate = Math.round((blue_wins / n_rounds) * 1000) / 10
|
||||
|
||||
appendTerminal("\r\n");
|
||||
appendTerminal(`Ran ${n_rounds} rounds in ${elapsed}s\r\n`);
|
||||
appendTerminal(`Red won: ${red_wins} (${r_winrate}%)\r\n`);
|
||||
appendTerminal(`Blue won: ${blue_wins} (${b_winrate}%)\r\n`);
|
||||
appendTerminal("\r\n");
|
||||
appendTerminal(`Draws: ${draw_score}\r\n`);
|
||||
appendTerminal(`Invalid: ${draw_invalid}\r\n`);
|
||||
|
||||
if (currentGame) {
|
||||
self.postMessage({ type: "complete" });
|
||||
}
|
||||
} catch (error) {
|
||||
self.postMessage({ type: "error", error: String(error) });
|
||||
}
|
||||
} else if (type === "stop") {
|
||||
currentGame = null;
|
||||
self.postMessage({ type: "stopped" });
|
||||
}
|
||||
};
|
||||
71
webui/src/lib/worker_human.ts
Normal file
71
webui/src/lib/worker_human.ts
Normal file
@@ -0,0 +1,71 @@
|
||||
import init, { GameState, GameStateHuman } from "../wasm/runner";
|
||||
|
||||
let wasmReady = false;
|
||||
let wasmInitPromise: Promise<void> | null = null;
|
||||
let currentGame: GameStateHuman | null = null;
|
||||
|
||||
async function initWasm(): Promise<void> {
|
||||
if (wasmReady) return;
|
||||
|
||||
if (wasmInitPromise) {
|
||||
return wasmInitPromise;
|
||||
}
|
||||
|
||||
wasmInitPromise = (async () => {
|
||||
await init();
|
||||
wasmReady = true;
|
||||
})();
|
||||
|
||||
return wasmInitPromise;
|
||||
}
|
||||
|
||||
self.onmessage = async (event) => {
|
||||
const { type, ...event_data } = event.data;
|
||||
|
||||
if (type === "data") {
|
||||
if (currentGame !== null) {
|
||||
currentGame.take_input(event_data.data);
|
||||
|
||||
if (currentGame.is_error()) {
|
||||
currentGame = null;
|
||||
self.postMessage({ type: "complete" });
|
||||
} else if (currentGame.is_done()) {
|
||||
currentGame = null;
|
||||
self.postMessage({ type: "complete" });
|
||||
}
|
||||
}
|
||||
} else if (type === "init") {
|
||||
try {
|
||||
await initWasm();
|
||||
self.postMessage({ type: "ready" });
|
||||
} catch (error) {
|
||||
self.postMessage({ type: "error", error: String(error) });
|
||||
}
|
||||
} else if (type === "run") {
|
||||
try {
|
||||
await initWasm();
|
||||
|
||||
const appendOutput = (line: string) => {
|
||||
self.postMessage({ type: "output", line });
|
||||
};
|
||||
|
||||
const appendTerminal = (line: string) => {
|
||||
self.postMessage({ type: "terminal", line });
|
||||
};
|
||||
|
||||
currentGame = new GameStateHuman(
|
||||
event_data.script,
|
||||
appendOutput,
|
||||
appendOutput,
|
||||
appendTerminal
|
||||
);
|
||||
|
||||
currentGame.print_start();
|
||||
} catch (error) {
|
||||
self.postMessage({ type: "error", error: String(error) });
|
||||
}
|
||||
} else if (type === "stop") {
|
||||
currentGame = null;
|
||||
self.postMessage({ type: "stopped" });
|
||||
}
|
||||
};
|
||||
Reference in New Issue
Block a user