diff --git a/pkg/apiserver/controllers/v1/alerts.go b/pkg/apiserver/controllers/v1/alerts.go index 37df23337..54239416a 100644 --- a/pkg/apiserver/controllers/v1/alerts.go +++ b/pkg/apiserver/controllers/v1/alerts.go @@ -126,6 +126,11 @@ func (c *Controller) CreateAlert(gctx *gin.Context) { return } + if err := c.DBClient.UpdateMachineLastPush(machineID); err != nil { + c.HandleDBErrors(gctx, err) + return + } + for _, alert := range input { alert.MachineID = machineID for pIdx, profile := range c.Profiles { diff --git a/pkg/database/machines.go b/pkg/database/machines.go index 893098184..340052361 100644 --- a/pkg/database/machines.go +++ b/pkg/database/machines.go @@ -107,6 +107,14 @@ func (c *Client) DeleteWatcher(name string) error { return nil } +func (c *Client) UpdateMachineLastPush(machineID string) error { + _, err := c.Ent.Machine.Update().Where(machine.MachineIdEQ(machineID)).SetLastPush(time.Now()).Save(c.CTX) + if err != nil { + return errors.Wrapf(UpdateFail, "updating machine last_push: %s", err) + } + return nil +} + func (c *Client) UpdateMachineScenarios(scenarios string, ID int) error { _, err := c.Ent.Machine.UpdateOneID(ID). SetUpdatedAt(time.Now()).