Function handleResponsesStream

src/openai-handler.ts:1530–1770

* Responses API 流式处理 * * ★ 与 Chat Completions 流式的核心区别： * 1. 使用 event: 前缀的 SSE 事件（不是 data-only） * 2. 必须发送 response.completed 事件，否则 Codex 报 "stream closed before response.completed" * 3. 工具调用用 function_call 类型的 output item 表示

(
    res: Response,
    cursorReq: CursorChatRequest,
    body: Record<string, unknown>,
    anthropicReq: AnthropicRequest,
    log: RequestLogger,
)

 * 3. 工具调用用 function_call 类型的 output item 表示
 */
async function handleResponsesStream(
    res: Response,
    cursorReq: CursorChatRequest,
    body: Record<string, unknown>,
    anthropicReq: AnthropicRequest,
    log: RequestLogger,
): Promise<void> {
    res.writeHead(200, {
        'Content-Type': 'text/event-stream',
        'Cache-Control': 'no-cache',
        'Connection': 'keep-alive',
        'X-Accel-Buffering': 'no',
    });

    const respId = responsesId();
    const model = (body.model as string) || 'gpt-4';
    const hasTools = (anthropicReq.tools?.length ?? 0) > 0;
    let toolCallsDetected = 0;

    // 缓冲完整响应再处理（复用 Chat Completions 的逻辑）
    let fullResponse = '';
    let activeCursorReq = cursorReq;
    let retryCount = 0;

    // ★ 流式保活：防止网关 504
    const keepaliveInterval = setInterval(() => {
        try {
            res.write(': keepalive\n\n');
            if (typeof (res as unknown as { flush: () => void }).flush === 'function') {
                (res as unknown as { flush: () => void }).flush();
            }
        } catch { /* connection already closed */ }
    }, 15000);

    try {
        const executeStream = async () => {
            fullResponse = '';
            await sendCursorRequest(activeCursorReq, (event: CursorSSEEvent) => {
                if (event.type !== 'text-delta' || !event.delta) return;
                fullResponse += event.delta;
            });
        };

        await executeStream();

        // Thinking 提取
        if (hasLeadingThinking(fullResponse)) {
            const { strippedText } = extractThinking(fullResponse);
            fullResponse = strippedText;
        }

        // 拒绝检测 + 自动重试
        const shouldRetryRefusal = () => {
            if (!isRefusal(fullResponse)) return false;
            if (hasTools && hasToolCalls(fullResponse)) return false;
            return true;
        };