Method emitHistoricalEvents

src/node/services/agentSession.ts:1854–2210

(
    listener: (event: AgentSessionChatEvent) => void,
    mode?: OnChatMode
  )

  }

  private async emitHistoricalEvents(
    listener: (event: AgentSessionChatEvent) => void,
    mode?: OnChatMode
  ): Promise<void> {
    let replayMode: "full" | "since" | "live" = "full";
    let hasOlderHistory: boolean | undefined;
    let serverCursor: OnChatCursor | undefined;
    let emittedReplayMessages = false;

    const emitReplayMessage = (message: WorkspaceChatMessage): void => {
      emittedReplayMessages = true;
      listener({ workspaceId: this.workspaceId, message });
    };

    let replayedTerminalStreamError = false;
    let replayedStreamLifecycle: StreamLifecycleSnapshot | null = null;
    let replayedRuntimeStatus: RuntimeStatusEvent | null = null;
    const emitReplayStatusMessage = (message: WorkspaceChatMessage): void => {
      listener({ workspaceId: this.workspaceId, message });
    };
    const emitCurrentReplayTerminalState = (): void => {
      if (!replayedTerminalStreamError && this.terminalStreamError) {
        replayedTerminalStreamError = true;
        emitReplayStatusMessage({
          ...this.terminalStreamError,
          replay: true,
        });
      }

      const lifecycle = this.getCurrentStreamLifecycleSnapshot();
      if (!this.hasSameStreamLifecycle(replayedStreamLifecycle, lifecycle)) {
        replayedStreamLifecycle = copyStreamLifecycleSnapshot(lifecycle);
        emitReplayStatusMessage({
          type: "stream-lifecycle",
          workspaceId: this.workspaceId,
          ...lifecycle,
        });
      }

      const runtimeStatus = this.preparingRuntimeStatus;
      if (runtimeStatus && !this.hasSameRuntimeStatus(replayedRuntimeStatus, runtimeStatus)) {
        replayedRuntimeStatus = { ...runtimeStatus };
        emitReplayStatusMessage(runtimeStatus);
      }
    };

    let emittedReplayStreamEvents = false;
    const replayStreamEventTracker = (event: AgentSessionChatEvent) => {
      if (event.workspaceId !== this.workspaceId) {
        return;
      }

      const message = event.message;
      if (typeof message !== "object" || message === null) {
        return;
      }

      if (!("replay" in message) || message.replay !== true) {