\n \n

,\n ),\n { headers: { \"content-type\": \"text/html\" } },\n );\n }\n};\n\ninterface Segment {\n code: string;\n result?: { args: unknown[]; level: string; index: number }[];\n}\n\nconst hashSegments = (segments: Segment[]): string => {\n return base32Encode(\n createHash(\"sha256\").update(JSON.stringify(segments.map(s => s.code))).digest().slice(0, 20),\n \"RFC4648\",\n { padding: false },\n ).toLowerCase();\n};\n\ntype Log = {\n level: string;\n args: unknown[];\n stack: string;\n};\n\n// The script we run within the worker. Don't reference anything\n// outside of this function as it won't be available within the worker. We could even host this in a separate val and pass\nconst workerScript = () => {\n type Log = {\n level: string;\n args: unknown[];\n stack: string;\n };\n\n const logs: Log[] = [];\n globalThis.console = new Proxy(console, {\n get(target, key) {\n const real = target[key];\n if (typeof real === \"function\" && typeof key === \"string\") {\n const fn = function(...args: any[]) {\n logs.push({\n level: key,\n stack: new Error().stack.replace(\"Error\\n\", \"\")\n .split(\"\\n\").filter((s) => !s.includes(\"Proxy.fn\"))\n .join(\"\\n\"),\n args,\n });\n return real.call(this, ...args);\n };\n return fn;\n }\n },\n });\n async function evaluate(url) {\n try {\n const _ = await import(url);\n return;\n } catch (err) {\n return { error: { message: err.message, stack: err.stack.replaceAll(url, \"./script.ts\") } };\n }\n }\n self.onmessage = async (e) => {\n const blob = new Blob([e.data], { type: \"text/tsx\" });\n const url = URL.createObjectURL(blob);\n let resp = await evaluate(url);\n logs.forEach((l) => {\n l.stack = l.stack.replaceAll(url, \"./script.ts\");\n });\n self.postMessage(JSON.stringify({ resp, logs }));\n };\n};\n\ntype EvalResponse = { segments?: Segment[]; error?: { message: string; stack: string } };\n// read eval print page\nclass Repp {\n #segments: Segment[];\n constructor(segments: Segment[]) {\n this.#segments = segments;\n }\n hash(): string {\n // A subjectively \"nice looking\" hash value.\n // https://github.com/maxmcd/bramble/blob/205f61427fe505d109d22ef94967561006d6c83d/pkg/hasher/hasher.go#L47-L55\n return base32Encode(\n createHash(\"sha256\").update(JSON.stringify(this.#segments.map(s => s.code))).digest().slice(0, 20),\n \"RFC4648\",\n { padding: false },\n ).toLowerCase();\n }\n async save() {\n await blob.setJSON(this.hash(), this.#segments);\n }\n get segments() {\n return this.#segments;\n }\n get segmentLineIndex() {\n return [].concat(...this.#segments.map((s, i) => s.code.split(\"\\n\").map(() => i)));\n }\n async eval() {\n const blob = new Blob([`(${workerScript.toString()})()`], {\n type: \"text/tsx\",\n });\n return await new Promise(\n (resolve, reject) => {\n // Run the users code in a worker.\n let work = new Worker(URL.createObjectURL(blob), { type: \"module\" });\n const timeout = setTimeout(() => {\n work.terminate();\n resolve({ error: { message: \"timeout\" } });\n }, TIMEOUT);\n work.postMessage(this.#segments.map((s) => s.code).join(\"\\n\"));\n work.onmessage = (e) => {\n try {\n const resp: { logs: Log[]; error?: { message: string; stack: string } } = JSON.parse(e.data);\n this.segmentLineIndex;\n resp.logs.forEach((l) => {\n // Get the location of the log line in the total script by grabbing the\n // location at the last line of the last stack entry.\n let location = parseInt(l.stack.split(\"\\n\").slice(-1)[0].split(\":\").slice(-2, -1)[0]);\n // Which segment is this log line related to?\n const segmentIndex = this.segmentLineIndex[location - 1];\n const segment = this.#segments[segmentIndex];\n // Subtract the numbers of lines ahead of this segment so that log\n // locations are relative to a singe block.\n location = location - this.segmentLineIndex.indexOf(segmentIndex);\n // Append the logs, add the args, turn the line location into an index.\n segment.result = [...(segment.result ?? []), { args: l.args, level: l.level, index: location - 1 }];\n });\n clearTimeout(timeout);\n work.terminate();\n resolve({ segments: this.#segments, error: resp.error });\n } catch (e) {\n reject(e);\n }\n };\n },\n );\n }\n}\n\nexport default fetch;\n// https://stackoverflow.com/a/67394423/1333724\n// var __EVAL = async (s) => eval(`(async () => (void (__EVAL = ${__EVAL.toString()}); ${s}))()`);\n\n// // evaluate(\"let ten = 10\");\n// // evaluate(\"function cube(x) { return x ** 3 }\");\n// // evaluate(\"ten + cube(3)\");\n// evaluate(`\n// let resp = await fetch('https://www.google.com');\n// console.log(resp)\n// let x = 10\n// let foo = () => {\n// console.log(\"ho\")\n// }\n// let foo2 = () => {\n// foo()\n// }\n// let foo3 = () => {\n// foo2()\n// }\n// let foo4 = () => {\n// foo3()\n// }\n// let foo5 = () => {\n// foo4()\n// }\n\n// console.log(\"hi\")\n// foo5()\n\n// throw new Error(\"hi\")\n\n// `);\n// evaluate(\"console.log(\\\"SIDE EFFECT\\\")\");\n// evaluate(\"let twenty = 20\");\n// evaluate(\"twenty + 40\");","deleted","label",[98],"permalink","https://www.val.town/x/maxm/repp/code/main.tsx","extension","actionData","errors"]