Add safeguard if EventCBs are nil

DerAndereAndi · DerAndereAndi · commit 5f91b104fe30 · 2024-06-26T10:46:18.000+02:00
diff --git a/usecases/cem/cevc/events.go b/usecases/cem/cevc/events.go
@@ -114,7 +114,9 @@ func (e *CEVC) evTimeSeriesDescriptionDataUpdate(payload spineapi.EventPayload)
 		return
 	}
 
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyDemand)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyDemand)
+	}
 
 	_, err = e.TimeSlotConstraints(payload.Entity)
 	if err != nil {
@@ -128,16 +130,18 @@ func (e *CEVC) evTimeSeriesDescriptionDataUpdate(payload spineapi.EventPayload)
 		return
 	}
 
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, DataRequestedPowerLimitsAndIncentives)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataRequestedPowerLimitsAndIncentives)
+	}
 }
 
 // the load control limit data of an EV was updated
 func (e *CEVC) evTimeSeriesDataUpdate(payload spineapi.EventPayload) {
-	if _, err := e.ChargePlan(payload.Entity); err == nil {
+	if _, err := e.ChargePlan(payload.Entity); err == nil && e.EventCB != nil {
 		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateChargePlan)
 	}
 
-	if _, err := e.ChargePlanConstraints(payload.Entity); err == nil {
+	if _, err := e.ChargePlanConstraints(payload.Entity); err == nil && e.EventCB != nil {
 		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateTimeSlotConstraints)
 	}
 }
@@ -152,19 +156,23 @@ func (e *CEVC) evIncentiveTableDescriptionDataUpdate(payload spineapi.EventPaylo
 	}
 
 	// check if we are required to update the plan
-	if e.evCheckIncentiveTableDescriptionUpdateRequired(payload.Entity) {
+	if e.evCheckIncentiveTableDescriptionUpdateRequired(payload.Entity) && e.EventCB != nil {
 		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataRequestedIncentiveTableDescription)
 	}
 }
 
 // the incentive table constraint data of an EV was updated
 func (e *CEVC) evIncentiveTableConstraintsDataUpdate(payload spineapi.EventPayload) {
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)
+	}
 }
 
 // the incentive table data of an EV was updated
 func (e *CEVC) evIncentiveTableDataUpdate(payload spineapi.EventPayload) {
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)
+	}
 }
 
 // check timeSeries descriptions if constraints element has updateRequired set to true
diff --git a/usecases/cem/evcc/events.go b/usecases/cem/evcc/events.go
@@ -116,12 +116,16 @@ func (e *EVCC) evConnected(payload spineapi.EventPayload) {
 		}
 	}
 
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, EvConnected)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, EvConnected)
+	}
 }
 
 // an EV was disconnected
 func (e *EVCC) evDisconnected(payload spineapi.EventPayload) {
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, EvDisconnected)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, EvDisconnected)
+	}
 }
 
 // the configuration key description data of an EV was updated
@@ -141,13 +145,13 @@ func (e *EVCC) evConfigurationDataUpdate(payload spineapi.EventPayload) {
 		filter := model.DeviceConfigurationKeyValueDescriptionDataType{
 			KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeCommunicationsStandard),
 		}
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCommunicationStandard)
 		}
 
 		// Scenario 3
 		filter.KeyName = util.Ptr(model.DeviceConfigurationKeyNameTypeAsymmetricChargingSupported)
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateAsymmetricChargingSupport)
 		}
 	}
