diff --git a/controllers/webhookController.go b/controllers/webhookController.go index 5b74463..adb950c 100644 --- a/controllers/webhookController.go +++ b/controllers/webhookController.go @@ -14,20 +14,21 @@ import ( "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" - values := map[string]string{"stream_name": strean_name, "session_id": session_id} - - jsonValue, _ := json.Marshal(values) + values := map[string]string{"stream_name": stream_name, "session_id": session_id} + 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)) + if err != nil { + log.Printf("Error Post KickSession: %s\n", err) + } log.Printf("KickSession status code: %d\n", resp.StatusCode) - - if err != nil { - panic(err) - } } func ServerStart(c *fiber.Ctx) error { @@ -107,9 +108,9 @@ func OnPubStart(c *fiber.Ctx) error { 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())) } @@ -122,7 +123,7 @@ func OnPubStop(c *fiber.Ctx) error { if err := c.BodyParser(p); err != nil { 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())) } diff --git a/models/webhooks.go b/models/webhooks.go index b4c28c1..d4bcae3 100644 --- a/models/webhooks.go +++ b/models/webhooks.go @@ -18,7 +18,7 @@ type Pub struct { RemoteAddress string `json:"remotet_addr"` Url string `json:"url"` AppName string `json:"app_name"` - Channel string `json:"stream_name"` + StreamName string `json:"stream_name"` UrlParam string `json:"url_param"` HasInSession bool `json:"has_in_session"` HasOutSession bool `json:"has_out_session"`