safesight/edge/agent/internal/httpapi/preview.go
tian 29d9ef5d0d refactor: 项目结构梳理 - 设备端/管理端对称布局
仓库结构:
  edge/     设备端(原根目录设备端代码整体移入)
  control/  管理端(清理后)
  docs/     文档(PRD 移入 design/)
  README.md 根导航(新增)

清理:
- control/.brainstorm 临时草稿删除
- control 根级重复文档(API表/PRD_04)并入 docs/design/
- control/plan.md -> docs/implementation/control-plan.md
- control/safesightd-linux-arm64 二进制取消版本控制(.gitignore)
- edge/transform 模型转换产物归入 models/,onnx/pt 大源文件取消跟踪(.gitignore)
- Readme.md(PRD) -> docs/design/PRD_Product_v1.2.md(避开 README 大小写冲突)

更新:
- 根 README.md 导航、docs/README.md 文档索引
- deployment.md/检查表路径加 edge/ 前缀
- .gitignore 重写(edge/control 分区规则)
2026-08-02 11:39:54 +08:00

59 lines
1.3 KiB
Go

package httpapi
import (
"encoding/json"
"net/http"
"strconv"
)
type previewChannel struct {
Name string `json:"name"`
HlsURL string `json:"hls_url,omitempty"`
}
// handlePreviewChannels returns available video preview channels.
// GET /v1/preview/channels
func (s *Server) handlePreviewChannels(w http.ResponseWriter, r *http.Request) {
if r.Method != http.MethodGet {
errorJSON(w, http.StatusMethodNotAllowed, "method not allowed")
return
}
if !s.authorize(r, false) {
errorJSON(w, http.StatusUnauthorized, "unauthorized")
return
}
channels := s.discoverChannels(r)
if channels == nil {
channels = make([]previewChannel, 0)
}
writeJSON(w, http.StatusOK, map[string]any{"channels": channels})
}
func (s *Server) discoverChannels(r *http.Request) []previewChannel {
if s.ms == nil {
return nil
}
_, body, err := s.ms.GetGraphs(r.Context())
if err != nil {
return nil
}
var graphs []struct {
Name string `json:"name"`
}
if err := json.Unmarshal(body, &graphs); err != nil {
return nil
}
baseURL := "http://" + s.hostname + ":" + strconv.Itoa(s.mediaPort)
var channels []previewChannel
for _, g := range graphs {
channels = append(channels, previewChannel{
Name: g.Name,
HlsURL: baseURL + "/hls/" + g.Name + "/index.m3u8",
})
}
return channels
}