74 lines
2.0 KiB
TypeScript
74 lines
2.0 KiB
TypeScript
import { safeRun } from "../util.ts";
|
|
|
|
import { Sandbox } from "../sandbox.ts";
|
|
import { WorkerLike } from "./worker.ts";
|
|
import { Plug } from "../plug.ts";
|
|
import { AssetBundle } from "../asset_bundle/bundle.ts";
|
|
|
|
class DenoWorkerWrapper implements WorkerLike {
|
|
private worker: Worker;
|
|
onMessage?: (message: any) => Promise<void>;
|
|
ready: Promise<void>;
|
|
|
|
constructor(worker: Worker) {
|
|
this.worker = worker;
|
|
this.worker.addEventListener("message", (evt: any) => {
|
|
const data = evt.data;
|
|
if (!data) return;
|
|
safeRun(async () => {
|
|
await this.onMessage!(data);
|
|
});
|
|
});
|
|
this.ready = Promise.resolve();
|
|
}
|
|
postMessage(message: any): void {
|
|
this.worker.postMessage(message);
|
|
}
|
|
|
|
terminate() {
|
|
return this.worker.terminate();
|
|
}
|
|
}
|
|
|
|
// import workerBundleJson from "./worker_bundle.json" assert { type: "json" };
|
|
|
|
// const workerBundle = new AssetBundle(workerBundleJson);
|
|
|
|
// import "./sandbox_worker.ts";
|
|
|
|
export function createSandbox(plug: Plug<any>) {
|
|
// const workerHref = URL.createObjectURL(
|
|
// new Blob([
|
|
// workerBundle.readFileSync("worker.js"),
|
|
// ], {
|
|
// type: "application/javascript",
|
|
// }),
|
|
// );
|
|
const worker = new Worker(
|
|
// workerHref,
|
|
// import.meta.resolve("./sandbox_worker.ts"),
|
|
new URL("./sandbox_worker.ts", import.meta.url),
|
|
{
|
|
type: "module",
|
|
deno: {
|
|
permissions: {
|
|
// Disallow network access
|
|
net: false,
|
|
// This is required for console logging to work, apparently?
|
|
env: true,
|
|
// No talking to native code
|
|
ffi: false,
|
|
// No invocation of shell commands
|
|
run: false,
|
|
// No read access to the file system
|
|
read: false,
|
|
// No write access to the file system
|
|
write: false,
|
|
},
|
|
},
|
|
// Have to do this because the "deno" option is not standard and doesn't typecheck yet
|
|
} as any,
|
|
);
|
|
return new Sandbox(plug, new DenoWorkerWrapper(worker));
|
|
}
|