embarklabs
/
embark
mirror of https://github.com/embarklabs/embark.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

support long running processes comms via stdin/stdout

This commit is contained in:
Andre Medeiros 2019-07-24 15:54:57 -04:00
parent 2beeaa68f1
commit a03ad9aacc
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/embark-core/src/processes/processLauncher.js
View File

@ -10,6 +10,7 @@ class ProcessLauncher extends EventEmitter {
this.name = options.name;
this.command = options.command;
this.args = options.args || [];
this.splitLines = !!options.splitLines;
}
start() {
@ -18,9 +19,15 @@ class ProcessLauncher extends EventEmitter {
}
const stdioHandler = (chunk, fd) => {
const ev = `output:${fd}`; // output:stdout, output:stderr
if (!this.splitLines) {
return this.emit(ev, chunk.toString());
}
const lines = chunk.toString().trim().split("\n");
for (const l of lines) {
this.emit(`output:${fd}`, l);
this.emit(ev, l);
}
};
@ -29,7 +36,7 @@ class ProcessLauncher extends EventEmitter {
this.args,
{
detached: true,
stdio: [null, 'pipe', 'pipe'],
stdio: ['pipe', 'pipe', 'pipe'],
windowsHide: true
}
);
@ -56,6 +63,14 @@ class ProcessLauncher extends EventEmitter {
process.on('exit', () => child.kill('SIGINT'));
}
send(buf) {
if (!this.child) {
throw new Error('child process not started or killed');
}
this.child.stdin.write(buf);
}
stop() {
if (!this.child) {
throw new Error('child process not started or killed');
@ -100,8 +115,6 @@ class ProcessLauncher extends EventEmitter {