57 lines
1.5 KiB
TypeScript
57 lines
1.5 KiB
TypeScript
import { expect } from 'chai';
|
|
|
|
import { ChildProcessError } from '../../src';
|
|
import { ChildStreams, waitForChild } from '../../src/Child';
|
|
import { mustExist, Optional } from '../../src/Maybe';
|
|
import { describeLeaks, itLeaks } from '../helpers/async';
|
|
|
|
type Closer = (status: number) => Promise<void>;
|
|
|
|
function createChild(): ChildStreams & { closer: Optional<Closer> } {
|
|
return {
|
|
closer /* Optional<Closer> */ : undefined,
|
|
on(event: string, fn: Closer) {
|
|
if (event === 'close') {
|
|
this.closer = fn;
|
|
}
|
|
},
|
|
stderr: {
|
|
on() {
|
|
/* noop */
|
|
},
|
|
},
|
|
stdout: {
|
|
on() {
|
|
/* noop */
|
|
},
|
|
},
|
|
/* eslint-disable @typescript-eslint/no-explicit-any */
|
|
} as any;
|
|
}
|
|
|
|
describeLeaks('child process utils', async () => {
|
|
describeLeaks('wait for child helper', async () => {
|
|
itLeaks('should read stdout data', async () => {
|
|
const child = createChild();
|
|
|
|
const resultPromise = waitForChild(child);
|
|
await mustExist(child.closer)(0);
|
|
|
|
const result = await resultPromise;
|
|
expect(result.status).to.equal(0);
|
|
});
|
|
|
|
itLeaks('should read stderr data');
|
|
itLeaks('should resolve on success status');
|
|
|
|
itLeaks('should reject on failure status', async () => {
|
|
const child = createChild();
|
|
|
|
const resultPromise = waitForChild(child);
|
|
await mustExist(child.closer)(1);
|
|
|
|
return expect(resultPromise).to.eventually.be.rejectedWith(ChildProcessError);
|
|
});
|
|
});
|
|
});
|