Class Command

lib/command.ts:124–338

type CommandState = 'stopped' | 'started' | 'errored' | 'exited';

export class Command implements CommandInfo {
    private readonly killProcess: KillProcess;
    private readonly spawn: SpawnCommand;
    private readonly spawnOpts: SpawnOptions;
    readonly index: number;

    /** @inheritdoc */
    readonly name: string;

    /** @inheritdoc */
    readonly command: string;

    /** @inheritdoc */
    readonly prefixColor?: string;

    /** @inheritdoc */
    readonly env: Record<string, unknown>;

    /** @inheritdoc */
    readonly cwd?: string;

    /** @inheritdoc */
    readonly ipc?: number;

    readonly close = new Rx.Subject<CloseEvent>();
    readonly error = new Rx.Subject<unknown>();
    readonly stdout = new Rx.Subject<Buffer>();
    readonly stderr = new Rx.Subject<Buffer>();
    readonly timer = new Rx.Subject<TimerEvent>();

    /**
     * A stream of changes to the `#state` property.
     *
     * Note that the command never goes back to the `stopped` state, therefore it's not a value
     * that's emitted by this stream.
     */
    readonly stateChange = new Rx.Subject<Exclude<CommandState, 'stopped'>>();
    readonly messages = {
        incoming: new Rx.Subject<MessageEvent>(),
        outgoing: new Rx.ReplaySubject<OutgoingMessageEvent>(),
    };

    process?: ChildProcess;

    // TODO: Should exit/error/stdio subscriptions be added here?
    private subscriptions: readonly Rx.Subscription[] = [];
    stdin?: Writable;
    pid?: number;
    killed = false;
    exited = false;

    state: CommandState = 'stopped';

    constructor(
        { index, name, command, prefixColor, env, cwd, ipc }: CommandInfo & { index: number },
        spawnOpts: SpawnOptions,
        spawn: SpawnCommand,
        killProcess: KillProcess,