match existing behaviour when custom listeners defined
This commit is contained in:
parent
2b27c68c84
commit
45e00a8e6a
3 changed files with 30 additions and 13 deletions
23
lib/exec_wrapper.js
generated
23
lib/exec_wrapper.js
generated
|
|
@ -15,17 +15,26 @@ async function exec_wrapper(commandLine, args, options) {
|
||||||
let stderr = '';
|
let stderr = '';
|
||||||
let listeners = {
|
let listeners = {
|
||||||
stdout: (data) => {
|
stdout: (data) => {
|
||||||
var _a, _b, _c;
|
var _a;
|
||||||
stdout += data.toString();
|
stdout += data.toString();
|
||||||
// NB change behaviour to only write to stdout/err if no listener passed
|
if (((_a = originalListener) === null || _a === void 0 ? void 0 : _a.stdout) !== undefined) {
|
||||||
process.stdout.write(data);
|
originalListener.stdout(data);
|
||||||
(_c = (_a = originalListener) === null || _a === void 0 ? void 0 : (_b = _a).stdout) === null || _c === void 0 ? void 0 : _c.call(_b, data);
|
}
|
||||||
|
else {
|
||||||
|
// if no stdout listener was originally defined then match behaviour of exec.exec
|
||||||
|
process.stdout.write(data);
|
||||||
|
}
|
||||||
},
|
},
|
||||||
stderr: (data) => {
|
stderr: (data) => {
|
||||||
var _a, _b, _c;
|
var _a;
|
||||||
stderr += data.toString();
|
stderr += data.toString();
|
||||||
process.stderr.write(data);
|
if (((_a = originalListener) === null || _a === void 0 ? void 0 : _a.stderr) !== undefined) {
|
||||||
(_c = (_a = originalListener) === null || _a === void 0 ? void 0 : (_b = _a).stderr) === null || _c === void 0 ? void 0 : _c.call(_b, data);
|
originalListener.stderr(data);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
// if no stderr listener was originally defined then match behaviour of exec.exec
|
||||||
|
process.stderr.write(data);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
const returnCode = await exec.exec(commandLine, args, {
|
const returnCode = await exec.exec(commandLine, args, {
|
||||||
|
|
|
||||||
|
|
@ -1 +1 @@
|
||||||
{"version":3,"file":"exec_wrapper.js","sourceRoot":"","sources":["../src/exec_wrapper.ts"],"names":[],"mappings":";;;;;;;;;AAAA,oDAAsC;AAG/B,KAAK,UAAU,YAAY,CAAC,WAAmB,EAAE,IAAe,EAAE,OAAwB;;IAE/F,MAAM,gBAAgB,SAAG,OAAO,0CAAE,SAAS,CAAC;IAE5C,IAAI,MAAM,GAAG,EAAE,CAAC;IAChB,IAAI,MAAM,GAAG,EAAE,CAAC;IAEhB,IAAI,SAAS,GAAG;QACd,MAAM,EAAE,CAAC,IAAY,EAAE,EAAE;;YACvB,MAAM,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC;YAC1B,wEAAwE;YACxE,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;YAC3B,YAAA,gBAAgB,iDAAE,MAAM,mDAAG,IAAI,EAAE;QACnC,CAAC;QACD,MAAM,EAAE,CAAC,IAAY,EAAE,EAAE;;YACvB,MAAM,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC;YAC1B,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;YAC3B,YAAA,gBAAgB,iDAAE,MAAM,mDAAG,IAAI,EAAE;QACnC,CAAC;KACF,CAAC;IAEF,MAAM,UAAU,GAAG,MAAM,IAAI,CAAC,IAAI,CAChC,WAAW,EACX,IAAI,EACJ;QACE,SAAS,EAAE,SAAS;QACpB,GAAG,OAAO;KACX,CAAC,CAAC;IAEL,IAAI,MAAM,KAAK,MAAM,EAAG;QACtB,OAAO,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;KACxB;IAED,OAAO,UAAU,CAAC;AAEpB,CAAC;AAnCD,oCAmCC"}
|
{"version":3,"file":"exec_wrapper.js","sourceRoot":"","sources":["../src/exec_wrapper.ts"],"names":[],"mappings":";;;;;;;;;AAAA,oDAAsC;AAG/B,KAAK,UAAU,YAAY,CAAC,WAAmB,EAAE,IAAe,EAAE,OAAwB;;IAE/F,MAAM,gBAAgB,SAAG,OAAO,0CAAE,SAAS,CAAC;IAE5C,IAAI,MAAM,GAAG,EAAE,CAAC;IAChB,IAAI,MAAM,GAAG,EAAE,CAAC;IAEhB,IAAI,SAAS,GAAG;QACd,MAAM,EAAE,CAAC,IAAY,EAAE,EAAE;;YACvB,MAAM,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC;YAC1B,IAAI,OAAA,gBAAgB,0CAAE,MAAM,MAAK,SAAS,EAAE;gBAC1C,gBAAgB,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;aAC/B;iBAAM;gBACL,iFAAiF;gBACjF,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;aAC5B;QAEH,CAAC;QACD,MAAM,EAAE,CAAC,IAAY,EAAE,EAAE;;YACvB,MAAM,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC;YAC1B,IAAI,OAAA,gBAAgB,0CAAE,MAAM,MAAK,SAAS,EAAE;gBAC1C,gBAAgB,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;aAC/B;iBAAM;gBACL,iFAAiF;gBACjF,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;aAC5B;QACH,CAAC;KACF,CAAC;IAEF,MAAM,UAAU,GAAG,MAAM,IAAI,CAAC,IAAI,CAChC,WAAW,EACX,IAAI,EACJ;QACE,SAAS,EAAE,SAAS;QACpB,GAAG,OAAO;KACX,CAAC,CAAC;IAEL,IAAI,MAAM,KAAK,MAAM,EAAG;QACtB,OAAO,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;KACxB;IAED,OAAO,UAAU,CAAC;AAEpB,CAAC;AA3CD,oCA2CC"}
|
||||||
|
|
@ -11,14 +11,22 @@ export async function exec_wrapper(commandLine: string, args?: string[], options
|
||||||
let listeners = {
|
let listeners = {
|
||||||
stdout: (data: Buffer) => {
|
stdout: (data: Buffer) => {
|
||||||
stdout += data.toString();
|
stdout += data.toString();
|
||||||
// NB change behaviour to only write to stdout/err if no listener passed
|
if (originalListener?.stdout !== undefined) {
|
||||||
process.stdout.write(data);
|
originalListener.stdout(data);
|
||||||
originalListener?.stdout?.(data);
|
} else {
|
||||||
|
// if no stdout listener was originally defined then match behaviour of exec.exec
|
||||||
|
process.stdout.write(data);
|
||||||
|
}
|
||||||
|
|
||||||
},
|
},
|
||||||
stderr: (data: Buffer) => {
|
stderr: (data: Buffer) => {
|
||||||
stderr += data.toString();
|
stderr += data.toString();
|
||||||
process.stderr.write(data);
|
if (originalListener?.stderr !== undefined) {
|
||||||
originalListener?.stderr?.(data);
|
originalListener.stderr(data);
|
||||||
|
} else {
|
||||||
|
// if no stderr listener was originally defined then match behaviour of exec.exec
|
||||||
|
process.stderr.write(data);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue