xiner/Edu - Edu - Xiner

xiner/Edu

Fork 0

Commit Graph

Author	SHA1	Message	Date
SpecialX	765f7da4c0	feat(msg): v2 ARB-013 topic 命名统一 + 考试事件消费 ARB-013 P0 修复：PRODUCER_TOPIC_MAP 从 edu.notification.* 改为 edu.notify.notification.* kafka.consumer 新增 3 考试实时事件消费（exam.extended/force_submitted/question_reordered）嵌套 payload 解包支持 + topic-map 扩展新增 6 测试数据文件（docker-notify + 5 kafka 事件 json） 101 单元测试通过 + Docker 真实环境验证	2026-07-14 23:00:33 +08:00
SpecialX	7474a92e3b	feat(p5): messaging, push gateway and AI assistant services P5 阶段交付物： - services/msg: 消息通知服务（NestJS） - notifications: 发送通知 + ES 全文检索 + search - config/elasticsearch.ts: ES Client 单例 - package.json: 补充 @opentelemetry/sdk-node + exporter-trace-otlp-http - services/push-gateway: WebSocket 推送网关（Go Gin） - internal/hub/hub.go: WebSocket 连接池管理（Register/Unregister/SendToUser） - internal/ws/handler.go: JWT 鉴权 + WebSocket 升级 + 内部推送 API - services/ai: AI 辅助服务（Python FastAPI） - /chat + /chat/stream（SSE 流式） - /generate/question + /optimize/expression - config.py: OpenAI 兼容 API 配置 - packages/shared-proto/proto/msg.proto: NotificationService 契约（send/search） - packages/shared-proto/proto/ai.proto: AiService 契约（含 stream 方法）	2026-07-08 01:39:02 +08:00

Author

SHA1

Message

Date

SpecialX

765f7da4c0

feat(msg): v2 ARB-013 topic 命名统一 + 考试事件消费

ARB-013 P0 修复：PRODUCER_TOPIC_MAP 从 edu.notification.* 改为 edu.notify.notification.*

kafka.consumer 新增 3 考试实时事件消费（exam.extended/force_submitted/question_reordered）

嵌套 payload 解包支持 + topic-map 扩展

新增 6 测试数据文件（docker-notify + 5 kafka 事件 json）

101 单元测试通过 + Docker 真实环境验证

2026-07-14 23:00:33 +08:00

SpecialX

7474a92e3b

feat(p5): messaging, push gateway and AI assistant services

P5 阶段交付物：
- services/msg: 消息通知服务（NestJS）
  - notifications: 发送通知 + ES 全文检索 + search
  - config/elasticsearch.ts: ES Client 单例
  - package.json: 补充 @opentelemetry/sdk-node + exporter-trace-otlp-http
- services/push-gateway: WebSocket 推送网关（Go Gin）
  - internal/hub/hub.go: WebSocket 连接池管理（Register/Unregister/SendToUser）
  - internal/ws/handler.go: JWT 鉴权 + WebSocket 升级 + 内部推送 API
- services/ai: AI 辅助服务（Python FastAPI）
  - /chat + /chat/stream（SSE 流式）
  - /generate/question + /optimize/expression
  - config.py: OpenAI 兼容 API 配置
- packages/shared-proto/proto/msg.proto: NotificationService 契约（send/search）
- packages/shared-proto/proto/ai.proto: AiService 契约（含 stream 方法）

2026-07-08 01:39:02 +08:00

2 Commits