Function writeAIRouterStreamError

src/server/model/aiRouter.ts:1334–1359

(
  res: Response,
  protocol: AIRouterProtocol,
  message: string,
  type: string
)

}

function writeAIRouterStreamError(
  res: Response,
  protocol: AIRouterProtocol,
  message: string,
  type: string
) {
  if (protocol === AI_ROUTER_PROTOCOLS.ANTHROPIC_MESSAGES) {
    writeAIGatewayAnthropicStreamError(res, new Error(message));
    return;
  }

  if (res.writableEnded || res.destroyed) {
    return;
  }

  res.write(
    `data: ${JSON.stringify({
      error: {
        message,
        type,
      },
    })}\n\n`
  );
  res.write('data: [DONE]\n\n');
  res.end();
}

async function createAIRouterRuntimeFailureLog(args: {
  workspaceId: string;