Wideband autonomous SDR analysis engine forked from sdr-visual-suite
Nevar pievienot vairāk kā 25 tēmas Tēmai ir jāsākas ar burtu vai ciparu, tā var saturēt domu zīmes ('-') un var būt līdz 35 simboliem gara.

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