flowchart TB
    subgraph EzyPlatform
        subgraph SDK["ezyai-sdk"]
            CS["AbstractAIChatService<br/>ChatGpt / Claude / DeepSeek /<br/>Gemini / Grok / Qwen"]
            PS["EzyAIChatProfileService"]
            SS["AISkillService"]
            ST["EzyAISettingService"]
            TP["McpAIChatToolProvider"]
            KN["KnowledgeDataSourceManager<br/>DefaultKnowledgeDataSource"]
        end
        ADMIN["ezyai-admin-plugin<br/>Trang quản trị + Admin API"]
        WEB["ezyai-web-plugin<br/>Trang Skill Library + Web API"]
        SOCKET["ezyai-socket-plugin<br/>Đăng ký bot cho ezychat,<br/>gom MCP tool toàn zone"]
        EZYCHAT["ezychat<br/>ChatBotServiceManager"]
        OTHER["Các plugin khác<br/>(*_mcp_tool_event)"]
    end
    AI[("AI providers<br/>OpenAI, Anthropic, ...")]
    DB[("MySQL<br/>chat_profile, settings,<br/>data_meta, post, ...")]

    ADMIN --> SDK
    WEB --> SDK
    SOCKET --> SDK
    SOCKET -- "addChatBotServices" --> EZYCHAT
    TP -. "gọi tool" .-> OTHER
    CS -- "HTTP / SSE" --> AI
    SDK --> DB

classDiagram
    class ChatBotService {
        <<interface ezychat>>
        createInputStream(request)
        createOutputStream(handler)
        getServiceName()
    }
    class AIChatBotService {
        <<interface>>
        getModelNames()
    }
    class AbstractAIChatService
    class ClaudeChatService
    class ChatGptChatService
    ChatBotService <|.. AbstractAIChatService
    AIChatBotService <|.. AbstractAIChatService
    AbstractAIChatService <|-- ClaudeChatService
    AbstractAIChatService <|-- ChatGptChatService
    ChatGptChatService <|-- DeepSeekChatService
    ChatGptChatService <|-- GeminiChatService
    ChatGptChatService <|-- GrokChatService
    ChatGptChatService <|-- QwenChatService

sequenceDiagram
    autonumber
    participant C as Caller<br/>(admin API / ezychat bot)
    participant M as ChatBotServiceManager
    participant S as AbstractAIChatService
    participant DB as Profile / Skill / Setting
    participant T as McpAIChatToolProvider
    participant AI as AI provider

    C->>M: chatStreamAsync(serviceName, request, handler)
    M->>S: createInputStream(request)
    S->>DB: api key, skill ids, skills, allowed tools
    S->>S: applySkills + applyTopicGuard (system message)
    alt Có tool được phép
        loop tối đa max_allowed_tool_interactions vòng
            S->>AI: request (không stream) + tools
            AI-->>S: answer / tool calls
            alt Không có tool call
                S-->>M: answer đã sẵn sàng (không cần stream)
            else Có tool call
                S->>T: callTool(context, toolCall)
                T-->>S: tool result (+ metadata)
                S->>S: thêm assistant message + tool result
            end
        end
    end
    S->>AI: request stream=true (tool_choice = none nếu có tools)
    AI-->>S: SSE events
    M->>S: createOutputStream(handler)
    loop mỗi event
        S-->>C: onDelta(deltaContent)
    end
    S-->>C: onCompleted(answer: nội dung, token, metadata)

erDiagram
    CHAT_PROFILE ||--o| SETTINGS : "api key (PASSWORD)"
    CHAT_PROFILE ||--o{ DATA_META : "metadata, skill_id"
    DATA_META }o--|| POST_AI_SKILL : "skill_id"
    POST_AI_SKILL ||--o{ POST_META : "ai_skill_allowed_tool"

    CHAT_PROFILE {
        long id
        string chatBotServiceName
        string name
        string endpoint
        string model
        string status
    }
    SETTINGS {
        string name "ezyai_[service]_profile_[id]_api_key"
        string value "đã mã hoá"
    }
    DATA_META {
        string dataType "chat_profile"
        long dataId "profile id"
        string metaKey
        string metaValue
    }
    POST_AI_SKILL {
        long id
        string type "AI_SKILL"
        string content "system prompt"
    }
    POST_META {
        long postId
        string metaKey
        string metaValue "tên tool"
    }

flowchart LR
    P["Profile"] -->|skill_id| S1["Skill A<br/>prompt + tools"]
    P -->|skill_id| S2["Skill B<br/>prompt + tools"]
    S1 --> SP["System message"]
    S2 --> SP
    S1 --> AT["Allowed tools"]
    S2 --> AT
    ALL["Mọi MCP tool<br/>trong hệ thống"] --> F{"lọc"}
    AT --> F
    F --> TOOLS["Tool gửi cho AI"]

flowchart TB
    Q["search_knowledge_data_list<br/>(query, limit, dataSource)"] --> MGR["KnowledgeDataSourceManager"]
    MGR -->|theo tên| DS["DefaultKnowledgeDataSource"]
    MGR -.->|nguồn khác| PRV["KnowledgeDataSourceProvider"]
    DS --> STR["KnowledgeSearchStrategy<br/>(sắp theo priority)"]
    STR --> IDX["KnowledgeIndexedDataSearchStrategy<br/>DataIndexService<br/>Reciprocal Rank Fusion"]
    IDX -->|"(dataType, dataId)"| FET["EzyAIKnowledgeDataFetcher"]
    FET --> F1["Post fetcher"]
    FET --> F2["Product fetcher"]
    FET --> F3["Event fetcher<br/>ezyai_knowledge_data_list_fetcher"]
    F1 & F2 & F3 --> CH["KnowledgeContentChunker"]
    CH --> RANK["Ưu tiên chunk chứa từ khoá<br/>cắt theo limit"]
    RANK --> R["Kết quả cho AI<br/>+ metadata knowledgeList"]