From 2a0dc7b1144c8d8d0f8672c64ec53e71fd81e2bb Mon Sep 17 00:00:00 2001 From: nilo Date: Wed, 6 Nov 2024 19:51:05 -0300 Subject: [PATCH] implemented on_rtmp_connect --- controllers/webhookController.go | 5 +++++ routes/routes.go | 1 + 2 files changed, 6 insertions(+) diff --git a/controllers/webhookController.go b/controllers/webhookController.go index 30e18d2..f1ae528 100644 --- a/controllers/webhookController.go +++ b/controllers/webhookController.go @@ -28,6 +28,11 @@ func ServerStart(c *fiber.Ctx) error { return c.SendString("Server started: " + string(c.Body())) } +func OnRtmpConnect(c *fiber.Ctx) error { + utils.PrettyPrintJson(c.Body()) + return c.SendString("On_Rtmp_Connect: " + string(c.Body())) +} + func OnUpdate(c *fiber.Ctx) error { p := new(models.Update) if err := c.BodyParser(p); err != nil { diff --git a/routes/routes.go b/routes/routes.go index 4b1fc05..26d169a 100644 --- a/routes/routes.go +++ b/routes/routes.go @@ -24,6 +24,7 @@ func Setup(app *fiber.App) { // Webhooks app.Post("/on_server_start", controllers.ServerStart) + app.Post("/on_rtmp_connect", controllers.OnRtmpConnect) app.Post("/on_update", controllers.OnUpdate) app.Post("/on_pub_start", controllers.OnPubStart) app.Post("/on_pub_stop", controllers.OnPubStop)