Function simulateContextLimitError

src/node/services/streamSimulation.ts:68–106

(
  ctx: SimulationContext,
  historyService: HistoryService
)

 * Used by the OpenAI SDK `forceContextLimitError` provider option.
 */
export async function simulateContextLimitError(
  ctx: SimulationContext,
  historyService: HistoryService
): Promise<void> {
  const errorMessage =
    "Context length exceeded: the conversation is too long to send to this OpenAI model. Please shorten the history and try again.";

  const errorPartialMessage: MuxMessage = {
    id: ctx.assistantMessageId,
    role: "assistant",
    metadata: {
      historySequence: ctx.historySequence,
      timestamp: Date.now(),
      model: ctx.canonicalModelString,
      routedThroughGateway: ctx.routedThroughGateway,
      ...(ctx.routeProvider != null ? { routeProvider: ctx.routeProvider } : {}),
      systemMessageTokens: ctx.systemMessageTokens,
      agentId: ctx.effectiveAgentId,
      ...(ctx.metadataMode != null ? { mode: ctx.metadataMode } : {}),
      thinkingLevel: ctx.effectiveThinkingLevel,
      partial: true,
      error: errorMessage,
      errorType: "context_exceeded",
    },
    parts: [],
  };

  await historyService.writePartial(ctx.workspaceId, errorPartialMessage);

  ctx.emit("stream-start", createSimulatedStreamStart(ctx));
  ctx.emit(
    "error",
    createErrorEvent(ctx.workspaceId, {
      messageId: ctx.assistantMessageId,
      error: errorMessage,
      errorType: "context_exceeded",
    })
  );
}

// ---------------------------------------------------------------------------
// simulateToolPolicyNoop simulation