@@ -156,7 +160,7 @@ func (e *EVCC) evConfigurationDataUpdate(payload spineapi.EventPayload) {
 // the operating state of an EV was updated
 func (e *EVCC) evOperatingStateDataUpdate(payload spineapi.EventPayload) {
 	if deviceDiagnosis, err := client.NewDeviceDiagnosis(e.LocalEntity, payload.Entity); err == nil {
-		if _, err := deviceDiagnosis.GetState(); err == nil {
+		if _, err := deviceDiagnosis.GetState(); err == nil && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIdentifications)
 		}
 	}
@@ -166,7 +170,7 @@ func (e *EVCC) evOperatingStateDataUpdate(payload spineapi.EventPayload) {
 func (e *EVCC) evIdentificationDataUpdate(payload spineapi.EventPayload) {
 	if evIdentification, err := client.NewIdentification(e.LocalEntity, payload.Entity); err == nil {
 		// Scenario 4
-		if evIdentification.CheckEventPayloadDataForFilter(payload.Data) {
+		if evIdentification.CheckEventPayloadDataForFilter(payload.Data) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIdentifications)
 		}
 	}
@@ -176,7 +180,7 @@ func (e *EVCC) evIdentificationDataUpdate(payload spineapi.EventPayload) {
 func (e *EVCC) evManufacturerDataUpdate(payload spineapi.EventPayload) {
 	if evDeviceClassification, err := client.NewDeviceClassification(e.LocalEntity, payload.Entity); err == nil {
 		// Scenario 5
-		if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil {
+		if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateManufacturerData)
 		}
 	}
@@ -197,7 +201,7 @@ func (e *EVCC) evElectricalPermittedValuesUpdate(payload spineapi.EventPayload)
 		filter := model.ElectricalConnectionParameterDescriptionDataType{
 			ScopeType: util.Ptr(model.ScopeTypeTypeACPowerTotal),
 		}
-		if evElectricalConnection.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if evElectricalConnection.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			// Scenario 6
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentLimits)
 		}
diff --git a/usecases/cem/evcem/events.go b/usecases/cem/evcem/events.go
@@ -87,7 +87,7 @@ func (e *EVCEM) evElectricalConnectionDescriptionDataUpdate(payload spineapi.Eve
 	}
 
 	for _, item := range data.ElectricalConnectionDescriptionData {
-		if item.ElectricalConnectionId != nil && item.AcConnectedPhases != nil {
+		if item.ElectricalConnectionId != nil && item.AcConnectedPhases != nil && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePhasesConnected)
 			return
 		}
@@ -111,19 +111,19 @@ func (e *EVCEM) evMeasurementDataUpdate(payload spineapi.EventPayload) {
 		filter := model.MeasurementDescriptionDataType{
 			ScopeType: util.Ptr(model.ScopeTypeTypeACCurrent),
 		}
-		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentPerPhase)
 		}
 
 		// Scenario 2
 		filter.ScopeType = util.Ptr(model.ScopeTypeTypeACPower)
-		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePowerPerPhase)
 		}
 
 		// Scenario 3
 		filter.ScopeType = util.Ptr(model.ScopeTypeTypeCharge)
-		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyCharged)
 		}
 	}
diff --git a/usecases/cem/evsecc/events.go b/usecases/cem/evsecc/events.go
@@ -47,18 +47,22 @@ func (e *EVSECC) evseConnected(payload spineapi.EventPayload) {
 		_, _ = evseDeviceDiagnosis.RequestState()
 	}
 
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseConnected)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseConnected)
+	}
 }
 
 // an EVSE was disconnected
 func (e *EVSECC) evseDisconnected(payload spineapi.EventPayload) {
-	e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseDisconnected)
+	if e.EventCB != nil {
+		e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseDisconnected)
+	}
 }
 
 // the manufacturer Data of an EVSE was updated
 func (e *EVSECC) evseManufacturerDataUpdate(payload spineapi.EventPayload) {
 	if evDeviceClassification, err := client.NewDeviceClassification(e.LocalEntity, payload.Entity); err == nil {
-		if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil {
+		if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateManufacturerData)
 		}
 	}
@@ -67,7 +71,7 @@ func (e *EVSECC) evseManufacturerDataUpdate(payload spineapi.EventPayload) {
 // the operating State of an EVSE was updated
 func (e *EVSECC) evseStateUpdate(payload spineapi.EventPayload) {
 	if evDeviceDiagnosis, err := client.NewDeviceDiagnosis(e.LocalEntity, payload.Entity); err == nil {
-		if _, err := evDeviceDiagnosis.GetState(); err == nil {
+		if _, err := evDeviceDiagnosis.GetState(); err == nil && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateOperatingState)
 		}
 	}
diff --git a/usecases/cem/evsoc/events.go b/usecases/cem/evsoc/events.go
@@ -62,7 +62,7 @@ func (e *EVSOC) evMeasurementDataUpdate(payload spineapi.EventPayload) {
 		filter := model.MeasurementDescriptionDataType{
 			ScopeType: util.Ptr(model.ScopeTypeTypeStateOfCharge),
 		}
-		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateStateOfCharge)
 		}
 	}
