api.go 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544
  1. package api
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "io"
  6. "net/http"
  7. "sort"
  8. "strconv"
  9. "strings"
  10. "sync"
  11. "time"
  12. "github.com/gorilla/websocket"
  13. "ai-status-light/internal/database"
  14. "ai-status-light/internal/logger"
  15. mqttcli "ai-status-light/internal/mqtt"
  16. "ai-status-light/internal/web"
  17. )
  18. type ClientStatus struct {
  19. Port int `json:"port"`
  20. Status string `json:"status"`
  21. Code string `json:"code"`
  22. Timestamp string `json:"timestamp"`
  23. }
  24. type EventRequest struct {
  25. Code string `json:"code"`
  26. Timestamp string `json:"timestamp,omitempty"`
  27. }
  28. type Server struct {
  29. db *database.DB
  30. server *http.Server
  31. clients map[*websocket.Conn]bool
  32. clientsMu sync.Mutex
  33. upgrader websocket.Upgrader
  34. statusMap map[int]*ClientStatus
  35. statusMu sync.RWMutex
  36. certFile string
  37. keyFile string
  38. mqttClient *mqttcli.Client
  39. bleStdin io.Writer
  40. }
  41. type Response struct {
  42. Code int `json:"code"`
  43. Message string `json:"message"`
  44. Data interface{} `json:"data,omitempty"`
  45. }
  46. func New(db *database.DB, addr string) *Server {
  47. s := &Server{
  48. db: db,
  49. clients: make(map[*websocket.Conn]bool),
  50. statusMap: make(map[int]*ClientStatus),
  51. upgrader: websocket.Upgrader{
  52. CheckOrigin: func(r *http.Request) bool {
  53. return true
  54. },
  55. },
  56. }
  57. mux := http.NewServeMux()
  58. mux.HandleFunc("/api/clients", s.handleClients)
  59. mux.HandleFunc("/api/event", s.handleEvent)
  60. mux.HandleFunc("/api/mqtt", s.handleMQTT)
  61. mux.HandleFunc("/api/mqtt/", s.handleMQTTByID)
  62. mux.HandleFunc("/api/ble", s.handleBLE)
  63. mux.HandleFunc("/api/ble/", s.handleBLEByID)
  64. mux.HandleFunc("/api/health", s.handleHealth)
  65. mux.HandleFunc("/ws", s.handleWebSocket)
  66. mux.HandleFunc("/", web.Handler())
  67. s.server = &http.Server{
  68. Addr: addr,
  69. Handler: corsMiddleware(mux),
  70. }
  71. return s
  72. }
  73. func (s *Server) EnableTLS(certFile, keyFile string) {
  74. s.certFile = certFile
  75. s.keyFile = keyFile
  76. }
  77. func (s *Server) SetMQTTClient(client *mqttcli.Client) {
  78. s.mqttClient = client
  79. }
  80. func (s *Server) SetBLEStdin(stdin io.Writer) {
  81. s.bleStdin = stdin
  82. }
  83. func (s *Server) Start() error {
  84. if s.certFile != "" && s.keyFile != "" {
  85. logger.Info("API 服务器开始监听 (HTTPS): %s", s.server.Addr)
  86. err := s.server.ListenAndServeTLS(s.certFile, s.keyFile)
  87. if err != nil && err != http.ErrServerClosed {
  88. logger.Error("API 服务器监听失败: %v", err)
  89. }
  90. return err
  91. }
  92. logger.Info("API 服务器开始监听: %s", s.server.Addr)
  93. err := s.server.ListenAndServe()
  94. if err != nil && err != http.ErrServerClosed {
  95. logger.Error("API 服务器监听失败: %v", err)
  96. }
  97. return err
  98. }
  99. func corsMiddleware(next http.Handler) http.Handler {
  100. return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
  101. w.Header().Set("Access-Control-Allow-Origin", "*")
  102. w.Header().Set("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, OPTIONS")
  103. w.Header().Set("Access-Control-Allow-Headers", "Content-Type")
  104. if r.Method == "OPTIONS" {
  105. w.WriteHeader(http.StatusOK)
  106. return
  107. }
  108. next.ServeHTTP(w, r)
  109. })
  110. }
  111. func (s *Server) handleHealth(w http.ResponseWriter, r *http.Request) {
  112. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "ok"})
  113. }
  114. func (s *Server) handleEvent(w http.ResponseWriter, r *http.Request) {
  115. if r.Method != http.MethodPost {
  116. writeJSON(w, http.StatusMethodNotAllowed, Response{Code: -1, Message: "方法不允许"})
  117. return
  118. }
  119. var req EventRequest
  120. if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
  121. logger.Warn("事件请求体解析失败: %v", err)
  122. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "无效的请求体"})
  123. return
  124. }
  125. if req.Code == "" {
  126. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "code 不能为空"})
  127. return
  128. }
  129. logger.Info("收到事件: code=%s", req.Code)
  130. // 通过 MQTT 发送
  131. if s.mqttClient != nil {
  132. payload := map[string]interface{}{
  133. "code": req.Code,
  134. "timestamp": time.Now().Format(time.RFC3339),
  135. }
  136. if err := s.mqttClient.PublishRaw(s.mqttClient.GetTopic(), payload); err != nil {
  137. logger.Error("MQTT 发送失败: %v", err)
  138. }
  139. }
  140. // 通过 BLE 发送
  141. if s.bleStdin != nil {
  142. msg := fmt.Sprintf(`{"code":"%s"}`+"\n", req.Code)
  143. if _, err := s.bleStdin.Write([]byte(msg)); err != nil {
  144. logger.Error("BLE 发送失败: %v", err)
  145. }
  146. }
  147. // 广播到 WebSocket 客户端
  148. s.BroadcastStatus(0, req.Code, req.Code)
  149. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "ok"})
  150. }
  151. func (s *Server) handleClients(w http.ResponseWriter, r *http.Request) {
  152. if r.Method != http.MethodGet {
  153. writeJSON(w, http.StatusMethodNotAllowed, Response{Code: -1, Message: "方法不允许"})
  154. return
  155. }
  156. s.statusMu.RLock()
  157. result := make([]*ClientStatus, 0, len(s.statusMap))
  158. for _, cs := range s.statusMap {
  159. result = append(result, cs)
  160. }
  161. s.statusMu.RUnlock()
  162. sort.Slice(result, func(i, j int) bool {
  163. return result[i].Port < result[j].Port
  164. })
  165. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "success", Data: result})
  166. }
  167. func (s *Server) handleMQTT(w http.ResponseWriter, r *http.Request) {
  168. logger.Debug("HTTP %s %s", r.Method, r.URL.Path)
  169. switch r.Method {
  170. case http.MethodGet:
  171. s.listMQTTConfigs(w, r)
  172. case http.MethodPost:
  173. s.createMQTTConfig(w, r)
  174. default:
  175. logger.Warn("不支持的 HTTP 方法: %s %s", r.Method, r.URL.Path)
  176. writeJSON(w, http.StatusMethodNotAllowed, Response{Code: -1, Message: "方法不允许"})
  177. }
  178. }
  179. func (s *Server) handleMQTTByID(w http.ResponseWriter, r *http.Request) {
  180. logger.Debug("HTTP %s %s", r.Method, r.URL.Path)
  181. idStr := strings.TrimPrefix(r.URL.Path, "/api/mqtt/")
  182. id, err := strconv.Atoi(idStr)
  183. if err != nil {
  184. logger.Warn("无效的配置 ID: %s", idStr)
  185. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "无效的 ID"})
  186. return
  187. }
  188. switch r.Method {
  189. case http.MethodGet:
  190. s.getMQTTConfig(w, id)
  191. case http.MethodPut:
  192. s.updateMQTTConfig(w, r, id)
  193. case http.MethodDelete:
  194. s.deleteMQTTConfig(w, id)
  195. default:
  196. logger.Warn("不支持的 HTTP 方法: %s %s", r.Method, r.URL.Path)
  197. writeJSON(w, http.StatusMethodNotAllowed, Response{Code: -1, Message: "方法不允许"})
  198. }
  199. }
  200. func (s *Server) handleBLE(w http.ResponseWriter, r *http.Request) {
  201. logger.Debug("HTTP %s %s", r.Method, r.URL.Path)
  202. switch r.Method {
  203. case http.MethodGet:
  204. s.listBLEConfigs(w, r)
  205. case http.MethodPost:
  206. s.createBLEConfig(w, r)
  207. default:
  208. logger.Warn("不支持的 HTTP 方法: %s %s", r.Method, r.URL.Path)
  209. writeJSON(w, http.StatusMethodNotAllowed, Response{Code: -1, Message: "方法不允许"})
  210. }
  211. }
  212. func (s *Server) handleBLEByID(w http.ResponseWriter, r *http.Request) {
  213. logger.Debug("HTTP %s %s", r.Method, r.URL.Path)
  214. idStr := strings.TrimPrefix(r.URL.Path, "/api/ble/")
  215. id, err := strconv.Atoi(idStr)
  216. if err != nil {
  217. logger.Warn("无效的配置 ID: %s", idStr)
  218. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "无效的 ID"})
  219. return
  220. }
  221. switch r.Method {
  222. case http.MethodGet:
  223. s.getBLEConfig(w, id)
  224. case http.MethodPut:
  225. s.updateBLEConfig(w, r, id)
  226. case http.MethodDelete:
  227. s.deleteBLEConfig(w, id)
  228. default:
  229. logger.Warn("不支持的 HTTP 方法: %s %s", r.Method, r.URL.Path)
  230. writeJSON(w, http.StatusMethodNotAllowed, Response{Code: -1, Message: "方法不允许"})
  231. }
  232. }
  233. func (s *Server) listMQTTConfigs(w http.ResponseWriter, r *http.Request) {
  234. configs, err := s.db.ListMQTTConfigs()
  235. if err != nil {
  236. logger.Error("查询 MQTT 配置列表失败: %v", err)
  237. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  238. return
  239. }
  240. logger.Debug("查询 MQTT 配置列表: %d 条", len(configs))
  241. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "ok", Data: configs})
  242. }
  243. func (s *Server) createMQTTConfig(w http.ResponseWriter, r *http.Request) {
  244. var cfg database.MQTTConfig
  245. if err := json.NewDecoder(r.Body).Decode(&cfg); err != nil {
  246. logger.Warn("创建配置请求体解析失败: %v", err)
  247. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "无效的请求体"})
  248. return
  249. }
  250. if cfg.Broker == "" {
  251. logger.Warn("创建配置: broker 为空")
  252. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "broker 不能为空"})
  253. return
  254. }
  255. if cfg.ClientID == "" {
  256. cfg.ClientID = "opencode-monitor"
  257. }
  258. if cfg.Topic == "" {
  259. cfg.Topic = "opencode/status"
  260. }
  261. if err := s.db.SaveMQTTConfig(&cfg); err != nil {
  262. logger.Error("创建 MQTT 配置失败: %v", err)
  263. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  264. return
  265. }
  266. logger.Info("MQTT 配置已创建: id=%d, broker=%s, topic=%s", cfg.ID, cfg.Broker, cfg.Topic)
  267. writeJSON(w, http.StatusCreated, Response{Code: 0, Message: "创建成功", Data: cfg})
  268. }
  269. func (s *Server) getMQTTConfig(w http.ResponseWriter, id int) {
  270. configs, err := s.db.ListMQTTConfigs()
  271. if err != nil {
  272. logger.Error("查询 MQTT 配置失败: id=%d, %v", id, err)
  273. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  274. return
  275. }
  276. for _, cfg := range configs {
  277. if cfg.ID == id {
  278. logger.Debug("查询 MQTT 配置: id=%d", id)
  279. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "ok", Data: cfg})
  280. return
  281. }
  282. }
  283. logger.Warn("MQTT 配置不存在: id=%d", id)
  284. writeJSON(w, http.StatusNotFound, Response{Code: -1, Message: "配置不存在"})
  285. }
  286. func (s *Server) updateMQTTConfig(w http.ResponseWriter, r *http.Request, id int) {
  287. var cfg database.MQTTConfig
  288. if err := json.NewDecoder(r.Body).Decode(&cfg); err != nil {
  289. logger.Warn("更新配置请求体解析失败: id=%d, %v", id, err)
  290. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "无效的请求体"})
  291. return
  292. }
  293. cfg.ID = id
  294. if cfg.Broker == "" {
  295. logger.Warn("更新配置: broker 为空, id=%d", id)
  296. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "broker 不能为空"})
  297. return
  298. }
  299. if cfg.ClientID == "" {
  300. cfg.ClientID = "opencode-monitor"
  301. }
  302. if cfg.Topic == "" {
  303. cfg.Topic = "opencode/status"
  304. }
  305. if err := s.db.SaveMQTTConfig(&cfg); err != nil {
  306. logger.Error("更新 MQTT 配置失败: id=%d, %v", id, err)
  307. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  308. return
  309. }
  310. logger.Info("MQTT 配置已更新: id=%d, broker=%s, topic=%s", id, cfg.Broker, cfg.Topic)
  311. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "更新成功", Data: cfg})
  312. }
  313. func (s *Server) deleteMQTTConfig(w http.ResponseWriter, id int) {
  314. if err := s.db.DeleteMQTTConfig(id); err != nil {
  315. logger.Error("删除 MQTT 配置失败: id=%d, %v", id, err)
  316. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  317. return
  318. }
  319. logger.Info("MQTT 配置已删除: id=%d", id)
  320. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "删除成功"})
  321. }
  322. func (s *Server) listBLEConfigs(w http.ResponseWriter, r *http.Request) {
  323. configs, err := s.db.ListBLEConfigs()
  324. if err != nil {
  325. logger.Error("查询 BLE 配置列表失败: %v", err)
  326. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  327. return
  328. }
  329. logger.Debug("查询 BLE 配置列表: %d 条", len(configs))
  330. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "ok", Data: configs})
  331. }
  332. func (s *Server) createBLEConfig(w http.ResponseWriter, r *http.Request) {
  333. var cfg database.BLEConfig
  334. if err := json.NewDecoder(r.Body).Decode(&cfg); err != nil {
  335. logger.Warn("创建 BLE 配置请求体解析失败: %v", err)
  336. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "无效的请求体"})
  337. return
  338. }
  339. if cfg.DeviceName == "" || cfg.ServiceUUID == "" || cfg.ModeCharUUID == "" || cfg.ConfigCharUUID == "" {
  340. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "device_name, service_uuid, mode_char_uuid, config_char_uuid 不能为空"})
  341. return
  342. }
  343. if err := s.db.SaveBLEConfig(&cfg); err != nil {
  344. logger.Error("创建 BLE 配置失败: %v", err)
  345. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  346. return
  347. }
  348. logger.Info("BLE 配置已创建: id=%d, device=%s", cfg.ID, cfg.DeviceName)
  349. writeJSON(w, http.StatusCreated, Response{Code: 0, Message: "创建成功", Data: cfg})
  350. }
  351. func (s *Server) getBLEConfig(w http.ResponseWriter, id int) {
  352. configs, err := s.db.ListBLEConfigs()
  353. if err != nil {
  354. logger.Error("查询 BLE 配置失败: id=%d, %v", id, err)
  355. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  356. return
  357. }
  358. for _, cfg := range configs {
  359. if cfg.ID == id {
  360. logger.Debug("查询 BLE 配置: id=%d", id)
  361. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "ok", Data: cfg})
  362. return
  363. }
  364. }
  365. logger.Warn("BLE 配置不存在: id=%d", id)
  366. writeJSON(w, http.StatusNotFound, Response{Code: -1, Message: "配置不存在"})
  367. }
  368. func (s *Server) updateBLEConfig(w http.ResponseWriter, r *http.Request, id int) {
  369. var cfg database.BLEConfig
  370. if err := json.NewDecoder(r.Body).Decode(&cfg); err != nil {
  371. logger.Warn("更新 BLE 配置请求体解析失败: id=%d, %v", id, err)
  372. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "无效的请求体"})
  373. return
  374. }
  375. cfg.ID = id
  376. if cfg.DeviceName == "" || cfg.ServiceUUID == "" || cfg.ModeCharUUID == "" || cfg.ConfigCharUUID == "" {
  377. writeJSON(w, http.StatusBadRequest, Response{Code: -1, Message: "device_name, service_uuid, mode_char_uuid, config_char_uuid 不能为空"})
  378. return
  379. }
  380. if err := s.db.SaveBLEConfig(&cfg); err != nil {
  381. logger.Error("更新 BLE 配置失败: id=%d, %v", id, err)
  382. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  383. return
  384. }
  385. logger.Info("BLE 配置已更新: id=%d, device=%s", id, cfg.DeviceName)
  386. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "更新成功", Data: cfg})
  387. }
  388. func (s *Server) deleteBLEConfig(w http.ResponseWriter, id int) {
  389. if err := s.db.DeleteBLEConfig(id); err != nil {
  390. logger.Error("删除 BLE 配置失败: id=%d, %v", id, err)
  391. writeJSON(w, http.StatusInternalServerError, Response{Code: -1, Message: err.Error()})
  392. return
  393. }
  394. logger.Info("BLE 配置已删除: id=%d", id)
  395. writeJSON(w, http.StatusOK, Response{Code: 0, Message: "删除成功"})
  396. }
  397. func writeJSON(w http.ResponseWriter, statusCode int, data interface{}) {
  398. w.Header().Set("Content-Type", "application/json")
  399. w.WriteHeader(statusCode)
  400. json.NewEncoder(w).Encode(data)
  401. }
  402. func (s *Server) GetAddr() string {
  403. return s.server.Addr
  404. }
  405. func (s *Server) handleWebSocket(w http.ResponseWriter, r *http.Request) {
  406. conn, err := s.upgrader.Upgrade(w, r, nil)
  407. if err != nil {
  408. logger.Error("WebSocket 升级失败: %v", err)
  409. return
  410. }
  411. s.clientsMu.Lock()
  412. s.clients[conn] = true
  413. s.clientsMu.Unlock()
  414. logger.Info("WebSocket 客户端已连接,当前连接数: %d", len(s.clients))
  415. go func() {
  416. defer func() {
  417. s.clientsMu.Lock()
  418. delete(s.clients, conn)
  419. s.clientsMu.Unlock()
  420. conn.Close()
  421. logger.Info("WebSocket 客户端已断开,当前连接数: %d", len(s.clients))
  422. }()
  423. for {
  424. _, _, err := conn.ReadMessage()
  425. if err != nil {
  426. break
  427. }
  428. }
  429. }()
  430. }
  431. func (s *Server) BroadcastStatus(port int, status string, code string) {
  432. ts := time.Now().Format(time.RFC3339)
  433. s.statusMu.Lock()
  434. s.statusMap[port] = &ClientStatus{
  435. Port: port,
  436. Status: status,
  437. Code: code,
  438. Timestamp: ts,
  439. }
  440. s.statusMu.Unlock()
  441. s.clientsMu.Lock()
  442. defer s.clientsMu.Unlock()
  443. if len(s.clients) == 0 {
  444. return
  445. }
  446. payload := map[string]interface{}{
  447. "port": port,
  448. "status": status,
  449. "code": code,
  450. "timestamp": ts,
  451. }
  452. data, err := json.Marshal(payload)
  453. if err != nil {
  454. logger.Error("序列化广播消息失败: %v", err)
  455. return
  456. }
  457. for client := range s.clients {
  458. err := client.WriteMessage(websocket.TextMessage, data)
  459. if err != nil {
  460. logger.Debug("WebSocket 写入失败,移除客户端: %v", err)
  461. client.Close()
  462. delete(s.clients, client)
  463. }
  464. }
  465. }