Method debugTriggerStreamError

src/node/services/streamManager.ts:4137–4173

* DEBUG ONLY: Trigger an artificial stream error for testing * This method allows integration tests to simulate stream errors without * mocking the AI SDK or network layer. It triggers the same error handling * path as genuine stream errors by aborting the stream and manually triggering

(workspaceId: string, errorMessage: string)

   * causes the for-await loop to break cleanly).
   */
  async debugTriggerStreamError(workspaceId: string, errorMessage: string): Promise<boolean> {
    const typedWorkspaceId = workspaceId as WorkspaceId;
    const streamInfo = this.workspaceStreams.get(typedWorkspaceId);

    // Only trigger error if stream is actively running
    if (
      !streamInfo ||
      (streamInfo.state !== StreamState.STARTING && streamInfo.state !== StreamState.STREAMING)
    ) {
      return false;
    }

    // Abort the stream first (causes for-await loop to break cleanly)
    streamInfo.abortController.abort(new Error(errorMessage));

    // Mark as error state (same as catch block does)
    streamInfo.state = StreamState.ERROR;

    // Update streamInfo metadata with error (so subsequent flushes preserve it)
    streamInfo.initialMetadata = {
      ...streamInfo.initialMetadata,
      error: errorMessage,
      errorType: "network",
    };

    // Write error state to partial.json (same as real error handling)
    await this.persistStreamError(typedWorkspaceId, streamInfo, {
      messageId: streamInfo.messageId,
      error: errorMessage,
      errorType: "network",
    });

    // Wait for the stream processing to complete (cleanup)
    await streamInfo.processingPromise;

    return true;
  }
}