diff --git a/usecases/cem/opev/events.go b/usecases/cem/opev/events.go
@@ -85,7 +85,7 @@ func (e *OPEV) evLoadControlLimitDataUpdate(payload spineapi.EventPayload) {
 		LimitCategory: util.Ptr(model.LoadControlCategoryTypeObligation),
 		ScopeType:     util.Ptr(model.ScopeTypeTypeOverloadProtection),
 	}
-	if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+	if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)
 	}
 }
@@ -114,7 +114,7 @@ func (e *OPEV) evElectricalPermittedValuesUpdate(payload spineapi.EventPayload)
 			ElectricalConnectionId: values[0].ElectricalConnectionId,
 			ParameterId:            values[0].ParameterId,
 		}
-		if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) {
+		if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentLimits)
 		}
 	}
diff --git a/usecases/cem/oscev/events.go b/usecases/cem/oscev/events.go
@@ -43,7 +43,7 @@ func (e *OSCEV) evLoadControlLimitDataUpdate(payload spineapi.EventPayload) {
 		ScopeType:     util.Ptr(model.ScopeTypeTypeSelfConsumption),
 	}
 
-	if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+	if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)
 	}
 }
@@ -72,7 +72,7 @@ func (e *OSCEV) evElectricalPermittedValuesUpdate(payload spineapi.EventPayload)
 			ElectricalConnectionId: values[0].ElectricalConnectionId,
 			ParameterId:            values[0].ParameterId,
 		}
-		if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) {
+		if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentLimits)
 		}
 	}
diff --git a/usecases/cem/vabd/events.go b/usecases/cem/vabd/events.go
@@ -86,25 +86,25 @@ func (e *VABD) inverterMeasurementDataUpdate(payload spineapi.EventPayload) {
 		filter := model.MeasurementDescriptionDataType{
 			ScopeType: util.Ptr(model.ScopeTypeTypeACPowerTotal),
 		}
-		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePower)
 		}
 
 		// Scenario 2
 		filter.ScopeType = util.Ptr(model.ScopeTypeTypeCharge)
-		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyCharged)
 		}
 
 		// Scenario 3
 		filter.ScopeType = util.Ptr(model.ScopeTypeTypeDischarge)
-		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyDischarged)
 		}
 
 		// Scenario 4
 		filter.ScopeType = util.Ptr(model.ScopeTypeTypeStateOfCharge)
-		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateStateOfCharge)
 		}
 	}
diff --git a/usecases/cem/vapd/events.go b/usecases/cem/vapd/events.go
@@ -104,7 +104,7 @@ func (e *VAPD) inverterConfigurationDataUpdate(payload spineapi.EventPayload) {
 			KeyName:   util.Ptr(model.DeviceConfigurationKeyNameTypePeakPowerOfPVSystem),
 			ValueType: util.Ptr(model.DeviceConfigurationKeyValueTypeTypeScaledNumber),
 		}
-		if deviceConfiguration.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if deviceConfiguration.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePowerNominalPeak)
 		}
 	}
@@ -127,13 +127,13 @@ func (e *VAPD) inverterMeasurementDataUpdate(payload spineapi.EventPayload) {
 		filter := model.MeasurementDescriptionDataType{
 			ScopeType: util.Ptr(model.ScopeTypeTypeACPowerTotal),
 		}
-		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePower)
 		}
 
 		// Scenario 3
 		filter.ScopeType = util.Ptr(model.ScopeTypeTypeACYieldTotal)
-		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePVYieldTotal)
 		}
 	}
diff --git a/usecases/cs/lpc/events.go b/usecases/cs/lpc/events.go
@@ -32,7 +32,7 @@ func (e *LPC) HandleEvent(payload spineapi.EventPayload) {
 		return
 	}
 
-	if internal.IsHeartbeat(payload) {
+	if internal.IsHeartbeat(payload) && e.EventCB != nil {
 		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateHeartbeat)
 		return
 	}
@@ -146,7 +146,7 @@ func (e *LPC) loadControlLimitDataUpdate(payload spineapi.EventPayload) {
 			LimitDirection: util.Ptr(model.EnergyDirectionTypeConsume),
 			ScopeType:      util.Ptr(model.ScopeTypeTypeActivePowerLimit),
 		}
-		if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)
 		}
 	}
@@ -158,13 +158,13 @@ func (e *LPC) configurationDataUpdate(payload spineapi.EventPayload) {
 		filter := model.DeviceConfigurationKeyValueDescriptionDataType{
 			KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeConsumptionActivePowerLimit),
 		}
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeConsumptionActivePowerLimit)
 		}
 		filter = model.DeviceConfigurationKeyValueDescriptionDataType{
 			KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeDurationMinimum),
 		}
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeDurationMinimum)
 		}
 	}
