Function handleOpenAIResponses

src/openai-handler.ts:1340–1398

(req: Request, res: Response)

 * 而非 data: {"object":"chat.completion.chunk",...} 格式
 */
export async function handleOpenAIResponses(req: Request, res: Response): Promise<void> {
    const body = req.body as Record<string, unknown>;
    const isStream = (body.stream as boolean) ?? true;
    const chatBody = responsesToChatCompletions(body);
    const log = createRequestLogger({
        method: req.method,
        path: req.path,
        model: chatBody.model,
        stream: isStream,
        hasTools: (chatBody.tools?.length ?? 0) > 0,
        toolCount: chatBody.tools?.length ?? 0,
        messageCount: chatBody.messages?.length ?? 0,
        apiFormat: 'responses',
    });
    log.startPhase('receive', '接收请求');
    log.recordOriginalRequest(body);
    log.info('OpenAI', 'receive', '收到 OpenAI Responses 请求', {
        model: chatBody.model,
        stream: isStream,
        toolCount: chatBody.tools?.length ?? 0,
        messageCount: chatBody.messages?.length ?? 0,
    });

    try {
        // Step 1: 转换请求格式 Responses → Chat Completions → Anthropic → Cursor
        log.startPhase('convert', '格式转换 (Responses→Chat→Anthropic)');
        const anthropicReq = convertToAnthropicRequest(chatBody);
        const cursorReq = await convertToCursorRequest(anthropicReq);
        log.endPhase();
        log.recordCursorRequest(cursorReq);

        // 身份探针拦截
        if (isIdentityProbe(anthropicReq)) {
            log.intercepted('身份探针拦截 (Responses)');
            const mockText = "I am Claude, an advanced AI programming assistant created by Anthropic. I am ready to help you write code, debug, and answer your technical questions.";
            if (isStream) {
                return handleResponsesStreamMock(res, body, mockText);
            } else {
                return handleResponsesNonStreamMock(res, body, mockText);
            }
        }

        if (isStream) {
            await handleResponsesStream(res, cursorReq, body, anthropicReq, log);
        } else {
            await handleResponsesNonStream(res, cursorReq, body, anthropicReq, log);
        }
    } catch (err: unknown) {
        const message = err instanceof Error ? err.message : String(err);
        log.fail(message);
        console.error(`[OpenAI] /v1/responses 处理失败:`, message);
        const status = err instanceof OpenAIRequestError ? err.status : 500;
        const type = err instanceof OpenAIRequestError ? err.type : 'server_error';
        const code = err instanceof OpenAIRequestError ? err.code : 'internal_error';
        res.status(status).json({
            error: { message, type, code },
        });
    }