aboutsummaryrefslogtreecommitdiffhomepage
path: root/worker/php/exec.mjs
blob: d8ca8993db0ff85edede1ea78f41b8f6beaa7fc8 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
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(),
		});
	}
});