67 lines
1.6 KiB
TypeScript
67 lines
1.6 KiB
TypeScript
import { VMScript, NodeVM } from 'vm2';
|
|
import crypto1 from 'crypto';
|
|
import net1 from 'net';
|
|
|
|
const evaluate = async (script, scope) => {
|
|
const vm = new NodeVM({
|
|
allowAsync: true,
|
|
sandbox: {},
|
|
console: 'inherit',
|
|
wrapper: 'none',
|
|
require: {
|
|
builtin: ['stream', 'http', 'https', 'url', 'buffer', 'zlib', 'isomorphic-fetch', 'punycode', 'encoding', 'net'],
|
|
root: ['./'],
|
|
external: true,
|
|
context: 'sandbox'
|
|
}
|
|
});
|
|
|
|
const s = new VMScript(script, scope);
|
|
return await vm.run(script, scope);
|
|
};
|
|
|
|
const socketName = crypto1.randomBytes(20).toString('hex');
|
|
|
|
const server = net1.createServer(socket => {
|
|
const buffer = [];
|
|
|
|
const sync = async () => {
|
|
|
|
const request = buffer.join('').toString();
|
|
console.log(request);
|
|
if (request.includes('\n')) {
|
|
try {
|
|
const { code, scope } = JSON.parse(request);
|
|
|
|
const result = await evaluate(code, {
|
|
...scope,
|
|
module: null
|
|
});
|
|
|
|
console.log(JSON.stringify({ result }));
|
|
socket.write(JSON.stringify({ result }) + '\n');
|
|
socket.end();
|
|
} catch (error) {
|
|
console.log(`RUNTIME: ${error.message}, ${error.stack}`);
|
|
socket.write(JSON.stringify({ error: error.message }) + '\n');
|
|
socket.end();
|
|
}
|
|
}
|
|
};
|
|
socket.on('error', err => {
|
|
|
|
console.log(err);
|
|
});
|
|
|
|
|
|
socket.on('data', data => {
|
|
buffer.push(data);
|
|
sync();
|
|
});
|
|
});
|
|
|
|
server.on('listening', () => {
|
|
console.log(`/tmp/vm2-${socketName}.sock`);
|
|
});
|
|
|
|
server.listen(`/tmp/vm2-${socketName}.sock`);
|