From ea6c615be010e76acce10978362e0e991f50e1a4 Mon Sep 17 00:00:00 2001 From: nilo Date: Wed, 6 Nov 2024 21:29:07 -0300 Subject: [PATCH] try to inform OBS that is forbidden --- controllers/webhookController.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/controllers/webhookController.go b/controllers/webhookController.go index adb950c..6707ed8 100644 --- a/controllers/webhookController.go +++ b/controllers/webhookController.go @@ -15,7 +15,7 @@ import ( ) func KickSession(stream_name, session_id string) { - url := "localhost:8083/api/ctrl/kick_session" + url := "http://localhost:8083/api/ctrl/kick_session" values := map[string]string{"stream_name": stream_name, "session_id": session_id} @@ -110,9 +110,11 @@ func OnPubStart(c *fiber.Ctx) error { log.Printf("Start StreamName %s, UrlParam %s, SessionId %s\n", p.StreamName, p.UrlParam, p.SessionId) + // TODO: Verify if the key is correct. If not, Kick the Session. KickSession(p.StreamName, p.SessionId) + return fiber.ErrForbidden - return c.SendString("On_Pub_Start: " + string(c.Body())) + // return c.SendString("On_Pub_Start: " + string(c.Body())) } func OnPubStop(c *fiber.Ctx) error {