Class ShellProcess

packages/nodebox/src/modules/shell.ts:35–152

}

export class ShellProcess {
  public id?: string;
  public state: 'running' | 'idle';

  public stdout: Emitter<{
    data: [string];
  }>;
  public stderr: Emitter<{
    data: [string];
  }>;
  public stdin: {
    write: (data: string | Uint8Array) => Promise<void>;
  };

  constructor(private readonly channel: MessageSender) {
    this.state = 'running';
    this.stdout = new Emitter();
    this.stderr = new Emitter();
    this.stdin = {
      write: (data: string | Uint8Array): Promise<void> => {
        if (!this.id) {
          throw new Error('Failed to write to stdin, no process is currently running');
        }

        return this.channel.send('shell/stdin', { data: data, workerId: this.id });
      },
    };

    this.forwardStdEvents();
  }

  private forwardStdEvents(): void {
    this.channel.on('worker/tty', (message) => {
      const { data } = message;

      if (data.workerId !== this.id) {
        return;
      }

      switch (data.payload.type) {
        case 'out': {
          this.stdout.emit('data', data.payload.data);
          break;
        }

        case 'err': {
          this.stderr.emit('data', data.payload.data);
          break;
        }
      }
    });
  }

  /**
   * Evaluates a given module in the File
   */
  public async runCommand(command: string, args: Array<string>, options: ShellCommandOptions = {}): Promise<ShellInfo> {
    invariant(!this.id, 'Failed to run "runCommand" on a ShellProcess: there is already a process running.');