apps/plugin-rtsp
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-rtsp.git synced 2025-10-24 08:03:28 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修改API

Browse Source
This commit is contained in:
langhuihui
2021-02-26 22:01:22 +08:00
parent 0689154012
commit 7fa6d0dcce
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
main.go
View File

@@ -42,7 +42,7 @@ func init() {
} }
func runPlugin() { func runPlugin() {
http.HandleFunc("/rtsp/list", func(w http.ResponseWriter, r *http.Request) { http.HandleFunc("/api/rtsp/list", func(w http.ResponseWriter, r *http.Request) {
sse := NewSSE(w, r.Context()) sse := NewSSE(w, r.Context())
var err error var err error
for tick := time.NewTicker(time.Second); err == nil; <-tick.C { for tick := time.NewTicker(time.Second); err == nil; <-tick.C {
@@ -55,8 +55,8 @@ func runPlugin() {
err = sse.WriteJSON(info) err = sse.WriteJSON(info)
} }
}) })
http.HandleFunc("/rtsp/pull", func(w http.ResponseWriter, r *http.Request) { http.HandleFunc("/api/rtsp/pull", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Access-Control-Allow-Origin", "*") CORS(w, r)
targetURL := r.URL.Query().Get("target") targetURL := r.URL.Query().Get("target")
streamPath := r.URL.Query().Get("streamPath") streamPath := r.URL.Query().Get("streamPath")
if err := new(RTSP).PullStream(streamPath, targetURL); err == nil { if err := new(RTSP).PullStream(streamPath, targetURL); err == nil {