Wideband autonomous SDR analysis engine forked from sdr-visual-suite
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.

342 строки
13KB

  1. package main
  2. import (
  3. "context"
  4. "encoding/json"
  5. "log"
  6. "net/http"
  7. "os"
  8. "path/filepath"
  9. "strconv"
  10. "strings"
  11. "sync"
  12. "time"
  13. "sdr-wideband-suite/internal/config"
  14. "sdr-wideband-suite/internal/detector"
  15. "sdr-wideband-suite/internal/events"
  16. fftutil "sdr-wideband-suite/internal/fft"
  17. "sdr-wideband-suite/internal/pipeline"
  18. "sdr-wideband-suite/internal/recorder"
  19. "sdr-wideband-suite/internal/runtime"
  20. )
  21. func registerAPIHandlers(mux *http.ServeMux, cfgPath string, cfgManager *runtime.Manager, srcMgr *sourceManager, dspUpdates chan dspUpdate, gpuState *gpuStatus, recMgr *recorder.Manager, sigSnap *signalSnapshot, eventMu *sync.RWMutex, phaseSnap *phaseSnapshot) {
  22. mux.HandleFunc("/api/config", func(w http.ResponseWriter, r *http.Request) {
  23. w.Header().Set("Content-Type", "application/json")
  24. switch r.Method {
  25. case http.MethodGet:
  26. _ = json.NewEncoder(w).Encode(cfgManager.Snapshot())
  27. case http.MethodPost:
  28. var update runtime.ConfigUpdate
  29. if err := json.NewDecoder(r.Body).Decode(&update); err != nil {
  30. http.Error(w, "invalid json", http.StatusBadRequest)
  31. return
  32. }
  33. prev := cfgManager.Snapshot()
  34. next, err := cfgManager.ApplyConfig(update)
  35. if err != nil {
  36. http.Error(w, err.Error(), http.StatusBadRequest)
  37. return
  38. }
  39. if update.Pipeline != nil && update.Pipeline.Profile != nil {
  40. if prof, ok := pipeline.ResolveProfile(next, *update.Pipeline.Profile); ok {
  41. pipeline.MergeProfile(&next, prof)
  42. cfgManager.Replace(next)
  43. }
  44. }
  45. sourceChanged := prev.CenterHz != next.CenterHz || prev.SampleRate != next.SampleRate || prev.GainDb != next.GainDb || prev.AGC != next.AGC || prev.TunerBwKHz != next.TunerBwKHz
  46. if sourceChanged {
  47. if err := srcMgr.ApplyConfig(next); err != nil {
  48. cfgManager.Replace(prev)
  49. http.Error(w, "failed to apply source config", http.StatusInternalServerError)
  50. return
  51. }
  52. }
  53. if err := config.Save(cfgPath, next); err != nil {
  54. log.Printf("config save failed: %v", err)
  55. }
  56. detChanged := prev.Detector.ThresholdDb != next.Detector.ThresholdDb ||
  57. prev.Detector.MinDurationMs != next.Detector.MinDurationMs ||
  58. prev.Detector.HoldMs != next.Detector.HoldMs ||
  59. prev.Detector.EmaAlpha != next.Detector.EmaAlpha ||
  60. prev.Detector.HysteresisDb != next.Detector.HysteresisDb ||
  61. prev.Detector.MinStableFrames != next.Detector.MinStableFrames ||
  62. prev.Detector.GapToleranceMs != next.Detector.GapToleranceMs ||
  63. prev.Detector.CFARMode != next.Detector.CFARMode ||
  64. prev.Detector.CFARGuardHz != next.Detector.CFARGuardHz ||
  65. prev.Detector.CFARTrainHz != next.Detector.CFARTrainHz ||
  66. prev.Detector.CFARRank != next.Detector.CFARRank ||
  67. prev.Detector.CFARScaleDb != next.Detector.CFARScaleDb ||
  68. prev.Detector.CFARWrapAround != next.Detector.CFARWrapAround ||
  69. prev.SampleRate != next.SampleRate ||
  70. prev.FFTSize != next.FFTSize
  71. windowChanged := prev.FFTSize != next.FFTSize
  72. var newDet *detector.Detector
  73. var newWindow []float64
  74. if detChanged {
  75. newDet = detector.New(next.Detector, next.SampleRate, next.FFTSize)
  76. }
  77. if windowChanged {
  78. newWindow = fftutil.Hann(next.FFTSize)
  79. }
  80. pushDSPUpdate(dspUpdates, dspUpdate{cfg: next, det: newDet, window: newWindow, dcBlock: next.DCBlock, iqBalance: next.IQBalance, useGPUFFT: next.UseGPUFFT})
  81. _ = json.NewEncoder(w).Encode(next)
  82. default:
  83. http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
  84. }
  85. })
  86. mux.HandleFunc("/api/sdr/settings", func(w http.ResponseWriter, r *http.Request) {
  87. w.Header().Set("Content-Type", "application/json")
  88. if r.Method != http.MethodPost {
  89. http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
  90. return
  91. }
  92. var update runtime.SettingsUpdate
  93. if err := json.NewDecoder(r.Body).Decode(&update); err != nil {
  94. http.Error(w, "invalid json", http.StatusBadRequest)
  95. return
  96. }
  97. prev := cfgManager.Snapshot()
  98. next, err := cfgManager.ApplySettings(update)
  99. if err != nil {
  100. http.Error(w, err.Error(), http.StatusBadRequest)
  101. return
  102. }
  103. if prev.AGC != next.AGC || prev.TunerBwKHz != next.TunerBwKHz {
  104. if err := srcMgr.ApplyConfig(next); err != nil {
  105. cfgManager.Replace(prev)
  106. http.Error(w, "failed to apply sdr settings", http.StatusInternalServerError)
  107. return
  108. }
  109. }
  110. if prev.DCBlock != next.DCBlock || prev.IQBalance != next.IQBalance {
  111. pushDSPUpdate(dspUpdates, dspUpdate{cfg: next, dcBlock: next.DCBlock, iqBalance: next.IQBalance})
  112. }
  113. if err := config.Save(cfgPath, next); err != nil {
  114. log.Printf("config save failed: %v", err)
  115. }
  116. _ = json.NewEncoder(w).Encode(next)
  117. })
  118. mux.HandleFunc("/api/stats", func(w http.ResponseWriter, r *http.Request) {
  119. w.Header().Set("Content-Type", "application/json")
  120. _ = json.NewEncoder(w).Encode(srcMgr.Stats())
  121. })
  122. mux.HandleFunc("/api/gpu", func(w http.ResponseWriter, r *http.Request) {
  123. w.Header().Set("Content-Type", "application/json")
  124. _ = json.NewEncoder(w).Encode(gpuState.snapshot())
  125. })
  126. mux.HandleFunc("/api/pipeline/policy", func(w http.ResponseWriter, r *http.Request) {
  127. w.Header().Set("Content-Type", "application/json")
  128. cfg := cfgManager.Snapshot()
  129. _ = json.NewEncoder(w).Encode(pipeline.PolicyFromConfig(cfg))
  130. })
  131. mux.HandleFunc("/api/pipeline/recommendations", func(w http.ResponseWriter, r *http.Request) {
  132. w.Header().Set("Content-Type", "application/json")
  133. cfg := cfgManager.Snapshot()
  134. policy := pipeline.PolicyFromConfig(cfg)
  135. budget := pipeline.BudgetModelFromPolicy(policy)
  136. recommend := map[string]any{
  137. "profile": policy.Profile,
  138. "mode": policy.Mode,
  139. "intent": policy.Intent,
  140. "surveillance_strategy": policy.SurveillanceStrategy,
  141. "refinement_strategy": policy.RefinementStrategy,
  142. "monitor_center_hz": policy.MonitorCenterHz,
  143. "monitor_start_hz": policy.MonitorStartHz,
  144. "monitor_end_hz": policy.MonitorEndHz,
  145. "monitor_span_hz": policy.MonitorSpanHz,
  146. "signal_priorities": policy.SignalPriorities,
  147. "auto_record_classes": policy.AutoRecordClasses,
  148. "auto_decode_classes": policy.AutoDecodeClasses,
  149. "refinement_jobs": policy.MaxRefinementJobs,
  150. "refinement_detail_fft": policy.RefinementDetailFFTSize,
  151. "refinement_auto_span": policy.RefinementAutoSpan,
  152. "refinement_min_span_hz": policy.RefinementMinSpanHz,
  153. "refinement_max_span_hz": policy.RefinementMaxSpanHz,
  154. "budgets": budget,
  155. }
  156. _ = json.NewEncoder(w).Encode(recommend)
  157. })
  158. mux.HandleFunc("/api/refinement", func(w http.ResponseWriter, r *http.Request) {
  159. w.Header().Set("Content-Type", "application/json")
  160. snap := phaseSnap.Snapshot()
  161. windowStats := buildWindowStats(snap.refinement.Input.Windows)
  162. arbitration := buildArbitrationSnapshot(snap.refinement, snap.arbitration)
  163. out := map[string]any{
  164. "plan": snap.refinement.Input.Plan,
  165. "windows": snap.refinement.Input.Windows,
  166. "window_stats": windowStats,
  167. "request": snap.refinement.Input.Request,
  168. "context": snap.refinement.Input.Context,
  169. "detail_level": snap.refinement.Input.Detail,
  170. "arbitration": arbitration,
  171. "work_items": snap.refinement.Input.WorkItems,
  172. "candidates": len(snap.refinement.Input.Candidates),
  173. "scheduled": len(snap.refinement.Input.Scheduled),
  174. "signals": len(snap.refinement.Result.Signals),
  175. "decisions": len(snap.refinement.Result.Decisions),
  176. "surveillance_level": snap.surveillance.Level,
  177. "surveillance_levels": snap.surveillance.Levels,
  178. "display_level": snap.surveillance.DisplayLevel,
  179. "refinement_level": snap.refinement.Input.Level,
  180. "presentation_level": snap.presentation,
  181. }
  182. _ = json.NewEncoder(w).Encode(out)
  183. })
  184. mux.HandleFunc("/api/events", func(w http.ResponseWriter, r *http.Request) {
  185. w.Header().Set("Content-Type", "application/json")
  186. limit := 200
  187. if v := r.URL.Query().Get("limit"); v != "" {
  188. if parsed, err := strconv.Atoi(v); err == nil {
  189. limit = parsed
  190. }
  191. }
  192. var since time.Time
  193. if v := r.URL.Query().Get("since"); v != "" {
  194. if parsed, err := parseSince(v); err == nil {
  195. since = parsed
  196. } else {
  197. http.Error(w, "invalid since", http.StatusBadRequest)
  198. return
  199. }
  200. }
  201. snap := cfgManager.Snapshot()
  202. eventMu.RLock()
  203. evs, err := events.ReadRecent(snap.EventPath, limit, since)
  204. eventMu.RUnlock()
  205. if err != nil {
  206. http.Error(w, "failed to read events", http.StatusInternalServerError)
  207. return
  208. }
  209. _ = json.NewEncoder(w).Encode(evs)
  210. })
  211. mux.HandleFunc("/api/signals", func(w http.ResponseWriter, r *http.Request) {
  212. w.Header().Set("Content-Type", "application/json")
  213. if sigSnap == nil {
  214. _ = json.NewEncoder(w).Encode([]detector.Signal{})
  215. return
  216. }
  217. _ = json.NewEncoder(w).Encode(sigSnap.get())
  218. })
  219. mux.HandleFunc("/api/candidates", func(w http.ResponseWriter, r *http.Request) {
  220. w.Header().Set("Content-Type", "application/json")
  221. if sigSnap == nil {
  222. _ = json.NewEncoder(w).Encode([]pipeline.Candidate{})
  223. return
  224. }
  225. sigs := sigSnap.get()
  226. _ = json.NewEncoder(w).Encode(pipeline.CandidatesFromSignals(sigs, "tracked-signal-snapshot"))
  227. })
  228. mux.HandleFunc("/api/decoders", func(w http.ResponseWriter, r *http.Request) {
  229. w.Header().Set("Content-Type", "application/json")
  230. _ = json.NewEncoder(w).Encode(decoderKeys(cfgManager.Snapshot()))
  231. })
  232. mux.HandleFunc("/api/recordings", func(w http.ResponseWriter, r *http.Request) {
  233. if r.Method != http.MethodGet {
  234. http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
  235. return
  236. }
  237. w.Header().Set("Content-Type", "application/json")
  238. snap := cfgManager.Snapshot()
  239. list, err := recorder.ListRecordings(snap.Recorder.OutputDir)
  240. if err != nil {
  241. http.Error(w, "failed to list recordings", http.StatusInternalServerError)
  242. return
  243. }
  244. _ = json.NewEncoder(w).Encode(list)
  245. })
  246. mux.HandleFunc("/api/recordings/", func(w http.ResponseWriter, r *http.Request) {
  247. w.Header().Set("Content-Type", "application/json")
  248. id := strings.TrimPrefix(r.URL.Path, "/api/recordings/")
  249. if id == "" {
  250. http.Error(w, "missing id", http.StatusBadRequest)
  251. return
  252. }
  253. snap := cfgManager.Snapshot()
  254. base := filepath.Clean(filepath.Join(snap.Recorder.OutputDir, id))
  255. if !strings.HasPrefix(base, filepath.Clean(snap.Recorder.OutputDir)) {
  256. http.Error(w, "invalid path", http.StatusBadRequest)
  257. return
  258. }
  259. if r.URL.Path == "/api/recordings/"+id+"/audio" {
  260. http.ServeFile(w, r, filepath.Join(base, "audio.wav"))
  261. return
  262. }
  263. if r.URL.Path == "/api/recordings/"+id+"/iq" {
  264. http.ServeFile(w, r, filepath.Join(base, "signal.cf32"))
  265. return
  266. }
  267. if r.URL.Path == "/api/recordings/"+id+"/decode" {
  268. mode := r.URL.Query().Get("mode")
  269. cmd := buildDecoderMap(cfgManager.Snapshot())[mode]
  270. if cmd == "" {
  271. http.Error(w, "decoder not configured", http.StatusBadRequest)
  272. return
  273. }
  274. meta, err := recorder.ReadMeta(filepath.Join(base, "meta.json"))
  275. if err != nil {
  276. http.Error(w, "meta read failed", http.StatusInternalServerError)
  277. return
  278. }
  279. audioPath := filepath.Join(base, "audio.wav")
  280. if _, errStat := os.Stat(audioPath); errStat != nil {
  281. audioPath = ""
  282. }
  283. res, err := recorder.DecodeOnDemand(cmd, filepath.Join(base, "signal.cf32"), meta.SampleRate, audioPath)
  284. if err != nil {
  285. http.Error(w, res.Stderr, http.StatusInternalServerError)
  286. return
  287. }
  288. _ = json.NewEncoder(w).Encode(res)
  289. return
  290. }
  291. http.ServeFile(w, r, filepath.Join(base, "meta.json"))
  292. })
  293. mux.HandleFunc("/api/streams", func(w http.ResponseWriter, r *http.Request) {
  294. w.Header().Set("Content-Type", "application/json")
  295. n := recMgr.ActiveStreams()
  296. _ = json.NewEncoder(w).Encode(map[string]any{"active_sessions": n})
  297. })
  298. mux.HandleFunc("/api/demod", func(w http.ResponseWriter, r *http.Request) {
  299. if r.Method != http.MethodGet {
  300. http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
  301. return
  302. }
  303. q := r.URL.Query()
  304. freq, _ := strconv.ParseFloat(q.Get("freq"), 64)
  305. bw, _ := strconv.ParseFloat(q.Get("bw"), 64)
  306. sec, _ := strconv.Atoi(q.Get("sec"))
  307. if sec < 1 {
  308. sec = 1
  309. }
  310. if sec > 10 {
  311. sec = 10
  312. }
  313. mode := q.Get("mode")
  314. data, _, err := recMgr.DemodLive(freq, bw, mode, sec)
  315. if err != nil {
  316. http.Error(w, err.Error(), http.StatusBadRequest)
  317. return
  318. }
  319. w.Header().Set("Content-Type", "audio/wav")
  320. _, _ = w.Write(data)
  321. })
  322. }
  323. func newHTTPServer(addr string, webRoot string, h *hub, cfgPath string, cfgManager *runtime.Manager, srcMgr *sourceManager, dspUpdates chan dspUpdate, gpuState *gpuStatus, recMgr *recorder.Manager, sigSnap *signalSnapshot, eventMu *sync.RWMutex, phaseSnap *phaseSnapshot) *http.Server {
  324. mux := http.NewServeMux()
  325. registerWSHandlers(mux, h, recMgr)
  326. registerAPIHandlers(mux, cfgPath, cfgManager, srcMgr, dspUpdates, gpuState, recMgr, sigSnap, eventMu, phaseSnap)
  327. mux.Handle("/", http.FileServer(http.Dir(webRoot)))
  328. return &http.Server{Addr: addr, Handler: mux}
  329. }
  330. func shutdownServer(server *http.Server) {
  331. ctxTimeout, cancelTimeout := context.WithTimeout(context.Background(), 5*time.Second)
  332. defer cancelTimeout()
  333. _ = server.Shutdown(ctxTimeout)
  334. }