Class ProcessManager

packages/acp-link/src/manager/manager.ts:11–245

const SHUTDOWN_TIMEOUT_MS = 5000

export class ProcessManager {
  private instances = new Map<string, AcpInstance>()
  // eslint-disable-next-line @typescript-eslint/no-explicit-any
  private processes = new Map<string, any>()

  create(group: string, command: string): AcpInstance {
    const id = crypto.randomUUID()
    const instance: AcpInstance = {
      id,
      group,
      command,
      status: 'running',
      pid: undefined,
      startTime: Date.now(),
      exitCode: null,
      logs: [],
      subscribers: new Set(),
    }

    const args = this.parseCommand(command)
    const fullArgs = ['--group', group, ...args]

    const proc = Bun.spawn(['acp-link', ...fullArgs], {
      stdout: 'pipe',
      stderr: 'pipe',
      env: { ...Bun.env, ACP_CHILD: '1' },
    })

    instance.pid = proc.pid
    this.instances.set(id, instance)
    this.processes.set(id, proc)
    log(
      'manager',
      `created instance ${id.slice(0, 8)} group=${group} pid=${proc.pid} cmd="acp-link ${fullArgs.join(' ')}"`,
    )

    this.pipeStream(proc.stdout, id, 'stdout')
    this.pipeStream(proc.stderr, id, 'stderr')

    proc.exited.then(code => {
      instance.status = code === 0 ? 'stopped' : 'failed'
      instance.exitCode = code
      instance.pid = undefined
      this.processes.delete(id)
      log(
        'manager',
        `instance ${id.slice(0, 8)} ${instance.status} exit=${code}`,
      )
      this.notifyStatus(instance)
    })

    return instance
  }

  stop(id: string): boolean {
    const proc = this.processes.get(id)
    if (!proc) return false
    const inst = this.instances.get(id)