Implement new event system in object types

2026-05-28 04:35:54 -04:00 · 2019-09-16 11:00:37 +02:00 · 2019-09-16 11:00:37 +02:00 · 3dbfc8ae72
commit 3dbfc8ae72
parent 8bde33e09e
42 changed files with 43 additions and 1 deletions
--- a/configobject/objecttypes/checkcommand/checkcommand.go
+++ b/configobject/objecttypes/checkcommand/checkcommand.go
@ -87,5 +87,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "checkcommand",
 	}
 }
--- a/configobject/objecttypes/checkcommand/checkcommandargument/checkcommandargument.go
+++ b/configobject/objecttypes/checkcommand/checkcommandargument/checkcommandargument.go
@ -97,5 +97,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "checkcommand",
 	}
 }
--- a/configobject/objecttypes/checkcommand/checkcommandcustomvar/checkcommandcustomvar.go
+++ b/configobject/objecttypes/checkcommand/checkcommandcustomvar/checkcommandcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "checkcommand",
 	}
 }
--- a/configobject/objecttypes/checkcommand/checkcommandenvvar/checkcommandenvvar.go
+++ b/configobject/objecttypes/checkcommand/checkcommandenvvar/checkcommandenvvar.go
@ -76,5 +76,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "checkcommand",
 	}
 }
--- a/configobject/objecttypes/endpoint/endpoint.go
+++ b/configobject/objecttypes/endpoint/endpoint.go
@ -81,5 +81,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "endpoint",
 	}
 }
--- a/configobject/objecttypes/eventcommand/eventcommand.go
+++ b/configobject/objecttypes/eventcommand/eventcommand.go
@ -87,5 +87,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "eventcommand",
 	}
 }
--- a/configobject/objecttypes/eventcommand/eventcommandargument/eventcommandargument.go
+++ b/configobject/objecttypes/eventcommand/eventcommandargument/eventcommandargument.go
@ -97,5 +97,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "eventcommand",
 	}
 }
--- a/configobject/objecttypes/eventcommand/eventcommandcustomvar/eventcommandcustomvar.go
+++ b/configobject/objecttypes/eventcommand/eventcommandcustomvar/eventcommandcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "eventcommand",
 	}
 }
--- a/configobject/objecttypes/eventcommand/eventcommandenvvar/eventcommandenvvar.go
+++ b/configobject/objecttypes/eventcommand/eventcommandenvvar/eventcommandenvvar.go
@ -76,5 +76,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "eventcommand",
 	}
 }
--- a/configobject/objecttypes/host/host.go
+++ b/configobject/objecttypes/host/host.go
@ -183,5 +183,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "host",
 	}
 }
--- a/configobject/objecttypes/host/hostcomment/hostcomment.go
+++ b/configobject/objecttypes/host/hostcomment/hostcomment.go
@ -98,5 +98,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "hostcomment",
 	}
 }
--- a/configobject/objecttypes/host/hostcustomvar/hostcustomvar.go
+++ b/configobject/objecttypes/host/hostcustomvar/hostcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "host",
 	}
 }
--- a/configobject/objecttypes/host/hostdowntime/hostdowntime.go
+++ b/configobject/objecttypes/host/hostdowntime/hostdowntime.go
@ -110,5 +110,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "hostdowntime",
 	}
 }
--- a/configobject/objecttypes/hostgroup/hostgroup.go
+++ b/configobject/objecttypes/hostgroup/hostgroup.go
@ -87,5 +87,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "hostgroup",
 	}
 }
--- a/configobject/objecttypes/hostgroup/hostgroupcustomvar/hostgroupcustomvar.go
+++ b/configobject/objecttypes/hostgroup/hostgroupcustomvar/hostgroupcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "hostgroup",
 	}
 }
--- a/configobject/objecttypes/hostgroup/hostgroupmember/hostgroupmember.go
+++ b/configobject/objecttypes/hostgroup/hostgroupmember/hostgroupmember.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "host",
 	}
 }
--- a/configobject/objecttypes/notification/notification.go
+++ b/configobject/objecttypes/notification/notification.go
@ -117,5 +117,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notification",
 	}
 }
--- a/configobject/objecttypes/notification/notificationcustomvar/notificationcustomvar.go
+++ b/configobject/objecttypes/notification/notificationcustomvar/notificationcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notification",
 	}
 }
--- a/configobject/objecttypes/notification/notificationuser/notificationuser.go
+++ b/configobject/objecttypes/notification/notificationuser/notificationuser.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notification",
 	}
 }
--- a/configobject/objecttypes/notification/notificationusergroup/notificationusergroup.go
+++ b/configobject/objecttypes/notification/notificationusergroup/notificationusergroup.go
@ -19,7 +19,7 @@ var (
 type NotificationUsergroup struct {
 	Id						string 		`json:"id"`
 	NotificationId			string		`json:"notification_id"`
-	UsergroupId	 				string 		`json:"usergroup_id"`
+	UsergroupId	 			string 		`json:"usergroup_id"`
 	EnvId           		string		`json:"env_id"`
 }

@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notification",
 	}
 }
