aboutsummaryrefslogtreecommitdiffhomepage
path: root/services/sandbox-exec/lib/exec_standalone.js
diff options
context:
space:
mode:
Diffstat (limited to 'services/sandbox-exec/lib/exec_standalone.js')
-rw-r--r--services/sandbox-exec/lib/exec_standalone.js67
1 files changed, 67 insertions, 0 deletions
diff --git a/services/sandbox-exec/lib/exec_standalone.js b/services/sandbox-exec/lib/exec_standalone.js
new file mode 100644
index 0000000..3b34adb
--- /dev/null
+++ b/services/sandbox-exec/lib/exec_standalone.js
@@ -0,0 +1,67 @@
+import { readFileSync } from 'node:fs';
+import PHPWasm from './php-wasm.js'
+
+const userCode = `
+while ($l = fgets(STDIN)) {
+ echo $l, PHP_EOL;
+}
+`;
+
+const PRELUDE = `
+define('STDIN', fopen('php://stdin', 'r'));
+define('STDOUT', fopen('php://stdout', 'r'));
+define('STDERR', fopen('php://stderr', 'r'));
+
+`;
+const BUFFER_MAX = 1024 * 1024 * 1;
+
+let stdinPos = 0; // bytewise
+let stdinBuf = Buffer.from(readFileSync('/dev/stdin'));
+let stdoutPos = 0; // bytewise
+let stdoutBuf = Buffer.alloc(BUFFER_MAX);
+let stderrPos = 0; // bytewise
+let 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
+ }
+ if (asciiCode < 0) {
+ asciiCode += 256;
+ }
+ stdoutBuf.writeUInt8(asciiCode, stdoutPos++);
+ },
+ stderr: (asciiCode) => {
+ if (asciiCode === null) {
+ return; // flush
+ }
+ if (BUFFER_MAX <= stderrPos) {
+ return; // ignore
+ }
+ if (asciiCode < 0) {
+ asciiCode += 256;
+ }
+ stderrBuf.writeUInt8(asciiCode, stderrPos++);
+ },
+});
+
+const result = ccall(
+ 'php_wasm_run',
+ 'number', ['string'],
+ [PRELUDE + userCode],
+);
+console.log({
+ status: result === 0 ? 'AC' : 'RE',
+ stdout: stdoutBuf.subarray(0, stdoutPos).toString(),
+ stderr: stderrBuf.subarray(0, stderrPos).toString(),
+});