feat: 新增 Discord 渠道接入

backend/app/api/chat.py

@@ -19,7 +19,7 @@
 from starlette.background import BackgroundTask
 
 from app.agents.branching import model_for_agent, visible_published_skills
-from app.channels.service_outbox import stage_channel_delivery
+from app.channels.service_outbox import stage_channel_delivery, stage_user_message_mirror
 from app.core import AgentLoop
 from app.core.cancellation import cancel_chat_turn
 from app.core.capability_manifest import CapabilityManifestBuilder
@@ -652,6 +652,8 @@ def _maybe_handle_scheduled_task_request(
         created_at=now,
     )
     db.add(user_message)
+    if request.channel == "web":
+        stage_user_message_mirror(db, chat_session, user_message, web_origin=True)
     draft_payload = draft.model_dump(mode="json")
     db.add(
         AgentEvent(

backend/app/channels/__init__.py

@@ -17,6 +17,7 @@
 _wecom_stream_manager = None
 _feishu_process_manager = None
 _dingtalk_stream_manager = None
+_discord_stream_manager = None
 _binding_lifecycle_locks: dict[str, threading.RLock] = {}
 _binding_lifecycle_locks_guard = threading.Lock()
 _connector_lock_file: IO[bytes] | None = None
@@ -126,6 +127,15 @@ def get_dingtalk_stream_manager():
     return _dingtalk_stream_manager
 
 
+def get_discord_stream_manager():
+    global _discord_stream_manager
+    if _discord_stream_manager is None:
+        from app.channels.adapters.discord import DiscordStreamManager
+
+        _discord_stream_manager = DiscordStreamManager()
+    return _discord_stream_manager
+
+
 def channel_services_enabled() -> bool:
     # staffdeck_role 预留角色拆分：all=单体全量，connector=仅渠道连接器
     return get_settings().staffdeck_role in {"all", "connector"}
@@ -135,6 +145,7 @@ def _ensure_adapters_registered() -> None:
     # 各适配器模块导入即自注册(模块级 register_channel_adapter)
     import app.channels.adapters.feishu  # noqa: F401
     import app.channels.adapters.dingtalk  # noqa: F401
+    import app.channels.adapters.discord  # noqa: F401
     import app.channels.adapters.wechat  # noqa: F401
     import app.channels.adapters.wecom  # noqa: F401
 
@@ -167,6 +178,8 @@ def _ingress_manager(channel: str):
         return get_feishu_process_manager()
     if channel == "dingtalk":
         return get_dingtalk_stream_manager()
+    if channel == "discord":
+        return get_discord_stream_manager()
     return None
 
 
@@ -213,6 +226,8 @@ def wait_binding_ingress_stopped(channel: str, binding_id: str, timeout_seconds:
         return get_feishu_process_manager().wait_binding_stopped(binding_id, timeout_seconds)
     if channel == "dingtalk":
         return get_dingtalk_stream_manager().wait_binding_stopped(binding_id, timeout_seconds)
+    if channel == "discord":
+        return get_discord_stream_manager().wait_binding_stopped(binding_id, timeout_seconds)
     return True
 
 
@@ -243,6 +258,7 @@ def start_channel_services() -> None:
         get_wecom_stream_manager().start()
         get_feishu_process_manager().start()
         get_dingtalk_stream_manager().start()
+        get_discord_stream_manager().start()
         start_delivery_daemon()
         start_staged_inbound_daemon()
         # 启动恢复:一次性清扫崩溃残留的 processing 入站事件(独立线程,不阻塞启动)
@@ -285,6 +301,10 @@ def stop_channel_services(timeout_seconds: float = 5.0) -> bool:
     dingtalk_stopped = dingtalk_manager is None or dingtalk_manager.stop(
         timeout_seconds=max(0.0, deadline - time.monotonic())
     )
+    discord_manager = _discord_stream_manager
+    discord_stopped = discord_manager is None or discord_manager.stop(
+        timeout_seconds=max(0.0, deadline - time.monotonic())
+    )
     sweep_thread = _intake_sweep_thread
     if sweep_thread and sweep_thread.is_alive():
         sweep_thread.join(timeout=max(0.0, deadline - time.monotonic()))
@@ -296,6 +316,7 @@ def stop_channel_services(timeout_seconds: float = 5.0) -> bool:
         and wecom_stopped
         and feishu_stopped
         and dingtalk_stopped
+        and discord_stopped
         and sweep_stopped
     )
     if stopped:

backend/app/channels/adapters/base.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
 from dataclasses import dataclass, field
+from enum import StrEnum
 from typing import Any, Protocol
 
 import httpx
@@ -154,6 +155,28 @@ def remove_reaction(
     ) -> None: ...
 
 
+class ChannelCapability(StrEnum):
+    """渠道能力枚举:8 项 Discord 功能扩展的运行时能力声明。"""
+
+    SLASH_COMMANDS = "slash_commands"  # 原生斜杠命令
+    THREADS = "threads"  # 线程
+    BATCH_SEND = "batch_send"  # 批量投递
+    BACKFILL = "backfill"  # 历史回填
+    TYPING = "typing"  # typing indicator
+    VOICE = "voice"  # 语音
+    RICH_MEDIA = "rich_media"  # embeds/附件
+
+
+class ChannelCapabilityAdapter(Protocol):
+    """可选混入:声明该渠道支持的能力集合。
+
+    与 ChannelReactionAdapter 一样是可选协议;未实现此协议的渠道
+    自动视为无任何扩展能力,所有门禁降级跳过。
+    """
+
+    def channel_capabilities(self) -> set[ChannelCapability]: ...
+
+
 _adapters: dict[str, ChannelAdapter] = {}
 
 
@@ -184,6 +207,72 @@ def channel_reaction_token(channel: str) -> str | None:
     return token or None
 
 
+def channel_capabilities_of(adapter: object) -> set[ChannelCapability]:
+    """安全获取适配器的能力声明集合。
+
+    实现了 ChannelCapabilityAdapter 协议(有可调用的 channel_capabilities
+    方法)时返回其声明集合,否则返回空集。存量渠道(微信/企微/飞书/钉钉)
+    未实现该协议,自动降级为无能力,保证向后兼容。
+    """
+    capabilities = getattr(adapter, "channel_capabilities", None)
+    if not callable(capabilities):
+        return set()
+    declared = capabilities()
+    if not isinstance(declared, set):
+        return set()
+    return set(declared)
+
+
+def evaluate_allowlist(message_ctx: dict[str, Any], allowlist: dict[str, Any] | None) -> bool:
+    """入站白名单判定:True 放行,False 拒绝(功能5)。
+
+    allowlist schema(§3.1/§4.5):
+      {mode: "allow_all"|"deny_all"(缺省 allow_all),
+       guild_ids/channel_ids/role_ids/user_ids: [str],
+       deny: [str]}(条目支持 "dimension:id" 前缀,纯 id 匹配任意维度)
+    判定序:deny 命中→拒绝;deny_all 且 allow 未命中→拒绝;allow_all 且 allow
+    非空未命中→拒绝;其余放行。role_ids 需要 members intent,首版(P2)不参与。
+    """
+    if not isinstance(allowlist, dict) or not allowlist:
+        return True
+    mode = str(allowlist.get("mode") or "").strip() or "allow_all"
+    if mode not in ("allow_all", "deny_all"):
+        mode = "allow_all"
+    guild_id = str(message_ctx.get("guild_id") or "").strip()
+    channel_id = str(message_ctx.get("channel_id") or "").strip()
+    author_id = str(message_ctx.get("author_id") or "").strip()
+    for entry in allowlist.get("deny") or []:
+        token = str(entry).strip()
+        if not token:
+            continue
+        if ":" in token:
+            dimension, _, value = token.partition(":")
+            value = value.strip()
+            if not value or dimension not in {"guild", "channel", "user"}:
+                continue
+            if dimension == "guild" and value == guild_id:
+                return False
+            if dimension == "channel" and value == channel_id:
+                return False
+            if dimension == "user" and value == author_id:
+                return False
+        elif token in (guild_id, channel_id, author_id):
+            return False
+    allow_guilds = _allowlist_ids(allowlist, "guild_ids")
+    allow_channels = _allowlist_ids(allowlist, "channel_ids")
+    allow_users = _allowlist_ids(allowlist, "user_ids")
+    allow_hit = guild_id in allow_guilds or channel_id in allow_channels or author_id in allow_users
+    if mode == "deny_all":
+        return allow_hit
+    if not allow_guilds and not allow_channels and not allow_users:
+        return True
+    return allow_hit
+
+
+def _allowlist_ids(allowlist: dict[str, Any], key: str) -> set[str]:
+    return {str(value).strip() for value in (allowlist.get(key) or []) if str(value).strip()}
+
+
 def split_channel_text(text: str, limit: int = CHANNEL_TEXT_LIMIT) -> list[str]:
     """按渠道 2000 字上限拆分长文本，优先 \n\n / \n / 空格边界，找不到则硬切。"""
     if not text: