feat(worker): move directory worker/ to worker/php/

1 files changed, 0 insertions, 85 deletions

diff --git a/worker/exec.mjs b/worker/exec.mjs
deleted file mode 100644
index d8ca899..0000000
--- a/worker/exec.mjs
+++ /dev/null
@@ -1,85 +0,0 @@
-import PHPWasm from "./php-wasm.js";
-
-process.once("message", async ({ code: originalCode, input }) => {
-	const PRELUDE = `
-  define('STDIN', fopen('php://stdin', 'r'));
-  define('STDOUT', fopen('php://stdout', 'r'));
-  define('STDERR', fopen('php://stderr', 'r'));
-
-  error_reporting(E_ALL & ~E_WARNING & ~E_NOTICE & ~E_DEPRECATED);
-
-  `;
-
-	// remove php tag
-	let code;
-	if (originalCode.startsWith("<?php")) {
-		code = PRELUDE + originalCode.slice(5);
-	} else if (originalCode.startsWith("<?")) {
-		code = PRELUDE + originalCode.slice(2);
-	} else {
-		code = PRELUDE + originalCode;
-	}
-
-	const BUFFER_MAX = 10 * 1024;
-
-	let stdinPos = 0; // bytewise
-	const stdinBuf = Buffer.from(input);
-	let stdoutPos = 0; // bytewise
-	const stdoutBuf = Buffer.alloc(BUFFER_MAX);
-	let stderrPos = 0; // bytewise
-	const stderrBuf = Buffer.alloc(BUFFER_MAX);
-
-	const { ccall } = await PHPWasm({
-		stdin: () => {
-			if (stdinBuf.length <= stdinPos) {
-				return null;
-			}
-			return stdinBuf.readUInt8(stdinPos++);
-		},
-		stdout: (asciiCode) => {
-			if (asciiCode === null) {
-				return; // flush
-			}
-			if (BUFFER_MAX <= stdoutPos) {
-				return; // ignore
-			}
-			stdoutBuf.writeUInt8(
-				asciiCode < 0 ? asciiCode + 256 : asciiCode,
-				stdoutPos++,
-			);
-		},
-		stderr: (asciiCode) => {
-			if (asciiCode === null) {
-				return; // flush
-			}
-			if (BUFFER_MAX <= stderrPos) {
-				return; // ignore
-			}
-			stderrBuf.writeUInt8(
-				asciiCode < 0 ? asciiCode + 256 : asciiCode,
-				stderrPos++,
-			);
-		},
-	});
-
-	let err;
-	let result;
-	try {
-		result = ccall("php_wasm_run", "number", ["string"], [code]);
-	} catch (e) {
-		err = e;
-	}
-	if (err) {
-		process.send({
-			status: "runtime_error",
-			stdout: stdoutBuf.subarray(0, stdoutPos).toString(),
-			stderr: `${stderrBuf.subarray(0, stderrPos).toString()}\n${err.toString()}`,
-		});
-	} else {
-		process.send({
-			status: result === 0 ? "success" : "runtime_error",
-			stdout: stdoutBuf.subarray(0, stdoutPos).toString(),
-			stderr: stderrBuf.subarray(0, stderrPos).toString(),
-		});
-	}
-});