diff --git a/usecases/cs/lpp/events.go b/usecases/cs/lpp/events.go
@@ -32,7 +32,7 @@ func (e *LPP) HandleEvent(payload spineapi.EventPayload) {
 		return
 	}
 
-	if internal.IsHeartbeat(payload) {
+	if internal.IsHeartbeat(payload) && e.EventCB != nil {
 		e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateHeartbeat)
 		return
 	}
@@ -146,7 +146,7 @@ func (e *LPP) loadControlLimitDataUpdate(payload spineapi.EventPayload) {
 			ScopeType:      util.Ptr(model.ScopeTypeTypeActivePowerLimit),
 			LimitDirection: util.Ptr(model.EnergyDirectionTypeProduce),
 		}
-		if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)
 		}
 	}
@@ -158,13 +158,13 @@ func (e *LPP) configurationDataUpdate(payload spineapi.EventPayload) {
 		filter := model.DeviceConfigurationKeyValueDescriptionDataType{
 			KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeProductionActivePowerLimit),
 		}
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeProductionActivePowerLimit)
 		}
 		filter = model.DeviceConfigurationKeyValueDescriptionDataType{
 			KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeDurationMinimum),
 		}
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeDurationMinimum)
 		}
 	}
diff --git a/usecases/eg/lpc/events.go b/usecases/eg/lpc/events.go
@@ -118,7 +118,7 @@ func (e *LPC) loadControlLimitDataUpdate(payload spineapi.EventPayload) {
 			LimitDirection: util.Ptr(model.EnergyDirectionTypeConsume),
 			ScopeType:      util.Ptr(model.ScopeTypeTypeActivePowerLimit),
 		}
-		if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)
 		}
 	}
@@ -140,11 +140,11 @@ func (e *LPC) configurationDataUpdate(payload spineapi.EventPayload) {
 		filter := model.DeviceConfigurationKeyValueDescriptionDataType{
 			KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeConsumptionActivePowerLimit),
 		}
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeConsumptionActivePowerLimit)
 		}
 		filter.KeyName = util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeDurationMinimum)
-		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {
+		if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {
 			e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeDurationMinimum)
 		}
 	}
diff --git a/usecases/eg/lpp/events.go b/usecases/eg/lpp/events.go
diff --git a/usecases/ma/mgcp/events.go b/usecases/ma/mgcp/events.go
diff --git a/usecases/ma/mpc/events.go b/usecases/ma/mpc/events.go
diff --git a/usecases/usecase/usecase.go b/usecases/usecase/usecase.go

