Class RuntimeHostRunRuntime

packages/cli/src/runtime-host-run-command.ts:221–503

}

class RuntimeHostRunRuntime implements MakaRunRuntime {
  readonly #connection: RuntimeHostConnection;
  readonly #driver: RuntimeHostMakaSessionDriver;
  readonly #observer: ((outcome: MakaRunOutcome) => void | Promise<void>) | undefined;
  readonly #graphEnabled: boolean;
  readonly #sessionCwdOverride: MakaRunContextInput['sessionCwdOverride'];
  readonly #maxSteps: number | undefined;
  readonly #unsubscribeTranscriptReplacements: () => void;
  #sessionId: string | undefined;
  #activeTurn: { sessionId: string; turnId: string; runId: string } | undefined;
  #stopRequested = false;
  #closed = false;
  readonly #interactions: NonInteractiveInteractionController;
  #graphAdmissionTurnIds = new Set<string>();
  #latestTranscriptReplacement: StoredMessage[] | undefined;
  readonly #graphTerminalWaiters = new Map<
    string,
    Set<{
      resolve(messages: StoredMessage[]): void;
      reject(error: Error): void;
      timer: ReturnType<typeof setTimeout>;
    }>
  >();

  constructor(
    connection: RuntimeHostConnection,
    driver: RuntimeHostMakaSessionDriver,
    observer: ((outcome: MakaRunOutcome) => void | Promise<void>) | undefined,
    graphEnabled: boolean,
    sessionCwdOverride: MakaRunContextInput['sessionCwdOverride'],
    maxSteps: number | undefined,
  ) {
    this.#connection = connection;
    this.#driver = driver;
    this.#observer = observer;
    this.#graphEnabled = graphEnabled;
    this.#sessionCwdOverride = sessionCwdOverride;
    this.#maxSteps = maxSteps;
    this.#interactions = new NonInteractiveInteractionController(driver, (pending) =>
      this.#stopForInteraction(pending),
    );
    this.#unsubscribeTranscriptReplacements = driver.subscribeTranscriptReplacements(
      (_sessionId, _turnId, messages) => this.#acceptGraphTranscript(messages),
    );
  }

  async createSession(input: CreateSessionInput): Promise<SessionSummary> {
    const created = await this.#driver.createSession(input);
    this.#sessionId = created.id;
    return created;
  }

  async readExecutionBoundary(sessionId: string): Promise<ExecutionBoundaryReadModel> {
    await this.#attach(sessionId);
    return this.#connection.request('session.execution_boundary.query', { sessionId });
  }

  async *sendMessage(sessionId: string, input: UserMessageInput): AsyncIterable<SessionEvent> {