|
|
@@ -16,6 +16,7 @@ func init() {
|
|
|
bus.AddHandler("sql", HandleAlertsQuery)
|
|
|
bus.AddHandler("sql", GetAlertById)
|
|
|
bus.AddHandler("sql", DeleteAlertById)
|
|
|
+ bus.AddHandler("sql", GetAllAlertQueryHandler)
|
|
|
}
|
|
|
|
|
|
func GetAlertById(query *m.GetAlertByIdQuery) error {
|
|
|
@@ -32,6 +33,17 @@ func GetAlertById(query *m.GetAlertByIdQuery) error {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
+func GetAllAlertQueryHandler(query *m.GetAllAlertsQuery) error {
|
|
|
+ var alerts []m.AlertRule
|
|
|
+ err := x.Sql("select * from alert_rule").Find(&alerts)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ query.Result = alerts
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
func DeleteAlertById(cmd *m.DeleteAlertCommand) error {
|
|
|
return inTransaction(func(sess *xorm.Session) error {
|
|
|
if _, err := sess.Exec("DELETE FROM alert_rule WHERE id = ?", cmd.AlertId); err != nil {
|