Original file line number	Diff line number	Diff line change
`@@ -114,7 +114,9 @@ func (e *CEVC) evTimeSeriesDescriptionDataUpdate(payload spineapi.EventPayload)`
`114`	`114`	`return`
`115`	`115`	`}`
`116`	`116`
`117`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyDemand)`
	`117`	`+ if e.EventCB != nil {`
	`118`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyDemand)`
	`119`	`+ }`
`118`	`120`
`119`	`121`	`_, err = e.TimeSlotConstraints(payload.Entity)`
`120`	`122`	`if err != nil {`
`@@ -128,16 +130,18 @@ func (e *CEVC) evTimeSeriesDescriptionDataUpdate(payload spineapi.EventPayload)`
`128`	`130`	`return`
`129`	`131`	`}`
`130`	`132`
`131`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, DataRequestedPowerLimitsAndIncentives)`
	`133`	`+ if e.EventCB != nil {`
	`134`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, DataRequestedPowerLimitsAndIncentives)`
	`135`	`+ }`
`132`	`136`	`}`
`133`	`137`
`134`	`138`	`// the load control limit data of an EV was updated`
`135`	`139`	`func (e *CEVC) evTimeSeriesDataUpdate(payload spineapi.EventPayload) {`
`136`		`- if _, err := e.ChargePlan(payload.Entity); err == nil {`
	`140`	`+ if _, err := e.ChargePlan(payload.Entity); err == nil && e.EventCB != nil {`
`137`	`141`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateChargePlan)`
`138`	`142`	`}`
`139`	`143`
`140`		`- if _, err := e.ChargePlanConstraints(payload.Entity); err == nil {`
	`144`	`+ if _, err := e.ChargePlanConstraints(payload.Entity); err == nil && e.EventCB != nil {`
`141`	`145`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateTimeSlotConstraints)`
`142`	`146`	`}`
`143`	`147`	`}`
`@@ -152,19 +156,23 @@ func (e *CEVC) evIncentiveTableDescriptionDataUpdate(payload spineapi.EventPaylo`
`152`	`156`	`}`
`153`	`157`
`154`	`158`	`// check if we are required to update the plan`
`155`		`- if e.evCheckIncentiveTableDescriptionUpdateRequired(payload.Entity) {`
	`159`	`+ if e.evCheckIncentiveTableDescriptionUpdateRequired(payload.Entity) && e.EventCB != nil {`
`156`	`160`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataRequestedIncentiveTableDescription)`
`157`	`161`	`}`
`158`	`162`	`}`
`159`	`163`
`160`	`164`	`// the incentive table constraint data of an EV was updated`
`161`	`165`	`func (e *CEVC) evIncentiveTableConstraintsDataUpdate(payload spineapi.EventPayload) {`
`162`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)`
	`166`	`+ if e.EventCB != nil {`
	`167`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)`
	`168`	`+ }`
`163`	`169`	`}`
`164`	`170`
`165`	`171`	`// the incentive table data of an EV was updated`
`166`	`172`	`func (e *CEVC) evIncentiveTableDataUpdate(payload spineapi.EventPayload) {`
`167`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)`
	`173`	`+ if e.EventCB != nil {`
	`174`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIncentiveTable)`
	`175`	`+ }`
`168`	`176`	`}`
`169`	`177`
`170`	`178`	`// check timeSeries descriptions if constraints element has updateRequired set to true`
Original file line number	Diff line number	Diff line change
`@@ -116,12 +116,16 @@ func (e *EVCC) evConnected(payload spineapi.EventPayload) {`
`116`	`116`	`}`
`117`	`117`	`}`
`118`	`118`
`119`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, EvConnected)`
	`119`	`+ if e.EventCB != nil {`
	`120`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, EvConnected)`
	`121`	`+ }`
`120`	`122`	`}`
`121`	`123`
`122`	`124`	`// an EV was disconnected`
`123`	`125`	`func (e *EVCC) evDisconnected(payload spineapi.EventPayload) {`
`124`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, EvDisconnected)`
	`126`	`+ if e.EventCB != nil {`
	`127`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, EvDisconnected)`
	`128`	`+ }`
`125`	`129`	`}`
`126`	`130`
`127`	`131`	`// the configuration key description data of an EV was updated`
`@@ -141,13 +145,13 @@ func (e *EVCC) evConfigurationDataUpdate(payload spineapi.EventPayload) {`
`141`	`145`	`filter := model.DeviceConfigurationKeyValueDescriptionDataType{`
`142`	`146`	`KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeCommunicationsStandard),`
`143`	`147`	`}`
`144`		`- if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`148`	`+ if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`145`	`149`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCommunicationStandard)`
`146`	`150`	`}`
`147`	`151`
`148`	`152`	`// Scenario 3`
`149`	`153`	`filter.KeyName = util.Ptr(model.DeviceConfigurationKeyNameTypeAsymmetricChargingSupported)`
`150`		`- if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`154`	`+ if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`151`	`155`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateAsymmetricChargingSupport)`
`152`	`156`	`}`
`153`	`157`	`}`
`@@ -156,7 +160,7 @@ func (e *EVCC) evConfigurationDataUpdate(payload spineapi.EventPayload) {`
`156`	`160`	`// the operating state of an EV was updated`
`157`	`161`	`func (e *EVCC) evOperatingStateDataUpdate(payload spineapi.EventPayload) {`
`158`	`162`	`if deviceDiagnosis, err := client.NewDeviceDiagnosis(e.LocalEntity, payload.Entity); err == nil {`
`159`		`- if _, err := deviceDiagnosis.GetState(); err == nil {`
	`163`	`+ if _, err := deviceDiagnosis.GetState(); err == nil && e.EventCB != nil {`
`160`	`164`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIdentifications)`
`161`	`165`	`}`
`162`	`166`	`}`
`@@ -166,7 +170,7 @@ func (e *EVCC) evOperatingStateDataUpdate(payload spineapi.EventPayload) {`
`166`	`170`	`func (e *EVCC) evIdentificationDataUpdate(payload spineapi.EventPayload) {`
`167`	`171`	`if evIdentification, err := client.NewIdentification(e.LocalEntity, payload.Entity); err == nil {`
`168`	`172`	`// Scenario 4`
`169`		`- if evIdentification.CheckEventPayloadDataForFilter(payload.Data) {`
	`173`	`+ if evIdentification.CheckEventPayloadDataForFilter(payload.Data) && e.EventCB != nil {`
`170`	`174`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateIdentifications)`
`171`	`175`	`}`
`172`	`176`	`}`
`@@ -176,7 +180,7 @@ func (e *EVCC) evIdentificationDataUpdate(payload spineapi.EventPayload) {`
`176`	`180`	`func (e *EVCC) evManufacturerDataUpdate(payload spineapi.EventPayload) {`
`177`	`181`	`if evDeviceClassification, err := client.NewDeviceClassification(e.LocalEntity, payload.Entity); err == nil {`
`178`	`182`	`// Scenario 5`
`179`		`- if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil {`
	`183`	`+ if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil && e.EventCB != nil {`
`180`	`184`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateManufacturerData)`
`181`	`185`	`}`
`182`	`186`	`}`
`@@ -197,7 +201,7 @@ func (e *EVCC) evElectricalPermittedValuesUpdate(payload spineapi.EventPayload)`
`197`	`201`	`filter := model.ElectricalConnectionParameterDescriptionDataType{`
`198`	`202`	`ScopeType: util.Ptr(model.ScopeTypeTypeACPowerTotal),`
`199`	`203`	`}`
`200`		`- if evElectricalConnection.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`204`	`+ if evElectricalConnection.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`201`	`205`	`// Scenario 6`
`202`	`206`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentLimits)`
`203`	`207`	`}`
Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ func (e *EVCEM) evElectricalConnectionDescriptionDataUpdate(payload spineapi.Eve`
`87`	`87`	`}`
`88`	`88`
`89`	`89`	`for _, item := range data.ElectricalConnectionDescriptionData {`
`90`		`- if item.ElectricalConnectionId != nil && item.AcConnectedPhases != nil {`
	`90`	`+ if item.ElectricalConnectionId != nil && item.AcConnectedPhases != nil && e.EventCB != nil {`
