init: 昔涟项目骨架

backend/gateway/cmd/main.go

@@ -0,0 +1,64 @@
+package main
+
+import (
+    "context"
+    "log"
+    "net/http"
+    "os"
+    "os/signal"
+    "syscall"
+    "time"
+
+    "github.com/gin-gonic/gin"
+    "github.com/yourname/cyrene-ai/gateway/internal/config"
+    "github.com/yourname/cyrene-ai/gateway/internal/middleware"
+    "github.com/yourname/cyrene-ai/gateway/internal/router"
+    "github.com/yourname/cyrene-ai/gateway/internal/ws"
+)
+
+func main() {
+    // 加载配置
+    cfg := config.Load()
+
+    // 初始化Gin
+    if cfg.Env == "production" {
+        gin.SetMode(gin.ReleaseMode)
+    }
+    r := gin.New()
+
+    // 中间件
+    r.Use(middleware.CORS())
+    r.Use(middleware.RequestLogging())
+    r.Use(gin.Recovery())
+
+    // 初始化WebSocket Hub
+    hub := ws.NewHub()
+    go hub.Run()
+
+    // 注册路由
+    router.Setup(r, hub, cfg)
+
+    // 启动服务
+    srv := &http.Server{
+        Addr:    ":" + cfg.Port,
+        Handler: r,
+    }
+
+    go func() {
+        log.Printf("🚀 Gateway 启动在端口 %s", cfg.Port)
+        if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
+            log.Fatalf("服务启动失败: %v", err)
+        }
+    }()
+
+    // 优雅关闭
+    quit := make(chan os.Signal, 1)
+    signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
+    <-quit
+    log.Println("正在关闭服务...")
+
+    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+    defer cancel()
+    srv.Shutdown(ctx)
+    log.Println("服务已关闭")
+}

backend/gateway/internal/ws/protocol.go

@@ -0,0 +1,56 @@
+package ws
+
+import "time"
+
+// 客户端 → 服务端消息
+type ClientMessage struct {
+    Type      string `json:"type"`       // message | voice_input | ping
+    SessionID string `json:"session_id"`
+    Mode      string `json:"mode"`        // text | voice_msg | voice_assistant
+    Content   string `json:"content"`
+    AudioData string `json:"audio_data,omitempty"` // base64
+    Timestamp int64  `json:"timestamp"`
+}
+
+// 服务端 → 客户端消息
+type ServerMessage struct {
+    Type         string          `json:"type"`          // response | segment | audio | error | device_update
+    MessageID    string          `json:"message_id"`
+    Text         string          `json:"text,omitempty"`
+    Segments     []VoiceSegment  `json:"segments,omitempty"`    // 断句数组
+    FullAudioURL string          `json:"full_audio_url,omitempty"`
+    ResponseMode string          `json:"response_mode"`
+    ToolCalls    []ToolCall      `json:"tool_calls,omitempty"`
+    Error        string          `json:"error,omitempty"`
+    Timestamp    int64           `json:"timestamp"`
+}
+
+type VoiceSegment struct {
+    Index      int    `json:"index"`
+    Text       string `json:"text"`
+    AudioURL   string `json:"audio_url"`
+    DurationMs int    `json:"duration_ms"`
+}
+
+type ToolCall struct {
+    Name      string                 `json:"name"`
+    Arguments map[string]interface{} `json:"arguments"`
+    Result    interface{}            `json:"result,omitempty"`
+}
+
+// WebSocket客户端
+type Client struct {
+    Hub      *Hub
+    Conn     *websocket.Conn  // 使用 gorilla/websocket
+    Send     chan []byte
+    UserID   string
+    SessionID string
+}
+
+// 连接池
+type Hub struct {
+    Clients    map[*Client]bool
+    Broadcast  chan []byte
+    Register   chan *Client
+    Unregister chan *Client
+}