Merge branch 'release/v0.6.1'

DerAndereAndi · DerAndereAndi · commit 68c6bcc2aebb · 2024-07-16T17:54:05.000+02:00
diff --git a/go.mod b/go.mod
@@ -4,7 +4,7 @@ go 1.21.1
 
 require (
 	github.com/ahmetb/go-linq/v3 v3.2.0
-	github.com/enbility/ship-go v0.5.1
+	github.com/enbility/ship-go v0.5.2
 	github.com/golanguzb70/lrucache v1.2.0
 	github.com/google/go-cmp v0.6.0
 	github.com/rickb777/date v1.20.6
diff --git a/go.sum b/go.sum
@@ -2,8 +2,8 @@ github.com/ahmetb/go-linq/v3 v3.2.0 h1:BEuMfp+b59io8g5wYzNoFe9pWPalRklhlhbiU3hYZ
 github.com/ahmetb/go-linq/v3 v3.2.0/go.mod h1:haQ3JfOeWK8HpVxMtHHEMPVgBKiYyQ+f1/kLZh/cj9U=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/enbility/ship-go v0.5.1 h1:8Vax1MpyI/C+kQlMFAzQ7/h/xJ7fuumSLJy9FYgEkcE=
-github.com/enbility/ship-go v0.5.1/go.mod h1:jewJWYQ10jNhsnhS1C4jESx3CNmDa5HNWZjBhkTug5Y=
+github.com/enbility/ship-go v0.5.2 h1:T9+YuP5ZpofKd463PLKq78fAaPAcGMnRAcv8c8aD5yU=
+github.com/enbility/ship-go v0.5.2/go.mod h1:jewJWYQ10jNhsnhS1C4jESx3CNmDa5HNWZjBhkTug5Y=
 github.com/golanguzb70/lrucache v1.2.0 h1:VjpjmB4VTf9VXBtZTJGcgcN0CNFM5egDrrSjkGyQOlg=
 github.com/golanguzb70/lrucache v1.2.0/go.mod h1:zc2GD26KwGEDdTHsCCTcJorv/11HyKwQVS9gqg2bizc=
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
diff --git a/spine/feature_local_test.go b/spine/feature_local_test.go
@@ -44,8 +44,8 @@ func (s *LocalFeatureTestSuite) BeforeTest(suiteName, testName string) {
 	_, s.localServerFeatureWrite = createLocalFeatures(s.localEntity, s.subFeatureType, s.serverWriteFunction)
 
 	remoteDevice := createRemoteDevice(s.localDevice, s.senderMock)
-	s.remoteFeature, s.remoteServerFeature = createRemoteEntityAndFeature(remoteDevice, 1, s.featureType)
-	s.remoteSubFeature, _ = createRemoteEntityAndFeature(remoteDevice, 2, s.subFeatureType)
+	s.remoteFeature, s.remoteServerFeature = createRemoteEntityAndFeature(remoteDevice, 1, s.featureType, s.function)
+	s.remoteSubFeature, _ = createRemoteEntityAndFeature(remoteDevice, 2, s.subFeatureType, s.serverWriteFunction)
 }
 
 func (s *LocalFeatureTestSuite) TestDeviceClassification_Functions() {
diff --git a/spine/function_data_cmd.go b/spine/function_data_cmd.go
@@ -62,23 +62,23 @@ func (r *FunctionDataCmd[T]) NotifyOrWriteCmdType(deleteSelector, partialSelecto
 }
 
 func filtersForSelectorsElements(functionType model.FunctionType, filters []model.FilterType, deleteSelector, partialSelector any, deleteElements, readElements any) []model.FilterType {
-	if deleteSelector != nil || deleteElements != nil {
+	if !util.IsNil(deleteSelector) || !util.IsNil(deleteElements) {
 		filter := model.FilterType{CmdControl: &model.CmdControlType{Delete: &model.ElementTagType{}}}
-		if deleteSelector != nil {
+		if !util.IsNil(deleteSelector) {
 			filter = addSelectorToFilter(filter, functionType, &deleteSelector)
 		}
-		if deleteElements != nil {
+		if !util.IsNil(deleteElements) {
 			filter = addElementToFilter(filter, functionType, &deleteElements)
 		}
 		filters = append(filters, filter)
 	}
 
-	if partialSelector != nil || readElements != nil {
+	if !util.IsNil(partialSelector) || !util.IsNil(readElements) {
 		filter := model.FilterType{CmdControl: &model.CmdControlType{Partial: &model.ElementTagType{}}}
-		if partialSelector != nil {
+		if !util.IsNil(partialSelector) {
 			filter = addSelectorToFilter(filter, functionType, partialSelector)
 		}
-		if readElements != nil {
+		if !util.IsNil(readElements != nil) {
 			filter = addElementToFilter(filter, functionType, readElements)
 		}
 		filters = append(filters, filter)
diff --git a/spine/helper_test.go b/spine/helper_test.go
@@ -197,12 +197,22 @@ func createRemoteDevice(localDevice *DeviceLocal, sender api.SenderInterface) *D
 	return remoteDevice
 }
 
-func createRemoteEntityAndFeature(remoteDevice *DeviceRemote, entityId uint, featureType model.FeatureTypeType) (api.FeatureRemoteInterface, api.FeatureRemoteInterface) {
+func createRemoteEntityAndFeature(remoteDevice *DeviceRemote, entityId uint, featureType model.FeatureTypeType, functionType model.FunctionType) (api.FeatureRemoteInterface, api.FeatureRemoteInterface) {
 	remoteEntity := NewEntityRemote(remoteDevice, model.EntityTypeTypeEVSE, []model.AddressEntityType{model.AddressEntityType(entityId)})
 	remoteDevice.AddEntity(remoteEntity)
 	remoteFeature := NewFeatureRemote(remoteEntity.NextFeatureId(), remoteEntity, featureType, model.RoleTypeClient)
 	remoteEntity.AddFeature(remoteFeature)
 	remoteServerFeature := NewFeatureRemote(remoteEntity.NextFeatureId(), remoteEntity, featureType, model.RoleTypeServer)
+	remoteServerFeature.SetOperations([]model.FunctionPropertyType{
+		{
+			Function: util.Ptr(functionType),
+			PossibleOperations: &model.PossibleOperationsType{
+				Read: &model.PossibleOperationsReadType{
+					Partial: &model.ElementTagType{},
+				},
+			},
+		},
+	})
 	remoteEntity.AddFeature(remoteServerFeature)
 
 	return remoteFeature, remoteServerFeature
diff --git a/spine/nodemanagement_test.go b/spine/nodemanagement_test.go
@@ -21,7 +21,7 @@ func TestNodemanagement_BindingCalls(t *testing.T) {
 	_, serverFeature := createLocalFeatures(localEntity, featureType, "")
 
 	remoteDevice := createRemoteDevice(localDevice, senderMock)
-	clientFeature, _ := createRemoteEntityAndFeature(remoteDevice, bindingEntityId, featureType)
+	clientFeature, _ := createRemoteEntityAndFeature(remoteDevice, bindingEntityId, featureType, "")
 
 	senderMock.On("Reply", mock.Anything, mock.Anything, mock.Anything).Run(func(args mock.Arguments) {
 		cmd := args.Get(2).(model.CmdType)
@@ -94,7 +94,7 @@ func TestNodemanagement_SubscriptionCalls(t *testing.T) {
 	_, serverFeature := createLocalFeatures(localEntity, featureType, "")
 
 	remoteDevice := createRemoteDevice(localDevice, senderMock)
-	clientFeature, _ := createRemoteEntityAndFeature(remoteDevice, subscriptionEntityId, featureType)
+	clientFeature, _ := createRemoteEntityAndFeature(remoteDevice, subscriptionEntityId, featureType, "")
 
 	senderMock.On("Reply", mock.Anything, mock.Anything, mock.Anything).Run(func(args mock.Arguments) {
 		cmd := args.Get(2).(model.CmdType)
diff --git a/util/helper.go b/util/helper.go
@@ -2,10 +2,27 @@ package util
 
 import (
 	"encoding/json"
+	"reflect"
 )
 
 // quick way to a struct into another
 func DeepCopy[A any](source, dest A) {
 	byt, _ := json.Marshal(source)
 	_ = json.Unmarshal(byt, dest)
 }
+
+// checck if a value is nil for any type
+func IsNil(data any) bool {
+	if data == nil {
+		return true
+	}
+	switch reflect.TypeOf(data).Kind() {
+	case reflect.Ptr,
+		reflect.Map,
+		reflect.Array,
+		reflect.Chan,
+		reflect.Slice:
+		return reflect.ValueOf(data).IsNil()
+	}
+	return false
+}

Original file line number	Diff line number	Diff line change
`@@ -44,8 +44,8 @@ func (s *LocalFeatureTestSuite) BeforeTest(suiteName, testName string) {`
`44`	`44`	`_, s.localServerFeatureWrite = createLocalFeatures(s.localEntity, s.subFeatureType, s.serverWriteFunction)`
`45`	`45`
`46`	`46`	`remoteDevice := createRemoteDevice(s.localDevice, s.senderMock)`
`47`		`- s.remoteFeature, s.remoteServerFeature = createRemoteEntityAndFeature(remoteDevice, 1, s.featureType)`
`48`		`- s.remoteSubFeature, _ = createRemoteEntityAndFeature(remoteDevice, 2, s.subFeatureType)`
	`47`	`+ s.remoteFeature, s.remoteServerFeature = createRemoteEntityAndFeature(remoteDevice, 1, s.featureType, s.function)`
	`48`	`+ s.remoteSubFeature, _ = createRemoteEntityAndFeature(remoteDevice, 2, s.subFeatureType, s.serverWriteFunction)`
`49`	`49`	`}`
`50`	`50`
`51`	`51`	`func (s *LocalFeatureTestSuite) TestDeviceClassification_Functions() {`
Original file line number	Diff line number	Diff line change
`@@ -62,23 +62,23 @@ func (r *FunctionDataCmd[T]) NotifyOrWriteCmdType(deleteSelector, partialSelecto`
`62`	`62`	`}`
`63`	`63`
`64`	`64`	`func filtersForSelectorsElements(functionType model.FunctionType, filters []model.FilterType, deleteSelector, partialSelector any, deleteElements, readElements any) []model.FilterType {`
`65`		`- if deleteSelector != nil \|\| deleteElements != nil {`
	`65`	`+ if !util.IsNil(deleteSelector) \|\| !util.IsNil(deleteElements) {`
`66`	`66`	`filter := model.FilterType{CmdControl: &model.CmdControlType{Delete: &model.ElementTagType{}}}`
`67`		`- if deleteSelector != nil {`
	`67`	`+ if !util.IsNil(deleteSelector) {`
`68`	`68`	`filter = addSelectorToFilter(filter, functionType, &deleteSelector)`
`69`	`69`	`}`
`70`		`- if deleteElements != nil {`
	`70`	`+ if !util.IsNil(deleteElements) {`
`71`	`71`	`filter = addElementToFilter(filter, functionType, &deleteElements)`
`72`	`72`	`}`
`73`	`73`	`filters = append(filters, filter)`
`74`	`74`	`}`
`75`	`75`
`76`		`- if partialSelector != nil \|\| readElements != nil {`
	`76`	`+ if !util.IsNil(partialSelector) \|\| !util.IsNil(readElements) {`
`77`	`77`	`filter := model.FilterType{CmdControl: &model.CmdControlType{Partial: &model.ElementTagType{}}}`
`78`		`- if partialSelector != nil {`
	`78`	`+ if !util.IsNil(partialSelector) {`
`79`	`79`	`filter = addSelectorToFilter(filter, functionType, partialSelector)`
`80`	`80`	`}`
`81`		`- if readElements != nil {`
	`81`	`+ if !util.IsNil(readElements != nil) {`
`82`	`82`	`filter = addElementToFilter(filter, functionType, readElements)`
`83`	`83`	`}`
`84`	`84`	`filters = append(filters, filter)`