`91`	`91`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePhasesConnected)`
`92`	`92`	`return`
`93`	`93`	`}`
`@@ -111,19 +111,19 @@ func (e *EVCEM) evMeasurementDataUpdate(payload spineapi.EventPayload) {`
`111`	`111`	`filter := model.MeasurementDescriptionDataType{`
`112`	`112`	`ScopeType: util.Ptr(model.ScopeTypeTypeACCurrent),`
`113`	`113`	`}`
`114`		`- if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`114`	`+ if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`115`	`115`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentPerPhase)`
`116`	`116`	`}`
`117`	`117`
`118`	`118`	`// Scenario 2`
`119`	`119`	`filter.ScopeType = util.Ptr(model.ScopeTypeTypeACPower)`
`120`		`- if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`120`	`+ if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`121`	`121`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePowerPerPhase)`
`122`	`122`	`}`
`123`	`123`
`124`	`124`	`// Scenario 3`
`125`	`125`	`filter.ScopeType = util.Ptr(model.ScopeTypeTypeCharge)`
`126`		`- if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`126`	`+ if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`127`	`127`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyCharged)`
`128`	`128`	`}`
`129`	`129`	`}`
Original file line number	Diff line number	Diff line change
`@@ -47,18 +47,22 @@ func (e *EVSECC) evseConnected(payload spineapi.EventPayload) {`
`47`	`47`	`_, _ = evseDeviceDiagnosis.RequestState()`
`48`	`48`	`}`
`49`	`49`
`50`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseConnected)`
	`50`	`+ if e.EventCB != nil {`
	`51`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseConnected)`
	`52`	`+ }`
`51`	`53`	`}`
`52`	`54`
`53`	`55`	`// an EVSE was disconnected`
`54`	`56`	`func (e *EVSECC) evseDisconnected(payload spineapi.EventPayload) {`
`55`		`- e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseDisconnected)`
	`57`	`+ if e.EventCB != nil {`
	`58`	`+ e.EventCB(payload.Ski, payload.Device, payload.Entity, EvseDisconnected)`
	`59`	`+ }`
