Method streamWithHistory

src/node/services/agentSession.ts:3462–3679

(
    modelString: string,
    options?: SendMessageOptions,
    openaiTruncationModeOverride?: "auto" | "disabled",
    disablePostCompactionAttachments?: boolean,
    agentInitiated?: boolean,
    abortSignal?: AbortSignal,
    goalKind?: GoalSyntheticMessageKind
  )

  }

  private async streamWithHistory(
    modelString: string,
    options?: SendMessageOptions,
    openaiTruncationModeOverride?: "auto" | "disabled",
    disablePostCompactionAttachments?: boolean,
    agentInitiated?: boolean,
    abortSignal?: AbortSignal,
    goalKind?: GoalSyntheticMessageKind
  ): Promise<Result<void, SendMessageError>> {
    const isStartupAbortRequested = (): boolean => abortSignal?.aborted === true;

    if (this.disposed || isStartupAbortRequested()) {
      return Ok(undefined);
    }

    // Reset per-stream flags (used for retries / crash-safe bookkeeping).
    this.compactionMonitor.resetForNewStream();
    this.clearLiveUsageState();
    this.ackPendingPostCompactionStateOnStreamEnd = false;
    this.activeStreamHadAnyDelta = false;
    this.activeStreamErrorEventReceived = false;
    this.activeStreamFailureHandled = false;
    this.activeStreamHadPostCompactionInjection = false;
    const providersConfigForCompaction = this.getProvidersConfigForCompaction();
    this.activeStreamContext = {
      modelString,
      options,
      agentInitiated,
      openaiTruncationModeOverride,
      ...(goalKind != null ? { goalKind } : {}),
      providersConfig: providersConfigForCompaction,
    };
    this.activeStreamUserMessageId = undefined;

    const commitResult = await this.historyService.commitPartial(this.workspaceId);
    if (!commitResult.success) {
      return Err(createUnknownSendMessageError(commitResult.error));
    }

    if (isStartupAbortRequested()) {
      return Ok(undefined);
    }

    let historyResult = await this.historyService.getHistoryFromLatestBoundary(this.workspaceId);
    if (isStartupAbortRequested()) {
      return Ok(undefined);
    }

    if (!historyResult.success) {
      return Err(createUnknownSendMessageError(historyResult.error));
    }

    if (historyResult.data.length === 0) {
      return Err(
        createUnknownSendMessageError(
          "Cannot resume stream: workspace history is empty. Send a new message instead."
        )
      );