feat(channels): 新增 Discord 渠道接入 - #82
Open
aurevian-biz wants to merge 31 commits into
Open
aurevian-biz wants to merge 31 commits into
aurevian-biz wants to merge 31 commits into
Conversation
Collaborator
|
@aurevian-biz |
Author
|
我没有主观故意性，应该是提交时没修改git的帐号，周四我会修改后再次提交。 |
Collaborator
|
好的，十分感谢 |
aurevian-biz
force-pushed
the
feat/discord-channel
branch
from
August 14, 2026 08:28
a8e8ab7 to
20e5adc
Compare
Author
|
已经将作者和提交者修改完成。 |
- SUPPORTED_CHANNELS/CHANNEL_META 增加 discord 条目 - channels/__init__.py 注册 DiscordStreamManager 单例与启停 - service_identity 增加 discord 标签与账号稳定键 - service_intake 将 discord 纳入 durable 渠道与 replay 解码
aurevian-biz
force-pushed
the
feat/discord-channel
branch
from
August 14, 2026 09:28
20e5adc to
5872d99
Compare
为 Discord 渠道 8 项功能扩展奠定共享地基: - ChannelCapability 枚举 + ChannelCapabilityAdapter 可选协议, 存量渠道自动降级为空能力集 - ChannelDelivery 新增 payload_json/thread_id/batch_id/delivery_kind 字段 - ChannelInboundEvent 新增 thread_id/mention_user_ids/command 字段(信封 v2) - SQLite 就地迁移 _migrate_channel_envelope_v2_schema, 幂等补列 - channel_capabilities_of 双防御(callable+isinstance) 保证向后兼容 本地验证: pytest 9 个新测试通过, ruff 通过
按 design-discord-channel-features.md 实现全部功能:
- 原生斜杠命令: commands.Bot+CommandTree 注册 5 命令, 回调走 durable inbox 管道复用幂等/重试
- 线程: 入站识别 is_thread/thread_id, 出站 target.thread_id 优先, 白名单按父频道
- 批处理: TokenBucket 限流(容量5/每5s补1) + BatchJob 状态机 + 幂等键 batch:{job}:{index}
- 回填: fetch_history REST 分页 + status=backfilled 不触发 agent + message_id 幂等 + web 合并可见
- 权限白名单: config_json.allowlist 六重 fence 校验, 拒绝落库 rejected 可审计
- typing: send_typing(每8s) + TypingManager 三进门禁(hasattr+能力声明+features 开关)
- 语音: VOICE 默认关闭, ffmpeg 缺失自动不声明, outbox delivery_kind==voice 分派
- 富媒体: embeds(≤10裁剪)+files(≤8MiB multipart)+payload_json 全链路传递+入站附件提取
另修复真实链路缺陷: ChannelInbound dataclass 无 .get() 致回填必崩,
新增 _backfill_message_dict 归一化; features.slash_commands/typing 开关接线。
本地验证: pytest 相关集合 1511 passed(5 预存/flaky 与本次无关), ruff 通过
- DiscordFeatureConfig: 8 功能开关(features) + 白名单编辑器(mode/ID 列表) + 回填触发按钮 + 批量发送面板(轮询进度) - ChannelMessageAttachments: 会话消息附件卡片渲染(image/pdf/文件名) - ChannelsPage 挂载功能配置 section 与附件渲染分支 - types: ChannelAllowlistConfig/ChannelFeatureFlags 等 6 个新类型, config_json 收紧为 ChannelBindingConfigJson - i18n: 补充 33 条 Discord 功能区词条 本地验证: build 通过, vitest 26 files/97 tests 通过
agent 运行生成的 harness 工作区文件此前只在 web 端展示(harness_artifacts 元数据),渠道投递所需的 channel_payload.files 载荷无生产写入方,导致 Discord 渠道永远只收到纯文本回复。 在 stage_channel_delivery 中对 discord 渠道补齐桥接:读取工作区文件字节 (base64),受 8MiB 单文件上限约束,读取失败静默降级;仅 discord 渠道生效, 微信/飞书/钉钉/企微路径零影响;显式 channel_payload 优先于桥接。 新增 test_channel_harness_payload.py 覆盖构造/超限跳过/非 discord 不桥接/ 文件缺失降级/显式载荷优先。
此前 Web 端提问从不外投，仅 assistant 回复经 outbox 回投 Discord， 方向不对称。新增 stage_user_message_mirror 登记 kind=user_mirror 投递，接入 harness_v2_engine.run 与定时任务草稿路径；仅 web 来源 且会话完整锚定渠道时触发，幂等按 message.id 去重，失败静默不 影响 Web 主流程，渠道来源不镜像以防回声。
…/discord-channel
- 显式 channel_payload 附件幂等镜像进 harness_artifacts（operation=channel_delivery）， 桥接路径产物天然已登记不重复，消除渠道与 artifact 账目脱节 - 新增 list_published_deliverables internal 能力，按 tenant+session 聚合并 跨 task frame 检索历史已发布交付物（created_at 倒序，limit 截断）
数字员工此前只能通过 list_published_deliverables 发现历史已发布 交付物的元数据，但因 task frame 工作区隔离，无法读取旧任务产物的 真实内容，只能重复创建文档。新增 internal 能力 read_published_deliverable： 按 path 跨所有 task frame 匹配（可选 task_frame_id 消歧），经 harness_task_workspace_path + open_harness_artifact 读回真实文件内容， base64 返回，超 max_bytes 截断并标记 truncated。 与 fix(channels): 渠道投递附件补登记搭配，补齐"发现→读取→复用"闭环。
- 解决 10 个文件的合并冲突，保留 discord 渠道功能并合并主线改动 - 修复合并回归：service_outbox voice 投递 elif 链断裂导致误触发 text send - 修复 update_channel_binding_agents features 块缺失 db.commit() - 保留 backfill 可视化、auto-thread、reaction 等 discord 分支逻辑 - 引入 main 的 default_handoff 人工处理、harness 改进、Feishu trace 等
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
数字员工现在可以接入 Discord 作为第 5 个消息渠道，能力与既有渠道同级且更完整：原生斜杠命令、线程（含自动建线程）、批量发送与限流、历史回填、权限白名单、连接/typing 指示、语音投递、富媒体（embeds/附件）发送。此前仅支持微信、企业微信、飞书、钉钉——本 PR 让 Discord 从「不支持」变为一等渠道，且完全复用既有渠道无关内核（入站 staging、出站 outbox、身份服务、凭证生命周期、能力声明），未做内核结构性改动。
顺带补齐一条通用能力：渠道投递的附件会登记为「已发布交付物」，并新增
read_published_deliverableharness 能力，使历史产物可被后续会话检索复用。能力矩阵
/employee/switch/current/help/bind按 guild 同步；回调序列化为文本指令走 durable inbox，幂等/重试/审计自动复用batch:{job}:{index}幂等键status=backfilled落库不触发 agent，web 会话页合并展示mode/guild/channel/user_ids + deny，deny 优先；越权入站落库 rejected 可审计关键设计决策
ChannelCapabilityStrEnum + 可选协议混入parse_command单一事实来源payload_json全链路传递，显式优先、harness 产物兜底read_published_deliverable读回验证
npm run build（tsc + vite）与i18n:check均通过connected=True，Discord 消息 → AgentLoop 回复delivered（群聊 + DM 双场景）；harness 产物实际投递为 Discord 附件风险与说明
content为空（UI 已提示）