`56`	`60`	`}`
`57`	`61`
`58`	`62`	`// the manufacturer Data of an EVSE was updated`
`59`	`63`	`func (e *EVSECC) evseManufacturerDataUpdate(payload spineapi.EventPayload) {`
`60`	`64`	`if evDeviceClassification, err := client.NewDeviceClassification(e.LocalEntity, payload.Entity); err == nil {`
`61`		`- if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil {`
	`65`	`+ if _, err := evDeviceClassification.GetManufacturerDetails(); err == nil && e.EventCB != nil {`
`62`	`66`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateManufacturerData)`
`63`	`67`	`}`
`64`	`68`	`}`
`@@ -67,7 +71,7 @@ func (e *EVSECC) evseManufacturerDataUpdate(payload spineapi.EventPayload) {`
`67`	`71`	`// the operating State of an EVSE was updated`
`68`	`72`	`func (e *EVSECC) evseStateUpdate(payload spineapi.EventPayload) {`
`69`	`73`	`if evDeviceDiagnosis, err := client.NewDeviceDiagnosis(e.LocalEntity, payload.Entity); err == nil {`
`70`		`- if _, err := evDeviceDiagnosis.GetState(); err == nil {`
	`74`	`+ if _, err := evDeviceDiagnosis.GetState(); err == nil && e.EventCB != nil {`
`71`	`75`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateOperatingState)`
`72`	`76`	`}`
`73`	`77`	`}`
Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ func (e *EVSOC) evMeasurementDataUpdate(payload spineapi.EventPayload) {`
`62`	`62`	`filter := model.MeasurementDescriptionDataType{`
`63`	`63`	`ScopeType: util.Ptr(model.ScopeTypeTypeStateOfCharge),`
`64`	`64`	`}`
`65`		`- if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`65`	`+ if evMeasurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`66`	`66`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateStateOfCharge)`
`67`	`67`	`}`
`68`	`68`	`}`
Original file line number	Diff line number	Diff line change
`@@ -85,7 +85,7 @@ func (e *OPEV) evLoadControlLimitDataUpdate(payload spineapi.EventPayload) {`
`85`	`85`	`LimitCategory: util.Ptr(model.LoadControlCategoryTypeObligation),`
`86`	`86`	`ScopeType: util.Ptr(model.ScopeTypeTypeOverloadProtection),`
`87`	`87`	`}`
`88`		`- if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`88`	`+ if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`89`	`89`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)`
`90`	`90`	`}`
`91`	`91`	`}`
`@@ -114,7 +114,7 @@ func (e *OPEV) evElectricalPermittedValuesUpdate(payload spineapi.EventPayload)`
`114`	`114`	`ElectricalConnectionId: values[0].ElectricalConnectionId,`
`115`	`115`	`ParameterId: values[0].ParameterId,`
`116`	`116`	`}`
`117`		`- if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) {`
	`117`	`+ if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) && e.EventCB != nil {`
