Wideband autonomous SDR analysis engine forked from sdr-visual-suite
No puede seleccionar más de 25 temas Los temas deben comenzar con una letra o número, pueden incluir guiones ('-') y pueden tener hasta 35 caracteres de largo.

323 líneas
12KB

  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. recommend := map[string]any{
  136. "mode": policy.Mode,
  137. "intent": policy.Intent,
  138. "monitor_span_hz": policy.MonitorSpanHz,
  139. "signal_priorities": policy.SignalPriorities,
  140. "auto_record_classes": policy.AutoRecordClasses,
  141. "auto_decode_classes": policy.AutoDecodeClasses,
  142. "refinement_jobs": policy.MaxRefinementJobs,
  143. "refinement_auto_span": policy.RefinementAutoSpan,
  144. "refinement_min_span_hz": policy.RefinementMinSpanHz,
  145. "refinement_max_span_hz": policy.RefinementMaxSpanHz,
  146. }
  147. _ = json.NewEncoder(w).Encode(recommend)
  148. })
  149. mux.HandleFunc("/api/refinement", func(w http.ResponseWriter, r *http.Request) {
  150. w.Header().Set("Content-Type", "application/json")
  151. snap := phaseSnap.Snapshot()
  152. windowStats := buildWindowStats(snap.refinementInput.Windows)
  153. out := map[string]any{
  154. "plan": snap.refinementInput.Plan,
  155. "windows": snap.refinementInput.Windows,
  156. "window_stats": windowStats,
  157. "candidates": len(snap.refinementInput.Candidates),
  158. "scheduled": len(snap.refinementInput.Scheduled),
  159. "signals": len(snap.refinement.Signals),
  160. "decisions": len(snap.refinement.Decisions),
  161. "decision_summary": summarizeDecisions(snap.refinement.Decisions),
  162. }
  163. _ = json.NewEncoder(w).Encode(out)
  164. })
  165. mux.HandleFunc("/api/events", func(w http.ResponseWriter, r *http.Request) {
  166. w.Header().Set("Content-Type", "application/json")
  167. limit := 200
  168. if v := r.URL.Query().Get("limit"); v != "" {
  169. if parsed, err := strconv.Atoi(v); err == nil {
  170. limit = parsed
  171. }
  172. }
  173. var since time.Time
  174. if v := r.URL.Query().Get("since"); v != "" {
  175. if parsed, err := parseSince(v); err == nil {
  176. since = parsed
  177. } else {
  178. http.Error(w, "invalid since", http.StatusBadRequest)
  179. return
  180. }
  181. }
  182. snap := cfgManager.Snapshot()
  183. eventMu.RLock()
  184. evs, err := events.ReadRecent(snap.EventPath, limit, since)
  185. eventMu.RUnlock()
  186. if err != nil {
  187. http.Error(w, "failed to read events", http.StatusInternalServerError)
  188. return
  189. }
  190. _ = json.NewEncoder(w).Encode(evs)
  191. })
  192. mux.HandleFunc("/api/signals", func(w http.ResponseWriter, r *http.Request) {
  193. w.Header().Set("Content-Type", "application/json")
  194. if sigSnap == nil {
  195. _ = json.NewEncoder(w).Encode([]detector.Signal{})
  196. return
  197. }
  198. _ = json.NewEncoder(w).Encode(sigSnap.get())
  199. })
  200. mux.HandleFunc("/api/candidates", func(w http.ResponseWriter, r *http.Request) {
  201. w.Header().Set("Content-Type", "application/json")
  202. if sigSnap == nil {
  203. _ = json.NewEncoder(w).Encode([]pipeline.Candidate{})
  204. return
  205. }
  206. sigs := sigSnap.get()
  207. _ = json.NewEncoder(w).Encode(pipeline.CandidatesFromSignals(sigs, "tracked-signal-snapshot"))
  208. })
  209. mux.HandleFunc("/api/decoders", func(w http.ResponseWriter, r *http.Request) {
  210. w.Header().Set("Content-Type", "application/json")
  211. _ = json.NewEncoder(w).Encode(decoderKeys(cfgManager.Snapshot()))
  212. })
  213. mux.HandleFunc("/api/recordings", func(w http.ResponseWriter, r *http.Request) {
  214. if r.Method != http.MethodGet {
  215. http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
  216. return
  217. }
  218. w.Header().Set("Content-Type", "application/json")
  219. snap := cfgManager.Snapshot()
  220. list, err := recorder.ListRecordings(snap.Recorder.OutputDir)
  221. if err != nil {
  222. http.Error(w, "failed to list recordings", http.StatusInternalServerError)
  223. return
  224. }
  225. _ = json.NewEncoder(w).Encode(list)
  226. })
  227. mux.HandleFunc("/api/recordings/", func(w http.ResponseWriter, r *http.Request) {
  228. w.Header().Set("Content-Type", "application/json")
  229. id := strings.TrimPrefix(r.URL.Path, "/api/recordings/")
  230. if id == "" {
  231. http.Error(w, "missing id", http.StatusBadRequest)
  232. return
  233. }
  234. snap := cfgManager.Snapshot()
  235. base := filepath.Clean(filepath.Join(snap.Recorder.OutputDir, id))
  236. if !strings.HasPrefix(base, filepath.Clean(snap.Recorder.OutputDir)) {
  237. http.Error(w, "invalid path", http.StatusBadRequest)
  238. return
  239. }
  240. if r.URL.Path == "/api/recordings/"+id+"/audio" {
  241. http.ServeFile(w, r, filepath.Join(base, "audio.wav"))
  242. return
  243. }
  244. if r.URL.Path == "/api/recordings/"+id+"/iq" {
  245. http.ServeFile(w, r, filepath.Join(base, "signal.cf32"))
  246. return
  247. }
  248. if r.URL.Path == "/api/recordings/"+id+"/decode" {
  249. mode := r.URL.Query().Get("mode")
  250. cmd := buildDecoderMap(cfgManager.Snapshot())[mode]
  251. if cmd == "" {
  252. http.Error(w, "decoder not configured", http.StatusBadRequest)
  253. return
  254. }
  255. meta, err := recorder.ReadMeta(filepath.Join(base, "meta.json"))
  256. if err != nil {
  257. http.Error(w, "meta read failed", http.StatusInternalServerError)
  258. return
  259. }
  260. audioPath := filepath.Join(base, "audio.wav")
  261. if _, errStat := os.Stat(audioPath); errStat != nil {
  262. audioPath = ""
  263. }
  264. res, err := recorder.DecodeOnDemand(cmd, filepath.Join(base, "signal.cf32"), meta.SampleRate, audioPath)
  265. if err != nil {
  266. http.Error(w, res.Stderr, http.StatusInternalServerError)
  267. return
  268. }
  269. _ = json.NewEncoder(w).Encode(res)
  270. return
  271. }
  272. http.ServeFile(w, r, filepath.Join(base, "meta.json"))
  273. })
  274. mux.HandleFunc("/api/streams", func(w http.ResponseWriter, r *http.Request) {
  275. w.Header().Set("Content-Type", "application/json")
  276. n := recMgr.ActiveStreams()
  277. _ = json.NewEncoder(w).Encode(map[string]any{"active_sessions": n})
  278. })
  279. mux.HandleFunc("/api/demod", func(w http.ResponseWriter, r *http.Request) {
  280. if r.Method != http.MethodGet {
  281. http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
  282. return
  283. }
  284. q := r.URL.Query()
  285. freq, _ := strconv.ParseFloat(q.Get("freq"), 64)
  286. bw, _ := strconv.ParseFloat(q.Get("bw"), 64)
  287. sec, _ := strconv.Atoi(q.Get("sec"))
  288. if sec < 1 {
  289. sec = 1
  290. }
  291. if sec > 10 {
  292. sec = 10
  293. }
  294. mode := q.Get("mode")
  295. data, _, err := recMgr.DemodLive(freq, bw, mode, sec)
  296. if err != nil {
  297. http.Error(w, err.Error(), http.StatusBadRequest)
  298. return
  299. }
  300. w.Header().Set("Content-Type", "audio/wav")
  301. _, _ = w.Write(data)
  302. })
  303. }
  304. 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 {
  305. mux := http.NewServeMux()
  306. registerWSHandlers(mux, h, recMgr)
  307. registerAPIHandlers(mux, cfgPath, cfgManager, srcMgr, dspUpdates, gpuState, recMgr, sigSnap, eventMu, phaseSnap)
  308. mux.Handle("/", http.FileServer(http.Dir(webRoot)))
  309. return &http.Server{Addr: addr, Handler: mux}
  310. }
  311. func shutdownServer(server *http.Server) {
  312. ctxTimeout, cancelTimeout := context.WithTimeout(context.Background(), 5*time.Second)
  313. defer cancelTimeout()
  314. _ = server.Shutdown(ctxTimeout)
  315. }