Class Runner

packages/computerd/src/exec/runner.ts:72–486

}

export class Runner {
  private readonly db: Database;
  private readonly opts: {
    cwd: string | undefined;
    env: Record<string, string> | undefined;
    logMaxBytes: number;
    retentionMs: number;
    sweepIntervalMs: number;
    defaultTimeoutMs: number;
    heartbeatIntervalMs: number;
    now: () => number;
  };
  private readonly records = new Map<string, ExecRecord>();
  private sweepTimer: NodeJS.Timeout | undefined;
  private disposed = false;

  constructor(init: RunnerInit) {
    this.db = init.db;
    this.opts = {
      cwd: init.cwd,
      env: init.env,
      logMaxBytes: init.logMaxBytes ?? DEFAULTS.logMaxBytes,
      retentionMs: init.retentionMs ?? DEFAULTS.retentionMs,
      sweepIntervalMs: init.sweepIntervalMs ?? DEFAULTS.sweepIntervalMs,
      defaultTimeoutMs: init.defaultTimeoutMs ?? DEFAULTS.defaultTimeoutMs,
      heartbeatIntervalMs: init.heartbeatIntervalMs ?? 0,
      now: init.now ?? Date.now,
    };
    initializeExecSchema(this.db);
    if (init.resetSchema !== false) clearExecState(this.db);
  }

  exec(command: string, options: ExecOptions = {}): ExecHandle {
    if (this.disposed) throw new Error("runner disposed");
    const id = options.id ?? randomUUID();
    const existing = this.records.get(id);
    if (existing?.live) {
      throw new ExecError("EEXEC_BUSY", `exec id ${id} is already running`);
    }
    if (existing !== undefined) this.disposeRecord(existing);

    const cwd = options.cwd ?? this.opts.cwd;
    const env = { ...process.env, ...this.opts.env, ...options.env };
    // Pre-flight the cwd via dofs's stat which walks vfs_nodes /
    // vfs_dirents in SQLite directly — no node:fs.statSync, no
    // FUSE callback. Preserves the historical ENOENT-cwd error
    // shape callers see when the path doesn't exist, without
    // taking a route that could deadlock against computerd's own FUSE
    // server.
    if (cwd !== undefined) {
      try {
        stat(this.db, cwd);
      } catch (err) {
        return this.spawnFailed(id, err);
      }
    }
    // Don't pass cwd to spawn. libuv's uv_spawn does fork +
    // chdir + execve in the child while the parent blocks on a