Class FakeClientChannel

src/node/runtime/transports/SSH2Transport.test.ts:7–53

import { SSH2Transport } from "./SSH2Transport";

class FakeClientChannel extends EventEmitter {
  readonly stdout = new PassThrough();
  readonly stderr?: PassThrough;
  destroyed = false;
  writableEnded = false;

  constructor(options?: { includeStderr?: boolean }) {
    super();
    if (options?.includeStderr) {
      this.stderr = new PassThrough();
    }
  }

  pipe<T extends NodeJS.WritableStream>(destination: T): T {
    this.stdout.pipe(destination);
    return destination;
  }

  write(_chunk: string | Buffer | Uint8Array): boolean {
    return true;
  }

  end(): void {
    this.writableEnded = true;
  }

  close(): void {
    this.destroyed = true;
    this.writableEnded = true;
    this.stdout.end();
    this.stderr?.end();
  }

  signal(_signal: string): void {
    // No-op for tests.
  }

  emitStderr(text: string): void {
    this.stderr?.write(text);
  }

  finish(exitCode = 0): void {
    this.emit("exit", exitCode, null);
    this.close();
    this.emit("close", exitCode, null);
  }
}

function createFakeClient(channel: FakeClientChannel) {
  return {