Function handleMessages

src/handler.ts:344–419

(req: Request, res: Response)

// ==================== Messages API ====================

export async function handleMessages(req: Request, res: Response): Promise<void> {
    const body = req.body as AnthropicRequest;

    const systemStr = typeof body.system === 'string' ? body.system : Array.isArray(body.system) ? body.system.map((b: any) => b.text || '').join('') : '';
    const log = createRequestLogger({
        method: req.method,
        path: req.path,
        model: body.model,
        stream: !!body.stream,
        hasTools: (body.tools?.length ?? 0) > 0,
        toolCount: body.tools?.length ?? 0,
        messageCount: body.messages?.length ?? 0,
        apiFormat: 'anthropic',
        systemPromptLength: systemStr.length,
    });

    log.startPhase('receive', '接收请求');
    log.recordOriginalRequest(body);
    log.info('Handler', 'receive', `收到 Anthropic Messages 请求`, {
        model: body.model,
        messageCount: body.messages?.length,
        stream: body.stream,
        toolCount: body.tools?.length ?? 0,
        maxTokens: body.max_tokens,
        hasSystem: !!body.system,
        thinking: body.thinking?.type,
    });

    try {
        if (isIdentityProbe(body)) {
            log.intercepted('身份探针拦截 → 返回模拟响应');
            if (body.stream) {
                return await handleMockIdentityStream(res, body);
            } else {
                return await handleMockIdentityNonStream(res, body);
            }
        }

        // 转换为 Cursor 请求
        log.startPhase('convert', '格式转换');
        log.info('Handler', 'convert', '开始转换为 Cursor 请求格式');
        // ★ 区分客户端 thinking 模式：
        // - enabled: GUI 插件，支持渲染 thinking content block
        // - adaptive: Claude Code，需要密码学 signature 验证，无法伪造 → 保留标签在正文中
        const thinkingConfig = getConfig().thinking;
        // ★ config.yaml thinking 开关优先级最高
        // enabled=true: 强制注入 thinking（即使客户端没请求）
        // enabled=false: 强制关闭 thinking
        // 未配置: 跟随客户端请求（不自动补上）
        if (thinkingConfig) {
            if (!thinkingConfig.enabled) {
                delete body.thinking;
            } else if (!body.thinking) {
                body.thinking = { type: 'enabled' };
            }
        }
        const clientRequestedThinking = body.thinking?.type === 'enabled';
        const cursorReq = await convertToCursorRequest(body);