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
|
'use strict';
var cp = require('child_process');
var fs = require('fs');
var concat = require('concat-stream');
var JSON = require('./json-buffer');
var inputFile = process.argv[2];
var outputFile = process.argv[3];
var args = JSON.parse(fs.readFileSync(inputFile, 'utf8'));
function output(result) {
fs.writeFileSync(outputFile, JSON.stringify(result));
}
var child = cp.spawn.apply(cp, args);
var options = (args[2] && typeof args[2] === 'object') ?
args[2] :
(args[1] && typeof args[1] === 'object' && !Array.isArray(args[1])) ?
args[1] :
{};
var complete = false;
var stdout, stderr;
child.stdout && child.stdout.pipe(concat(function (buf) {
stdout = buf.length ? buf : new Buffer(0);
}));
child.stderr && child.stderr.pipe(concat(function (buf) {
stderr = buf.length ? buf : new Buffer(0);
}));
child.on('error', function (err) {
output({pid: child.pid, error: err.message});
});
child.on('close', function (status, signal) {
if (options.encoding && options.encoding !== 'buffer') {
stdout = stdout.toString(options.encoding);
stderr = stderr.toString(options.encoding);
}
output({
pid: child.pid,
output: [null, stdout, stderr],
stdout: stdout,
stderr: stderr,
status: status,
signal: signal
});
});
if (options.timeout && typeof options.timeout === 'number') {
setTimeout(function () {
child.kill(options.killSignal || 'SIGTERM');
}, options.timeout);
}
if (options.input && (typeof options.input === 'string' || Buffer.isBuffer(options.input))) {
child.stdin.end(options.input);
}
|