Add explicit skip messages on version mismatch

Author: konradkonrad

rolling-shutter/keyperimpl/shutterservice/eventtriggerregisteredprocessor.go

@@ -85,6 +85,13 @@ func (p *EventTriggerRegisteredEventProcessor) ProcessEvents(ctx context.Context
 		}
 
 		triggerDefinition := EventTriggerDefinition{}
+		if len(registryEvent.TriggerDefinition) > 0 &&
+			registryEvent.TriggerDefinition[0] != Version {
+			evLog.Log().Int64("version", int64(
+				registryEvent.TriggerDefinition[0])).Msg(
+				"skipping trigger definition with outdated version")
+			continue
+		}
 		err := triggerDefinition.UnmarshalBytes(registryEvent.TriggerDefinition)
 		if err != nil {
 			evLog.Info().Err(err).Msg("skipping invalid trigger definition")

rolling-shutter/keyperimpl/shutterservice/triggerprocessor.go

@@ -64,6 +64,13 @@ func (tp *TriggerProcessor) FetchEvents(ctx context.Context, start, end uint64)
 
 		trigger := EventTriggerDefinition{}
 		err := trigger.UnmarshalBytes(triggerRegisteredEvent.Definition)
+		if len(triggerRegisteredEvent.Definition) > 0 &&
+			triggerRegisteredEvent.Definition[0] != Version {
+			triggerLog.Log().Int64("version", int64(
+				triggerRegisteredEvent.Definition[0])).Msg(
+				"ignoring trigger definition with outdated version in database")
+			continue
+		}
 		if err != nil {
 			// This is not supposed to happen as only valid triggers are inserted into the database.
 			triggerLog.Error().Err(err).Msg("ignoring invalid trigger definition in database")