nilopaim
/
apifiber
1
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

errors verification

main
nilo 2024-11-06 21:15:18 -03:00
parent dfa9f807c0
commit 01913bac2d
2 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
controllers/webhookController.go
View File

@ -14,20 +14,21 @@ import (
"github.com/gofiber/fiber/v2" "github.com/gofiber/fiber/v2"
) )
func KickSession(strean_name, session_id string) { func KickSession(stream_name, session_id string) {
url := "localhost:8083/api/ctrl/kick_session" url := "localhost:8083/api/ctrl/kick_session"
values := map[string]string{"stream_name": strean_name, "session_id": session_id} values := map[string]string{"stream_name": stream_name, "session_id": session_id}
jsonValue, _ := json.Marshal(values)
jsonValue, err := json.Marshal(values)
if err != nil {
log.Printf("Error Marshall KickSession: %s\n", err)
}
resp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonValue)) resp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonValue))
if err != nil {
log.Printf("Error Post KickSession: %s\n", err)
}
log.Printf("KickSession status code: %d\n", resp.StatusCode) log.Printf("KickSession status code: %d\n", resp.StatusCode)
if err != nil {
panic(err)
}
} }
func ServerStart(c *fiber.Ctx) error { func ServerStart(c *fiber.Ctx) error {
@ -107,9 +108,9 @@ func OnPubStart(c *fiber.Ctx) error {
return err return err
} }
log.Printf("Start channel %s, urlParam %s, SessionId %s\n", p.Channel, p.UrlParam, p.SessionId) log.Printf("Start StreamName %s, UrlParam %s, SessionId %s\n", p.StreamName, p.UrlParam, p.SessionId)
KickSession(p.Channel, p.SessionId) KickSession(p.StreamName, p.SessionId)
return c.SendString("On_Pub_Start: " + string(c.Body())) return c.SendString("On_Pub_Start: " + string(c.Body()))
} }
@ -122,7 +123,7 @@ func OnPubStop(c *fiber.Ctx) error {
if err := c.BodyParser(p); err != nil { if err := c.BodyParser(p); err != nil {
return err return err
} }
log.Printf("Stop %s\n", p.Channel) log.Printf("Stop Channel %s\n", p.StreamName)
return c.SendString("On_Pub_Stop: " + string(c.Body())) return c.SendString("On_Pub_Stop: " + string(c.Body()))
} }

2
models/webhooks.go
View File

@ -18,7 +18,7 @@ type Pub struct {
RemoteAddress string `json:"remotet_addr"` RemoteAddress string `json:"remotet_addr"`
Url string `json:"url"` Url string `json:"url"`
AppName string `json:"app_name"` AppName string `json:"app_name"`
Channel string `json:"stream_name"` StreamName string `json:"stream_name"`
UrlParam string `json:"url_param"` UrlParam string `json:"url_param"`
HasInSession bool `json:"has_in_session"` HasInSession bool `json:"has_in_session"`
HasOutSession bool `json:"has_out_session"` HasOutSession bool `json:"has_out_session"`