Filter usecase specific limitIds

Author: DerAndereAndi

uclpcserver/uclpc.go

@@ -52,7 +52,33 @@ func (e *UCLPCServer) loadControlWriteCB(msg *spineapi.Message) {
 	e.pendingMux.Lock()
 	defer e.pendingMux.Unlock()
 
-	if msg.RequestHeader == nil || msg.RequestHeader.MsgCounter == nil {
+	if msg.RequestHeader == nil || msg.RequestHeader.MsgCounter == nil ||
+		msg.Cmd.LoadControlLimitListData == nil {
+		return
+	}
+
+	descriptions := util.GetLocalLimitDescriptionsForTypeCategoryDirectionScope(
+		e.service,
+		model.LoadControlLimitTypeTypeSignDependentAbsValueLimit,
+		model.LoadControlCategoryTypeObligation,
+		model.EnergyDirectionTypeConsume,
+		model.ScopeTypeTypeActivePowerLimit,
+	)
+	if len(descriptions) != 1 || descriptions[0].LimitId == nil {
+		return
+	}
+	description := descriptions[0]
+
+	data := msg.Cmd.LoadControlLimitListData
+
+	if data == nil || data.LoadControlLimitData == nil || len(data.LoadControlLimitData) == 0 {
+		return
+	}
+
+	// we assume there is always only one limit
+	element := data.LoadControlLimitData[0]
+
+	if description.LimitId == nil || element.LimitId == nil || *description.LimitId != *element.LimitId {
 		return
 	}
 

uclpcserver/uclpc_test.go

@@ -1,6 +1,8 @@
 package uclpcserver
 
 import (
+	"time"
+
 	eebusutil "github.com/enbility/eebus-go/util"
 	spineapi "github.com/enbility/spine-go/api"
 	"github.com/enbility/spine-go/model"
@@ -16,6 +18,42 @@ func (s *UCLPCServerSuite) Test_loadControlWriteCB() {
 		RequestHeader: &model.HeaderType{
 			MsgCounter: eebusutil.Ptr(model.MsgCounterType(500)),
 		},
+		Cmd: model.CmdType{
+			LoadControlLimitListData: &model.LoadControlLimitListDataType{},
+		},
+	}
+
+	s.sut.loadControlWriteCB(msg)
+
+	msg.Cmd = model.CmdType{
+		LoadControlLimitListData: &model.LoadControlLimitListDataType{
+			LoadControlLimitData: []model.LoadControlLimitDataType{},
+		},
+	}
+
+	s.sut.loadControlWriteCB(msg)
+
+	msg.Cmd = model.CmdType{
+		LoadControlLimitListData: &model.LoadControlLimitListDataType{
+			LoadControlLimitData: []model.LoadControlLimitDataType{
+				{},
+			},
+		},
+	}
+
+	s.sut.loadControlWriteCB(msg)
+
+	msg.Cmd = model.CmdType{
+		LoadControlLimitListData: &model.LoadControlLimitListDataType{
+			LoadControlLimitData: []model.LoadControlLimitDataType{
+				{
+					LimitId:       eebusutil.Ptr(model.LoadControlLimitIdType(0)),
+					IsLimitActive: eebusutil.Ptr(true),
+					Value:         model.NewScaledNumberType(1000),
+					TimePeriod:    model.NewTimePeriodTypeWithRelativeEndTime(time.Minute * 2),
+				},
+			},
+		},
 	}
 
 	s.sut.loadControlWriteCB(msg)