--- a/configobject/objecttypes/notificationcommand/notificationcommand.go
+++ b/configobject/objecttypes/notificationcommand/notificationcommand.go
@ -87,5 +87,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notificationcommand",
 	}
 }
--- a/configobject/objecttypes/notificationcommand/notificationcommandargument/notificationcommandargument.go
+++ b/configobject/objecttypes/notificationcommand/notificationcommandargument/notificationcommandargument.go
@ -97,5 +97,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notificationcommand",
 	}
 }
--- a/configobject/objecttypes/notificationcommand/notificationcommandcustomvar/notificationcommandcustomvar.go
+++ b/configobject/objecttypes/notificationcommand/notificationcommandcustomvar/notificationcommandcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notificationcommand",
 	}
 }
--- a/configobject/objecttypes/notificationcommand/notificationcommandenvvar/notificationcommandenvvar.go
+++ b/configobject/objecttypes/notificationcommand/notificationcommandenvvar/notificationcommandenvvar.go
@ -76,5 +76,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "notificationcommand",
 	}
 }
--- a/configobject/objecttypes/service/service.go
+++ b/configobject/objecttypes/service/service.go
@ -174,5 +174,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "service",
 	}
 }
--- a/configobject/objecttypes/service/servicecomment/servicecomment.go
+++ b/configobject/objecttypes/service/servicecomment/servicecomment.go
@ -98,5 +98,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "servicecomment",
 	}
 }
--- a/configobject/objecttypes/service/servicecustomvar/servicecustomvar.go
+++ b/configobject/objecttypes/service/servicecustomvar/servicecustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "service",
 	}
 }
--- a/configobject/objecttypes/service/servicedowntime/servicedowntime.go
+++ b/configobject/objecttypes/service/servicedowntime/servicedowntime.go
@ -110,5 +110,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "servicedowntime",
 	}
 }
--- a/configobject/objecttypes/servicegroup/servicegroup.go
+++ b/configobject/objecttypes/servicegroup/servicegroup.go
@ -87,5 +87,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "servicegroup",
 	}
 }
--- a/configobject/objecttypes/servicegroup/servicegroupcustomvar/servicegroupcustomvar.go
+++ b/configobject/objecttypes/servicegroup/servicegroupcustomvar/servicegroupcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "servicegroup",
 	}
 }
--- a/configobject/objecttypes/servicegroup/servicegroupmember/servicegroupmember.go
+++ b/configobject/objecttypes/servicegroup/servicegroupmember/servicegroupmember.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "service",
 	}
 }
--- a/configobject/objecttypes/timeperiod/timeperiod.go
+++ b/configobject/objecttypes/timeperiod/timeperiod.go
@ -87,5 +87,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "timeperiod",
 	}
 }
--- a/configobject/objecttypes/timeperiod/timeperiodcustomvar/timeperiodcustomvar.go
+++ b/configobject/objecttypes/timeperiod/timeperiodcustomvar/timeperiodcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "timeperiod",
 	}
 }
--- a/configobject/objecttypes/timeperiod/timeperiodoverrideexclude/timeperiodoverrideexclude.go
+++ b/configobject/objecttypes/timeperiod/timeperiodoverrideexclude/timeperiodoverrideexclude.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "timeperiod",
 	}
 }
--- a/configobject/objecttypes/timeperiod/timeperiodoverrideinclude/timeperiodoverrideinclude.go
+++ b/configobject/objecttypes/timeperiod/timeperiodoverrideinclude/timeperiodoverrideinclude.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "timeperiod",
 	}
 }
--- a/configobject/objecttypes/timeperiod/timeperiodrange/timeperiodrange.go
+++ b/configobject/objecttypes/timeperiod/timeperiodrange/timeperiodrange.go
@ -73,5 +73,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "timeperiod",
 	}
 }
--- a/configobject/objecttypes/user/user.go
+++ b/configobject/objecttypes/user/user.go
@ -108,5 +108,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "user",
 	}
 }
--- a/configobject/objecttypes/user/usercustomvar/usercustomvar.go
+++ b/configobject/objecttypes/user/usercustomvar/usercustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "user",
 	}
 }
--- a/configobject/objecttypes/usergroup/usergroup.go
+++ b/configobject/objecttypes/usergroup/usergroup.go
@ -87,5 +87,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "usergroup",
 	}
 }
--- a/configobject/objecttypes/usergroup/usergroupcustomvar/usergroupcustomvar.go
+++ b/configobject/objecttypes/usergroup/usergroupcustomvar/usergroupcustomvar.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "usergroup",
 	}
 }
--- a/configobject/objecttypes/usergroup/usergroupmember/usergroupmember.go
+++ b/configobject/objecttypes/usergroup/usergroupmember/usergroupmember.go
@ -70,5 +70,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "user",
 	}
 }
--- a/configobject/objecttypes/zone/zone.go
+++ b/configobject/objecttypes/zone/zone.go
@ -90,5 +90,6 @@ func init() {
 		BulkInsertStmt: connection.NewBulkInsertStmt(name, Fields),
 		BulkDeleteStmt: connection.NewBulkDeleteStmt(name),
 		BulkUpdateStmt: connection.NewBulkUpdateStmt(name, Fields),
+		NotificationListenerType: "zone",
 	}
 }