/**
 * Messages Request Handler Module
 *
 * 处理/v1/messages请求的专用处理器
 * 按照细菌式编程原则：小巧、模块化、自包含
 */
import { FastifyRequest, FastifyReply } from 'fastify';
import { Provider } from '@/types';
import { UnifiedInputProcessor } from '@/input/unified-processor';
import { RoutingEngine } from '@/routing';
import { AnthropicOutputProcessor } from '@/output/anthropic';
import { StreamingHandler } from './streaming-handler';
export interface MessagesHandlerDependencies {
    inputProcessor: UnifiedInputProcessor;
    routingEngine: RoutingEngine;
    outputProcessor: AnthropicOutputProcessor;
    streamingHandler: StreamingHandler;
    providers: Map<string, Provider>;
    logger: any;
    config: any;
}
export declare class MessagesHandler {
    private deps;
    constructor(deps: MessagesHandlerDependencies);
    /**
     * 处理/v1/messages请求的主要入口
     */
    handleMessagesRequest(request: FastifyRequest, reply: FastifyReply): Promise<any>;
    /**
     * 处理输入阶段
     */
    private processInput;
    /**
     * 处理路由阶段
     */
    private processRouting;
    /**
     * 处理流式请求流程
     */
    private handleStreamingFlow;
    /**
     * 处理常规（非流式）请求流程
     */
    private handleRegularFlow;
    /**
     * 发送Provider请求
     */
    private sendProviderRequest;
    /**
     * 处理输出阶段
     */
    private processOutput;
    /**
     * 查找Provider
     */
    private findProvider;
    /**
     * 验证Provider可用性
     */
    private validateProvider;
    /**
     * 处理请求错误
     */
    private handleRequestError;
}
/**
 * 创建Messages Handler实例的工厂函数
 */
export declare function createMessagesHandler(deps: MessagesHandlerDependencies): MessagesHandler;
//# sourceMappingURL=messages-handler.d.ts.map