Function simulateToolPolicyNoop

src/node/services/streamSimulation.ts:118–193

(
  ctx: SimulationContext,
  effectiveToolPolicy: ToolPolicy | undefined,
  historyService: HistoryService
)

 * Used by the OpenAI SDK `simulateToolPolicyNoop` provider option.
 */
export async function simulateToolPolicyNoop(
  ctx: SimulationContext,
  effectiveToolPolicy: ToolPolicy | undefined,
  historyService: HistoryService
): Promise<void> {
  const noopMessage = createMuxMessage(ctx.assistantMessageId, "assistant", "", {
    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,
    toolPolicy: effectiveToolPolicy,
  });

  const parts: StreamEndEvent["parts"] = [
    {
      type: "text",
      text: "Tool execution skipped because the requested tool is disabled by policy.",
    },
  ];

  ctx.emit("stream-start", createSimulatedStreamStart(ctx));

  const textParts = parts.filter((part): part is MuxTextPart => part.type === "text");
  if (textParts.length === 0) {
    throw new Error("simulateToolPolicyNoop requires at least one text part");
  }

  for (const textPart of textParts) {
    if (textPart.text.length === 0) {
      continue;
    }

    const streamDeltaEvent: StreamDeltaEvent = {
      type: "stream-delta",
      workspaceId: ctx.workspaceId,
      messageId: ctx.assistantMessageId,
      delta: textPart.text,
      tokens: 0, // Mock scenario — actual tokenization happens in streamManager
      timestamp: Date.now(),
    };
    ctx.emit("stream-delta", streamDeltaEvent);
  }

  const streamEndEvent: StreamEndEvent = {
    type: "stream-end",
    workspaceId: ctx.workspaceId,
    messageId: ctx.assistantMessageId,
    metadata: {
      model: ctx.canonicalModelString,
      agentId: ctx.effectiveAgentId,
      ...(ctx.metadataMode != null ? { mode: ctx.metadataMode } : {}),
      thinkingLevel: ctx.effectiveThinkingLevel,
      routedThroughGateway: ctx.routedThroughGateway,
      ...(ctx.routeProvider != null ? { routeProvider: ctx.routeProvider } : {}),