aboutsummaryrefslogtreecommitdiffhomepage
path: root/services/sandbox-exec/lib/exec_standalone.js
blob: 3b34adb73a1296da9c98d95d65c766c44bfc3169 (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
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(),
});