feat(web): optional wordle-answers
This commit is contained in:
@@ -3,6 +3,7 @@ import SolverWorker from "./worker?worker";
|
||||
import type { GuessResult, SolutionSpaceResult, EvaluateWordsResult, SolverRequest, SolverResponse, EvaluateWordsProgress } from "./types";
|
||||
|
||||
let solver_worker = new SolverWorker();
|
||||
await init_solver();
|
||||
|
||||
let msg_id = 0;
|
||||
|
||||
@@ -13,6 +14,25 @@ const pending = new Map<number, {
|
||||
|
||||
const progresses = new Map<number, (p: EvaluateWordsProgress) => void>();
|
||||
|
||||
function init_solver(): Promise<void> {
|
||||
return new Promise((resolve) => {
|
||||
solver_worker.onmessage = (event: any) => {
|
||||
if (event.data.type === "ready") {
|
||||
solver_worker.onmessage = workerHandleMsg;
|
||||
resolve();
|
||||
} else {
|
||||
workerHandleMsg(event);
|
||||
}
|
||||
};
|
||||
});
|
||||
}
|
||||
|
||||
function create_solver_worker(): Promise<void> {
|
||||
solver_worker = new SolverWorker();
|
||||
|
||||
return init_solver();
|
||||
}
|
||||
|
||||
export function solver_guess(word: string[], colors: Color[]): Promise<GuessResult> {
|
||||
const id = msg_id++;
|
||||
|
||||
@@ -47,11 +67,11 @@ export function solver_solution_space(): Promise<SolutionSpaceResult> {
|
||||
|
||||
export function solver_evaluate_words(n: number, progress: ((p: EvaluateWordsProgress) => void) | null): Promise<EvaluateWordsResult> {
|
||||
const id = msg_id++;
|
||||
|
||||
|
||||
if (progress) {
|
||||
progresses.set(id, progress);
|
||||
}
|
||||
|
||||
|
||||
return new Promise((resolve, reject) => {
|
||||
pending.set(id, { resolve, reject });
|
||||
|
||||
@@ -65,13 +85,40 @@ export function solver_evaluate_words(n: number, progress: ((p: EvaluateWordsPro
|
||||
});
|
||||
}
|
||||
|
||||
export async function solver_reset(wordle_answers: boolean): Promise<void> {
|
||||
solver_worker.terminate();
|
||||
|
||||
solver_worker.onmessage = (event: MessageEvent<SolverResponse>) => {
|
||||
await create_solver_worker();
|
||||
console.log("Created: ans=" + wordle_answers);
|
||||
|
||||
pending.forEach((v, _) => {
|
||||
v.reject("Solver was reset");
|
||||
});
|
||||
pending.clear();
|
||||
progresses.clear();
|
||||
|
||||
const id = msg_id++;
|
||||
|
||||
return new Promise((resolve, reject) => {
|
||||
pending.set(id, { resolve, reject });
|
||||
|
||||
const r: SolverRequest = {
|
||||
type: "reload_wordlist",
|
||||
id: id,
|
||||
input: { use_wordle_ansers: wordle_answers },
|
||||
};
|
||||
|
||||
solver_worker.postMessage(JSON.parse(JSON.stringify(r)));
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
function workerHandleMsg(event: MessageEvent<SolverResponse>) {
|
||||
let res = event.data;
|
||||
|
||||
|
||||
if (res.type == "evaluate_words_progress") {
|
||||
let progress = progresses.get(res.id);
|
||||
|
||||
|
||||
if (progress) {
|
||||
progress(res.result);
|
||||
}
|
||||
@@ -79,6 +126,8 @@ solver_worker.onmessage = (event: MessageEvent<SolverResponse>) => {
|
||||
return;
|
||||
}
|
||||
|
||||
console.log("Rcv msg: ", res.type + " " + res.id);
|
||||
|
||||
const pendingRequest = pending.get(res.id);
|
||||
|
||||
if (!pendingRequest) {
|
||||
@@ -95,4 +144,5 @@ solver_worker.onmessage = (event: MessageEvent<SolverResponse>) => {
|
||||
} else {
|
||||
pendingRequest.reject("No result");
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user