Class InputHandler

lib/flow-control/input-handler.ts:20–95

 * If the input doesn't start with a command identifier, it is then always sent to the default target.
 */
export class InputHandler implements FlowController {
    private readonly logger: Logger;
    private readonly defaultInputTarget: CommandIdentifier;
    private readonly inputStream?: Readable;
    private readonly pauseInputStreamOnFinish: boolean;

    constructor({
        defaultInputTarget,
        inputStream,
        pauseInputStreamOnFinish,
        logger,
    }: {
        inputStream?: Readable;
        logger: Logger;
        defaultInputTarget?: CommandIdentifier;
        pauseInputStreamOnFinish?: boolean;
    }) {
        this.logger = logger;
        this.defaultInputTarget = defaultInputTarget || defaults.defaultInputTarget;
        this.inputStream = inputStream;
        this.pauseInputStreamOnFinish = pauseInputStreamOnFinish !== false;
    }

    handle(commands: Command[]): {
        commands: Command[];
        onFinish?: () => void | undefined;
    } {
        const { inputStream } = this;
        if (!inputStream) {
            return { commands };
        }

        const commandsMap = new Map<string, Command>();
        for (const command of commands) {
            commandsMap.set(command.index.toString(), command);
            commandsMap.set(command.name, command);
        }

        Rx.fromEvent(inputStream, 'data')
            .pipe(map((data) => String(data)))
            .subscribe((data) => {
                const dataParts = data.split(/:(.+)/s);
                let target = dataParts[0];
                let command = commandsMap.get(target);
                let input: string;

                if (dataParts.length > 1 && command) {
                    input = dataParts[1];
                } else {
                    // If `target` does not match a registered command,
                    // fallback to `defaultInputTarget` and forward the whole input data
                    target = this.defaultInputTarget.toString();
                    command = commandsMap.get(target);
                    input = data;
                }

                if (command?.stdin) {
                    command.stdin.write(input);