Class TerminalProcess

valdi/vscode_debugger/src/targets/node/program.ts:87–169

 * Program created from a subprocess.
 */
export class TerminalProcess implements IProgram {
  /**
   * How often to check and see if the process exited.
   */
  private static readonly terminationPollInterval = 1000;

  /**
   * How often to check and see if the process exited after we send a close signal.
   */
  private static readonly killConfirmInterval = 200;

  private didStop = false;
  private onStopped!: (killed: boolean) => void;
  public readonly stopped = new Promise<IStopMetadata>(
    resolve =>
      (this.onStopped = killed => {
        this.didStop = true;
        resolve({ code: 0, killed });
      }),
  );
  private loop?: { timer: NodeJS.Timer; processId: number };

  constructor(
    private readonly terminalResult: Dap.RunInTerminalResult,
    private readonly logger: ILogger,
  ) {
    if (terminalResult.processId) {
      this.startPollLoop(terminalResult.processId);
    }
  }

  public gotTelemetery({ processId }: IProcessTelemetry) {
    if (this.didStop) {
      killTree(processId, this.logger);
      return; // to avoid any races
    }

    if (!this.loop) {
      this.startPollLoop(processId);
    }
  }

  public stop(): Promise<IStopMetadata> {
    if (this.didStop) {
      return this.stopped;
    }
    this.didStop = true;

    // If we're already polling some process ID, kill it and accelerate polling
    // so we can confirm it's dead quickly.
    if (this.loop) {
      killTree(this.loop.processId, this.logger);
      this.startPollLoop(this.loop.processId, TerminalProcess.killConfirmInterval);
    } else if (this.terminalResult.shellProcessId) {
      // If we had a shell process ID, well, that's good enough.
      killTree(this.terminalResult.shellProcessId, this.logger);
      this.startPollLoop(this.terminalResult.shellProcessId, TerminalProcess.killConfirmInterval);
    } else {