apps/plugin-rtmp
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-rtmp.git synced 2025-10-04 23:23:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #15 from yangchao2015/v4

Browse Source 
增加RTMP流的查询接口
This commit is contained in:
dexter
2022-12-12 16:23:22 +08:00
committed by GitHub
parent 5a09e907ec e213d74c5f
commit 69b97e9be1
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
main.go
View File

@@ -3,10 +3,12 @@ package rtmp
import ( import (
"context" "context"
"net/http" "net/http"
"time"
"go.uber.org/zap" "go.uber.org/zap"
. "m7s.live/engine/v4" . "m7s.live/engine/v4"
"m7s.live/engine/v4/config" "m7s.live/engine/v4/config"
"m7s.live/engine/v4/util"
) )
type RTMPConfig struct { type RTMPConfig struct {
@@ -68,6 +70,22 @@ var conf = &RTMPConfig{
} }
var RTMPPlugin = InstallPlugin(conf) var RTMPPlugin = InstallPlugin(conf)
func filterStreams() (ss []*Stream) {
Streams.RLock()
defer Streams.RUnlock()
for _, s := range Streams.Map {
switch s.Publisher.(type) {
case *RTMPReceiver, *RTMPPuller:
ss = append(ss, s)
}
}
return
}
func (*RTMPConfig) API_list(w http.ResponseWriter, r *http.Request) {
util.ReturnJson(filterStreams, time.Second, w, r)
}
func (*RTMPConfig) API_Pull(rw http.ResponseWriter, r *http.Request) { func (*RTMPConfig) API_Pull(rw http.ResponseWriter, r *http.Request) {
err := RTMPPlugin.Pull(r.URL.Query().Get("streamPath"), r.URL.Query().Get("target"), new(RTMPPuller), r.URL.Query().Has("save")) err := RTMPPlugin.Pull(r.URL.Query().Get("streamPath"), r.URL.Query().Get("target"), new(RTMPPuller), r.URL.Query().Has("save"))
if err != nil { if err != nil {