syndicate-lang
/
syndicate-js
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Debug output for subprocess

This commit is contained in:
Tony Garnock-Jones 2019-06-03 12:05:18 +01:00
parent f19ecb69c8
commit d061d21748
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/driver-streams-node/package.json
View File

@ -19,6 +19,7 @@
"@syndicate-lang/syntax": "^0.1.0"
},
"dependencies": {
"@syndicate-lang/core": "^0.1.2"
"@syndicate-lang/core": "^0.1.2",
"debug": "^4.1.1"
}
}

6
packages/driver-streams-node/src/subprocess.js
View File

@ -20,6 +20,7 @@ import { currentFacet, Observe, Dataspace, genUuid, Bytes } from "@syndicate-lan
const S = activate require("./streams");
const Duplex = require("./duplex");
const child_process = require('child_process');
const debug = require('debug')('syndicate/driver-streams-node:subprocess');
assertion type Subprocess(id, command, args, options);
assertion type SubprocessAddress(command, args, options);
@ -60,6 +61,8 @@ spawn named 'driver/Subprocess' {
establishingFacet.stop(() => {
react {
S.duplexStreamBehaviour(id, s);
on start debug('+stream', id, command.toString(), args.toString(), options.toString());
on stop debug('-stream', id, command.toString(), args.toString(), options.toString());
on stop try { sp.kill('SIGHUP'); } catch (e) {}
}
});
@ -67,6 +70,9 @@ spawn named 'driver/Subprocess' {
}
during Subprocess($id, $command, $args, $options) spawn named ['Subprocess', id] {
on start debug('+subprocess', id, command.toString(), args.toString(), options.toString());
on stop debug('-subprocess', id, command.toString(), args.toString(), options.toString());
const sp = child_process.spawn(command, args.toJS(), options ? options.toJS() : void 0);
const stdio = sp.stdio.map((s, i) => {