feat(notify): enable watching user in keystone

pkg/notify/models/receiver.go

@@ -866,6 +866,9 @@ func (rm *SReceiverManager) OnUpdate(oldObj, newObj *jsonutils.JSONDict) {
 		log.Errorf("fail to FetchByIDs: %v", err)
 		return
 	}
+	if len(receivers) == 0 {
+		return
+	}
 	receiver := &receivers[0]
 	uname, _ := newObj.GetString("name")
 	domainId, _ := newObj.GetString("domain_id")
@@ -889,6 +892,9 @@ func (rm *SReceiverManager) OnDelete(obj *jsonutils.JSONDict) {
 		log.Errorf("fail to FetchByIDs: %v", err)
 		return
 	}
+	if len(receivers) == 0 {
+		return
+	}
 	receiver := &receivers[0]
 	err = receiver.Delete(context.Background(), auth.GetAdminSession(context.Background(), "", "").GetToken())
 	if err != nil {

pkg/notify/service/service.go

@@ -58,6 +58,11 @@ func StartService() {
 	db.EnsureAppInitSyncDB(applicaion, dbOpts, models.InitDB)
 	defer cloudcommon.CloseDB()
 
+	err := models.ReceiverManager.StartWatchUserInKeystone()
+	if err != nil {
+		log.Logger().Panic(err.Error())
+	}
+
 	// init notify service
 	models.NotifyService = rpc.NewSRpcService(opts.SocketFileDir, models.ConfigManager, models.TemplateManager)
 	models.NotifyService.InitAll()