fix: edge record notify

ccfos · Aug 13, 2024 · 7c91e51 · 7c91e51
1 parent bfea83a
commit 7c91e51
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 1 deletion.
diff --git a/alert/sender/callback.go b/alert/sender/callback.go
@@ -156,8 +156,16 @@ func NotifyRecord(ctx *ctx.Context, evt *models.AlertCurEvent, channel, target,
 		noti.SetDetails(string(res))
 	}
 
+	if !ctx.IsCenter {
+		_, err := poster.PostByUrlsWithResp[int64](ctx, "/v1/n9e/notify-record", noti)
+		if err != nil {
+			logger.Errorf("add noti:%v failed, err: %v", noti, err)
+		}
+		return
+	}
+
 	if err := noti.Add(ctx); err != nil {
-		logger.Errorf("Add noti failed, err: %v", err)
+		logger.Errorf("add noti:%v failed, err: %v", noti, err)
 	}
 }
 

diff --git a/center/router/router.go b/center/router/router.go
@@ -555,6 +555,7 @@ func (rt *Router) Config(r *gin.Engine) {
 
 			service.GET("/targets-of-alert-rule", rt.targetsOfAlertRule)
 
+			service.POST("/notify-record", rt.notificationRecordAdd)
 		}
 	}
 

diff --git a/center/router/router_notification_record.go b/center/router/router_notification_record.go
@@ -33,6 +33,15 @@ type Record struct {
 	Detail   string `json:"detail"`
 }
 
+// notificationRecordAdd
+func (rt *Router) notificationRecordAdd(c *gin.Context) {
+	var req models.NotificaitonRecord
+	ginx.BindJSON(c, &req)
+	err := req.Add(rt.Ctx)
+
+	ginx.NewRender(c).Data(req.Id, err)
+}
+
 func (rt *Router) notificationRecordList(c *gin.Context) {
 	eid := ginx.UrlParamInt64(c, "eid")
 	lst, err := models.NotificaitonRecordsGetByEventId(rt.Ctx, eid)