`118`	`118`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentLimits)`
`119`	`119`	`}`
`120`	`120`	`}`
Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ func (e *OSCEV) evLoadControlLimitDataUpdate(payload spineapi.EventPayload) {`
`43`	`43`	`ScopeType: util.Ptr(model.ScopeTypeTypeSelfConsumption),`
`44`	`44`	`}`
`45`	`45`
`46`		`- if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`46`	`+ if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`47`	`47`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)`
`48`	`48`	`}`
`49`	`49`	`}`
`@@ -72,7 +72,7 @@ func (e *OSCEV) evElectricalPermittedValuesUpdate(payload spineapi.EventPayload)`
`72`	`72`	`ElectricalConnectionId: values[0].ElectricalConnectionId,`
`73`	`73`	`ParameterId: values[0].ParameterId,`
`74`	`74`	`}`
`75`		`- if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) {`
	`75`	`+ if ec.CheckEventPayloadDataForFilter(payload.Data, filter1) && e.EventCB != nil {`
`76`	`76`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateCurrentLimits)`
`77`	`77`	`}`
`78`	`78`	`}`
Original file line number	Diff line number	Diff line change
`@@ -86,25 +86,25 @@ func (e *VABD) inverterMeasurementDataUpdate(payload spineapi.EventPayload) {`
`86`	`86`	`filter := model.MeasurementDescriptionDataType{`
`87`	`87`	`ScopeType: util.Ptr(model.ScopeTypeTypeACPowerTotal),`
`88`	`88`	`}`
`89`		`- if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`89`	`+ if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`90`	`90`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePower)`
`91`	`91`	`}`
`92`	`92`
`93`	`93`	`// Scenario 2`
`94`	`94`	`filter.ScopeType = util.Ptr(model.ScopeTypeTypeCharge)`
`95`		`- if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`95`	`+ if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`96`	`96`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyCharged)`
`97`	`97`	`}`
`98`	`98`
`99`	`99`	`// Scenario 3`
`100`	`100`	`filter.ScopeType = util.Ptr(model.ScopeTypeTypeDischarge)`
`101`		`- if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`101`	`+ if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`102`	`102`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateEnergyDischarged)`
`103`	`103`	`}`
`104`	`104`
`105`	`105`	`// Scenario 4`
`106`	`106`	`filter.ScopeType = util.Ptr(model.ScopeTypeTypeStateOfCharge)`
`107`		`- if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`107`	`+ if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`108`	`108`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateStateOfCharge)`
`109`	`109`	`}`
`110`	`110`	`}`
Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ func (e *VAPD) inverterConfigurationDataUpdate(payload spineapi.EventPayload) {`
`104`	`104`	`KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypePeakPowerOfPVSystem),`
`105`	`105`	`ValueType: util.Ptr(model.DeviceConfigurationKeyValueTypeTypeScaledNumber),`
`106`	`106`	`}`
`107`		`- if deviceConfiguration.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`107`	`+ if deviceConfiguration.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`108`	`108`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePowerNominalPeak)`
`109`	`109`	`}`
`110`	`110`	`}`
`@@ -127,13 +127,13 @@ func (e *VAPD) inverterMeasurementDataUpdate(payload spineapi.EventPayload) {`
`127`	`127`	`filter := model.MeasurementDescriptionDataType{`
`128`	`128`	`ScopeType: util.Ptr(model.ScopeTypeTypeACPowerTotal),`
`129`	`129`	`}`
`130`		`- if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`130`	`+ if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`131`	`131`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePower)`
`132`	`132`	`}`
`133`	`133`
`134`	`134`	`// Scenario 3`
`135`	`135`	`filter.ScopeType = util.Ptr(model.ScopeTypeTypeACYieldTotal)`
`136`		`- if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`136`	`+ if measurement.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`137`	`137`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdatePVYieldTotal)`
`138`	`138`	`}`
`139`	`139`	`}`
Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ func (e *LPC) HandleEvent(payload spineapi.EventPayload) {`
`32`	`32`	`return`
`33`	`33`	`}`
`34`	`34`
`35`		`- if internal.IsHeartbeat(payload) {`
	`35`	`+ if internal.IsHeartbeat(payload) && e.EventCB != nil {`
`36`	`36`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateHeartbeat)`
`37`	`37`	`return`
`38`	`38`	`}`
`@@ -146,7 +146,7 @@ func (e *LPC) loadControlLimitDataUpdate(payload spineapi.EventPayload) {`
`146`	`146`	`LimitDirection: util.Ptr(model.EnergyDirectionTypeConsume),`
`147`	`147`	`ScopeType: util.Ptr(model.ScopeTypeTypeActivePowerLimit),`
`148`	`148`	`}`
`149`		`- if lc.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`149`	`+ if lc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`150`	`150`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateLimit)`
`151`	`151`	`}`
`152`	`152`	`}`
`@@ -158,13 +158,13 @@ func (e *LPC) configurationDataUpdate(payload spineapi.EventPayload) {`
`158`	`158`	`filter := model.DeviceConfigurationKeyValueDescriptionDataType{`
`159`	`159`	`KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeConsumptionActivePowerLimit),`
`160`	`160`	`}`
`161`		`- if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`161`	`+ if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`162`	`162`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeConsumptionActivePowerLimit)`
`163`	`163`	`}`
`164`	`164`	`filter = model.DeviceConfigurationKeyValueDescriptionDataType{`
`165`	`165`	`KeyName: util.Ptr(model.DeviceConfigurationKeyNameTypeFailsafeDurationMinimum),`
`166`	`166`	`}`
`167`		`- if dc.CheckEventPayloadDataForFilter(payload.Data, filter) {`
	`167`	`+ if dc.CheckEventPayloadDataForFilter(payload.Data, filter) && e.EventCB != nil {`
`168`	`168`	`e.EventCB(payload.Ski, payload.Device, payload.Entity, DataUpdateFailsafeDurationMinimum)`
`169`	`169`	`}`
`170`	`170`	`}`