zabbix/zabbix-agent2-plugin-onvif
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: 重命名 callback

Browse Source
This commit is contained in:
Liam Chan 2024-08-26 14:31:36 +08:00
parent 2a1852188e
commit a6cc98a32b
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
router/handler/onvif/subscription.go
View File

@ -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(&notify)

4
router/router.go
View File

@ -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)
}
}