Step 19: 核心服务拆分 —— 从单体到微服务¶

// Step 17: 单体设计
class CustomerServiceAgent : public StatefulAgent {
    // 这一个人类负责：
    // - WebSocket 连接管理
    // - 会话状态维护
    // - LLM 调用和回复生成
    // - 知识库检索
    // - 情感/记忆/关系管理
};

// Step 17: 单体 Agent 处理所有逻辑
CustomerServiceAgent agent(tenant);
std::string response = agent.handle_customer_message(user_id, user_name, message);
// 内部：连接管理 + LLM 调用 + 知识检索 + 情感计算

// Step 20: 分层调用

// 1. ChatService 管理连接
std::string conn_id = chat_service->connect_customer(tenant_id, user_id, user_name);

// 2. 处理消息（ChatService 内部委托给 AIService）
std::string response = chat_service->handle_message(conn_id, message);

// 3. AIService 内部调用 KnowledgeService 做 RAG
// 4. 最终生成回复

// include/nuclaw/services/chat_service.hpp
class ChatService {
public:
    // 客户连接（模拟 WebSocket 连接建立）
    std::string connect_customer(const std::string& tenant_id,
                                  const std::string& user_id,
                                  const std::string& user_name);

    // 处理消息（核心：委托给 AIService）
    std::string handle_message(const std::string& connection_id,
                                const std::string& message);

private:
    std::shared_ptr<AIService> ai_service_;  // 依赖注入
    std::map<std::string, std::unique_ptr<WebSocketConnection>> connections_;
};

// include/nuclaw/services/ai_service.hpp
class AIService {
public:
    // 生成智能回复（复用 CustomerServiceAgent）
    std::string generate_response(const std::string& tenant_id,
                                   const std::string& user_id,
                                   const std::string& message,
                                   const std::vector<... >& history);

    // 注册租户 Agent（每个租户一个 CustomerServiceAgent 实例）
    void register_tenant_agent(const TenantContext& tenant);

private:
    // 复用 Step 17：每个租户一个 CustomerServiceAgent
    std::map<std::string, std::unique_ptr<CustomerServiceAgent>> tenant_agents_;
    std::shared_ptr<KnowledgeService> knowledge_service_;
};

// include/nuclaw/services/knowledge_service.hpp
class KnowledgeService {
public:
    // 初始化租户知识库（数据隔离）
    void initialize_tenant_kb(const std::string& tenant_id);

    // 添加文档
    void add_document(const std::string& tenant_id,
                      const std::string& doc_id,
                      const std::string& content);

    // RAG 检索
    std::vector<RetrievalResult> retrieve(const std::string& tenant_id,
                                           const std::string& query,
                                           int top_k = 5);

private:
    // 复用 Step 10：每个租户一个 VectorStore
    std::map<std::string, std::unique_ptr<VectorStore>> tenant_stores_;
};

// main.cpp 核心逻辑

// 1. 初始化 KnowledgeService（最底层，无依赖）
auto knowledge_service = std::make_shared<KnowledgeService>(kb_config);

// 2. 初始化 AIService（依赖 KnowledgeService）
auto ai_service = std::make_shared<AIService>(io, llm_config, knowledge_service);

// 3. 初始化 ChatService（依赖 AIService）
auto chat_service = std::make_shared<ChatService>(io, ai_service);

// 4. 注册租户
tenant_a.agent_persona = {{"name", "小快"}};
knowledge_service->initialize_tenant_kb(tenant_a.tenant_id);
ai_service->register_tenant_agent(tenant_a);

// 5. 添加知识库文档
knowledge_service->add_document(tenant_a.tenant_id, "faq_shipping", "...");

// 6. 处理客户连接
std::string conn_id = chat_service->connect_customer(tenant_id, user_id, user_name);
std::string response = chat_service->handle_message(conn_id, message);