Method persistStreamError

src/node/services/streamManager.ts:3199–3241

* Write error metadata to partial.json and emit the corresponding error event.

(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    payload: StreamErrorPayload & { errorType: StreamErrorType }
  )

   * Write error metadata to partial.json and emit the corresponding error event.
   */
  private async persistStreamError(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    payload: StreamErrorPayload & { errorType: StreamErrorType }
  ): Promise<void> {
    const refusalFinishReason =
      payload.errorType === "model_refusal"
        ? ([streamInfo.terminalFinishReason, streamInfo.terminalRawFinishReason].find(
            isRefusalFinishReason
          ) ?? streamInfo.terminalFinishReason)
        : undefined;
    const terminalRefusalUsage = streamInfo.terminalRefusalUsage;
    const terminalRefusalProviderMetadata = streamInfo.terminalRefusalProviderMetadata;

    const errorPartialMessage = this.buildPartialAssistantMessage(streamInfo, {
      metadata: {
        error: payload.error,
        errorType: payload.errorType,
        ...(refusalFinishReason !== undefined ? { finishReason: refusalFinishReason } : {}),
        ...(terminalRefusalUsage !== undefined ? { usage: terminalRefusalUsage } : {}),
        ...(terminalRefusalProviderMetadata !== undefined
          ? { providerMetadata: terminalRefusalProviderMetadata }
          : {}),
        // Keep tool-side / refused-fallback usage rows durable on the error
        // partial: a fallback chain that ends in a terminal refusal must not
        // drop the refused attempts' tokens from persisted metadata.
        ...(streamInfo.toolModelUsages.length > 0
          ? { toolModelUsages: streamInfo.toolModelUsages.map(clonePersistedToolModelUsage) }
          : {}),
      },
    });

    // Wait for any in-flight partial write to complete before writing error state.
    // This prevents race conditions where the error write and a throttled flush
    // write at the same time, causing inconsistent partial.json state.
    await this.awaitPendingPartialWrite(streamInfo);

    // Write error state to disk - await to ensure consistent state before any resume.
    await this.historyService.writePartial(workspaceId as string, errorPartialMessage);

    // Emit error event.
    this.emit("error", createErrorEvent(workspaceId as string, payload));
  }

  private getOpenAIPreviousResponseId(
    providerOptions?: Record<string, unknown>