From 19535e6a3735fc79211728ecff37e82448c034a1 Mon Sep 17 00:00:00 2001
From: hhs <386998068@qq.com>
Date: Sat, 13 Jun 2026 16:13:22 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20Phase=205.1=20-=20Client=20=E6=89=A9?=
 =?UTF-8?q?=E5=B1=95=EF=BC=8C=E6=B7=BB=E5=8A=A0=20orchestrator=20=E4=BE=9D?=
 =?UTF-8?q?=E8=B5=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 扩展 Client 结构体，添加 sessionManager、orchestrator、cancelFuncs 字段
- 创建 WSClient 适配器实现 orchestrator.Sender 接口
- 更新 ServeWS 函数签名，接收 orchestrator 参数
- 在 main.go 中初始化 AI 服务和 Orchestrator
---
 backend/cmd/server/main.go     | 14 +++++++-
 backend/internal/ws/handler.go | 60 ++++++++++++++++++++++++++++++----
 2 files changed, 66 insertions(+), 8 deletions(-)

diff --git a/backend/cmd/server/main.go b/backend/cmd/server/main.go
index a475fa4..61edbaf 100644
--- a/backend/cmd/server/main.go
+++ b/backend/cmd/server/main.go
@@ -10,8 +10,12 @@ import (
 
 	"github.com/gin-gonic/gin"
 
+	"github.com/hhs/camtalk/internal/ai/llm"
+	"github.com/hhs/camtalk/internal/ai/stt"
+	"github.com/hhs/camtalk/internal/ai/tts"
 	"github.com/hhs/camtalk/internal/config"
 	"github.com/hhs/camtalk/internal/logger"
+	"github.com/hhs/camtalk/internal/orchestrator"
 	"github.com/hhs/camtalk/internal/session"
 	"github.com/hhs/camtalk/internal/ws"
 )
@@ -40,6 +44,14 @@ func main() {
 	sessionMgr = session.NewMemoryManager(30*time.Minute, 20)
 	defer sessionMgr.(*session.MemoryManager).Stop()
 
+	// 初始化 AI 服务
+	sttService := stt.NewDeepgramService(cfg.AI.STT.APIKey, cfg.AI.STT.Endpoint, logger.Log)
+	llmService := llm.NewOpenAIService(cfg.AI.LLM.APIKey, cfg.AI.LLM.Model, cfg.AI.LLM.Endpoint, cfg.AI.LLM.Timeout, logger.Log)
+	ttsService := tts.NewOpenAIService(cfg.AI.TTS.APIKey, cfg.AI.TTS.Voice, cfg.AI.TTS.Endpoint, cfg.AI.TTS.Speed, cfg.AI.TTS.Timeout, logger.Log)
+
+	// 初始化 Orchestrator
+	orch := orchestrator.New(sttService, llmService, ttsService, sessionMgr)
+
 	// Gin 模式
 	if cfg.App.Env == "prod" {
 		gin.SetMode(gin.ReleaseMode)
@@ -55,7 +67,7 @@ func main() {
 	}
 
 	// WebSocket
-	r.GET("/ws", ws.ServeWS(sessionMgr))
+	r.GET("/ws", ws.ServeWS(sessionMgr, orch))
 
 	// HTTP Server
 	srv := &http.Server{
diff --git a/backend/internal/ws/handler.go b/backend/internal/ws/handler.go
index 83316b4..4c77ff6 100644
--- a/backend/internal/ws/handler.go
+++ b/backend/internal/ws/handler.go
@@ -13,6 +13,7 @@ import (
 	"github.com/hhs/camtalk/internal/errors"
 	"github.com/hhs/camtalk/internal/logger"
 	"github.com/hhs/camtalk/internal/models"
+	"github.com/hhs/camtalk/internal/orchestrator"
 	"github.com/hhs/camtalk/internal/session"
 )
 
@@ -22,9 +23,12 @@ var upgrader = websocket.Upgrader{
 
 // Client 代表一个 WebSocket 客户端连接。
 type Client struct {
-	conn      *websocket.Conn
-	sessionID string
-	mu        sync.Mutex
+	conn          *websocket.Conn
+	sessionID     string
+	sessionMgr    session.Manager
+	orchestrator  orchestrator.Orchestrator
+	cancelFuncs   map[string]context.CancelFunc // requestID → cancel func
+	mu            sync.Mutex
 }
 
 // SendJSON 向客户端发送 JSON 消息（公开以便 errors 包调用）。
@@ -34,14 +38,50 @@ func (c *Client) SendJSON(v any) error {
 	return c.conn.WriteJSON(v)
 }
 
+// WSClient 实现 orchestrator.Sender 接口，将消息推送到 WebSocket 连接。
+type WSClient struct {
+	client    *Client
+	requestID string
+}
+
+// SendSTTResult 发送语音识别结果。
+func (w *WSClient) SendSTTResult(result models.WsSTTResult) error {
+	result.RequestID = w.requestID
+	return w.client.SendJSON(result)
+}
+
+// SendLLMChunk 发送 LLM 流式文本增量。
+func (w *WSClient) SendLLMChunk(chunk models.WsLLMChunk) error {
+	chunk.RequestID = w.requestID
+	return w.client.SendJSON(chunk)
+}
+
+// SendLLMDone 发送 LLM 流结束信号。
+func (w *WSClient) SendLLMDone(done models.WsLLMDone) error {
+	done.RequestID = w.requestID
+	return w.client.SendJSON(done)
+}
+
+// SendTTSAudio 发送 TTS 音频数据。
+func (w *WSClient) SendTTSAudio(audio models.WsTTSAudio) error {
+	audio.RequestID = w.requestID
+	return w.client.SendJSON(audio)
+}
+
+// SendError 发送错误消息。
+func (w *WSClient) SendError(err models.WsError) error {
+	err.RequestID = w.requestID
+	return w.client.SendJSON(err)
+}
+
 // ServeWS 处理 WebSocket 升级请求。
-func ServeWS(sessionMgr session.Manager) gin.HandlerFunc {
+func ServeWS(sessionMgr session.Manager, orch orchestrator.Orchestrator) gin.HandlerFunc {
 	return func(c *gin.Context) {
-		serveWS(c, sessionMgr)
+		serveWS(c, sessionMgr, orch)
 	}
 }
 
-func serveWS(c *gin.Context, sessionMgr session.Manager) {
+func serveWS(c *gin.Context, sessionMgr session.Manager, orch orchestrator.Orchestrator) {
 	conn, err := upgrader.Upgrade(c.Writer, c.Request, nil)
 	if err != nil {
 		logger.Log.Errorw("websocket upgrade failed", "error", err)
@@ -56,7 +96,13 @@ func serveWS(c *gin.Context, sessionMgr session.Manager) {
 		return
 	}
 
-	client := &Client{conn: conn, sessionID: sessionID}
+	client := &Client{
+		conn:         conn,
+		sessionID:    sessionID,
+		sessionMgr:   sessionMgr,
+		orchestrator: orch,
+		cancelFuncs:  make(map[string]context.CancelFunc),
+	}
 
 	// 发送 connected 消息
 	_ = client.SendJSON(models.WsConnected{