From a6cc98a32b0a403c2b11957aaf59621017ab6155 Mon Sep 17 00:00:00 2001 From: imbytecat Date: Mon, 26 Aug 2024 14:31:36 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E9=87=8D=E5=91=BD=E5=90=8D=20callb?= =?UTF-8?q?ack?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- router/handler/onvif/subscription.go | 8 ++++---- router/router.go | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/router/handler/onvif/subscription.go b/router/handler/onvif/subscription.go index 66f654f..f268b9f 100644 --- a/router/handler/onvif/subscription.go +++ b/router/handler/onvif/subscription.go @@ -11,10 +11,10 @@ import ( "onvif-agent/response" ) -func CreateEventSubscription(c *gin.Context) { +func CreateSubscription(c *gin.Context) { xaddr := c.Param("xaddr") callbackURL := event.AttributedURIType(fmt.Sprintf("%s/onvif/subscriptions/%s/callback", config.Config.App.URL, xaddr)) - log.Printf("CreateEventSubscription callback URL: %s", callbackURL) + log.Printf("CreateSubscription callback URL: %s", callbackURL) conn := Conns[xaddr] if conn == nil { @@ -31,9 +31,9 @@ func CreateEventSubscription(c *gin.Context) { response.NewResponse().Success().WithData(result).Send(c) } -func EventNotifyCallback(c *gin.Context) { +func NotifyCallback(c *gin.Context) { xaddr := c.Param("xaddr") - log.Printf("EventNotifyCallback from: %s", xaddr) + log.Printf("NotifyCallback from: %s", xaddr) var notify event.Notify envelope := gosoap.NewSOAPEnvelope(¬ify) diff --git a/router/router.go b/router/router.go index d78a9ba..8e827b3 100644 --- a/router/router.go +++ b/router/router.go @@ -22,8 +22,8 @@ func SetupRoutes(r *gin.Engine) { subscriptionGroup := onvifGroup.Group("/subscriptions") { - subscriptionGroup.POST("/:xaddr", onvif.CreateEventSubscription) - subscriptionGroup.POST("/:xaddr/callback", onvif.EventNotifyCallback) + subscriptionGroup.POST("/:xaddr", onvif.CreateSubscription) + subscriptionGroup.POST("/:xaddr/callback", onvif.NotifyCallback) } }