Merge pull request 'Add ProjectID to stream event envelope (CF3 project channel)' (#11) from feature/project-inbox-r1 into main

conformance_test.go

@@ -125,6 +125,12 @@ func TestGoldenCardEvents(t *testing.T) {
 		Payload: json.RawMessage(`{"cardId":"card_abc123def456","actionId":"escalate"}`)})
 }
 
+func TestGoldenProjectStreamEvent(t *testing.T) {
+	// 项目流（D50）：伪会话键 "project:<projectId>" 复用会话流机制；信封带 ProjectID。
+	golden(t, "event_project_stream", StreamEvent{Seq: 47, ConversationID: "project:prj_abc123def456", ProjectID: "prj_abc123def456", TS: "2026-09-30T11:00:00Z", V: 1, Type: EvCardCreated,
+		Payload: json.RawMessage(`{"card":{"id":"card_def456abc789","projectId":"prj_abc123def456","kind":"result","title":"项目级卡","status":"done","createdAt":"2026-09-30T11:00:00Z","updatedAt":"2026-09-30T11:00:00Z"}}`)})
+}
+
 func TestGoldenUIVocabularies(t *testing.T) {
 	golden(t, "ui_avatar", []UINode{
 		{Type: UIAvatar, Avatar: &UIAvatarSpec{Name: "weichen", Sub: "OWNER"}},

events.go

@@ -4,10 +4,13 @@ import "encoding/json"
 
 // 事件信封：后端 → 前端的唯一增量通道（SSE），持久化后转发，Seq 在会话内单调。
 // 消费方对未知 Type 静默忽略（原则 6 前向兼容）。
+// 项目流（D50）：项目频道事件以伪会话键 "project:<projectId>" 复用同一机制
+//（独立 seq、持久化、断线重放），信封以 ProjectID 标识归属（会话流事件为空）。
 type StreamEvent struct {
 	Seq            int64           `json:"seq"`
 	RunID          ID              `json:"runId,omitempty"`
 	ConversationID ID              `json:"conversationId"`
+	ProjectID      ID              `json:"projectID,omitempty"` // 项目流事件的项目归属（D50；只增不删）
 	TS             string          `json:"ts"` // RFC3339
 	V              int             `json:"v"`
 	Type           StreamEventType `json:"type"`

testdata/golden/event_project_stream.json

@@ -0,0 +1,19 @@
+{
+  "seq": 47,
+  "conversationId": "project:prj_abc123def456",
+  "projectID": "prj_abc123def456",
+  "ts": "2026-09-30T11:00:00Z",
+  "v": 1,
+  "type": "card.created",
+  "payload": {
+    "card": {
+      "id": "card_def456abc789",
+      "projectId": "prj_abc123def456",
+      "kind": "result",
+      "title": "项目级卡",
+      "status": "done",
+      "createdAt": "2026-09-30T11:00:00Z",
+      "updatedAt": "2026-09-30T11:00:00Z"
+    }
+  }
+}