Demo HEMS improvements

- support LPC & LPP as Energy guard and controllable system
- comment SPINE message logging

Author: DerAndereAndi

cmd/hems/main.go

@@ -15,16 +15,27 @@ import (
 
 	"github.com/enbility/eebus-go/api"
 	"github.com/enbility/eebus-go/service"
-	"github.com/enbility/eebus-go/usecases/eg/lpc"
+	ucapi "github.com/enbility/eebus-go/usecases/api"
+	"github.com/enbility/eebus-go/usecases/cs/lpc"
+	cslpc "github.com/enbility/eebus-go/usecases/cs/lpc"
+	cslpp "github.com/enbility/eebus-go/usecases/cs/lpp"
+	eglpc "github.com/enbility/eebus-go/usecases/eg/lpc"
+	eglpp "github.com/enbility/eebus-go/usecases/eg/lpp"
 	shipapi "github.com/enbility/ship-go/api"
 	"github.com/enbility/ship-go/cert"
+	spineapi "github.com/enbility/spine-go/api"
 	"github.com/enbility/spine-go/model"
 )
 
 var remoteSki string
 
 type hems struct {
 	myService *service.Service
+
+	uccslpc ucapi.CsLPCInterface
+	uccslpp ucapi.CsLPPInterface
+	uceglpc ucapi.EgLPCInterface
+	uceglpp ucapi.EgLPPInterface
 }
 
 func (h *hems) run() {
@@ -84,8 +95,14 @@ func (h *hems) run() {
 	}
 
 	localEntity := h.myService.LocalDevice().EntityForType(model.EntityTypeTypeCEM)
-	uclpc := lpc.NewLPC(localEntity, nil)
-	h.myService.AddUseCase(uclpc)
+	h.uccslpc = cslpc.NewLPC(localEntity, h.OnLPCEvent)
+	h.myService.AddUseCase(h.uccslpc)
+	h.uccslpp = cslpp.NewLPP(localEntity, h.OnLPPEvent)
+	h.myService.AddUseCase(h.uccslpp)
+	h.uceglpc = eglpc.NewLPC(localEntity, nil)
+	h.myService.AddUseCase(h.uceglpc)
+	h.uceglpp = eglpp.NewLPP(localEntity, nil)
+	h.myService.AddUseCase(h.uceglpp)
 
 	if len(remoteSki) == 0 {
 		os.Exit(0)
@@ -97,6 +114,54 @@ func (h *hems) run() {
 	// defer h.myService.Shutdown()
 }
 
+// Controllable System LPC Event Handler
+
+func (h *hems) OnLPCEvent(ski string, device spineapi.DeviceRemoteInterface, entity spineapi.EntityRemoteInterface, event api.EventType) {
+	if entity.EntityType() != model.EntityTypeTypeGridGuard {
+		return
+	}
+
+	switch event {
+	case lpc.WriteApprovalRequired:
+		// get pending writes
+		pendingWrites := h.uccslpc.PendingConsumptionLimits()
+
+		// approve any write
+		for msgCounter, write := range pendingWrites {
+			fmt.Println("Approving LPC write with msgCounter", msgCounter, "and limit", write.Value, "W")
+			h.uccslpc.ApproveOrDenyConsumptionLimit(msgCounter, true, "")
+		}
+	case lpc.DataUpdateLimit:
+		if currentLimit, err := h.uccslpc.ConsumptionLimit(); err != nil {
+			fmt.Println("New LPC Limit set to", currentLimit.Value, "W")
+		}
+	}
+}
+
+// Controllable System LPP Event Handler
+
+func (h *hems) OnLPPEvent(ski string, device spineapi.DeviceRemoteInterface, entity spineapi.EntityRemoteInterface, event api.EventType) {
+	if entity.EntityType() != model.EntityTypeTypeGridGuard {
+		return
+	}
+
+	switch event {
+	case lpc.WriteApprovalRequired:
+		// get pending writes
+		pendingWrites := h.uccslpp.PendingProductionLimits()
+
+		// approve any write
+		for msgCounter, write := range pendingWrites {
+			fmt.Println("Approving LPP write with msgCounter", msgCounter, "and limit", write.Value, "W")
+			h.uccslpp.ApproveOrDenyProductionLimit(msgCounter, true, "")
+		}
+	case lpc.DataUpdateLimit:
+		if currentLimit, err := h.uccslpp.ProductionLimit(); err != nil {
+			fmt.Println("New LPP Limit set to", currentLimit.Value, "W")
+		}
+	}
+}
+
 // EEBUSServiceHandler
 
 func (h *hems) RemoteSKIConnected(service api.ServiceInterface, ski string) {}
@@ -158,22 +223,18 @@ func main() {
 
 func (h *hems) Trace(args ...interface{}) {
 	// h.print("TRACE", args...)
-	h.print("TRACE", args...)
 }
 
 func (h *hems) Tracef(format string, args ...interface{}) {
-	// h.print("TRACE", args...)
-	h.printFormat("TRACE", format, args...)
+	// h.printFormat("TRACE", format, args...)
 }
 
 func (h *hems) Debug(args ...interface{}) {
-	// h.print("TRACE", args...)
-	h.print("DEBUG", args...)
+	// h.print("DEBUG", args...)
 }
 
 func (h *hems) Debugf(format string, args ...interface{}) {
-	// h.print("TRACE", args...)
-	h.printFormat("DEBUG", format, args...)
+	// h.printFormat("DEBUG", format, args...)
 }
 
 func (h *hems) Info(args ...interface{}) {