Update DemoCEM

- Set default values for LPCServer
- Properly register RemoteSKI
- Add console logging

Author: DerAndereAndi

cmd/democem/democem.go

@@ -1,6 +1,10 @@
 package democem
 
 import (
+	"fmt"
+	"time"
+
+	"github.com/enbility/cemd/api"
 	"github.com/enbility/cemd/cem"
 	"github.com/enbility/cemd/ucevsecc"
 	"github.com/enbility/cemd/uclpcserver"
@@ -10,13 +14,16 @@ import (
 
 type DemoCem struct {
 	cem *cem.Cem
+
+	remoteSki string
 }
 
-func NewDemoCem(configuration *eebusapi.Configuration) *DemoCem {
-	demo := &DemoCem{}
+func NewDemoCem(configuration *eebusapi.Configuration, remoteSki string) *DemoCem {
+	demo := &DemoCem{
+		remoteSki: remoteSki,
+	}
 
-	noLogging := &logging.NoLogging{}
-	demo.cem = cem.NewCEM(configuration, demo, demo.deviceEventCB, noLogging)
+	demo.cem = cem.NewCEM(configuration, demo, demo.deviceEventCB, demo)
 
 	return demo
 }
@@ -29,10 +36,77 @@ func (d *DemoCem) Setup() error {
 	lpcs := uclpcserver.NewUCLPC(d.cem.Service, d.entityEventCB)
 	d.cem.AddUseCase(lpcs)
 
+	if err := lpcs.SetLoadControlLimit(api.LoadLimit{
+		IsChangeable: true,
+		IsActive:     false,
+		Value:        0,
+	}); err != nil {
+		logging.Log().Debug(err)
+	}
+	if err := lpcs.SetContractualConsumptionNominalMax(22000); err != nil {
+		logging.Log().Debug(err)
+	}
+	if err := lpcs.SetFailsafeConsumptionActivePowerLimit(4300, true); err != nil {
+		logging.Log().Debug(err)
+	}
+	if err := lpcs.SetFailsafeDurationMinimum(time.Hour*2, true); err != nil {
+		logging.Log().Debug(err)
+	}
+
 	evsecc := ucevsecc.NewUCEVSECC(d.cem.Service, d.entityEventCB)
 	d.cem.AddUseCase(evsecc)
 
+	d.cem.Service.RegisterRemoteSKI(d.remoteSki, true)
+
 	d.cem.Start()
 
 	return nil
 }
+
+// Logging interface
+
+func (d *DemoCem) Trace(args ...interface{}) {
+	d.print("TRACE", args...)
+}
+
+func (d *DemoCem) Tracef(format string, args ...interface{}) {
+	d.printFormat("TRACE", format, args...)
+}
+
+func (d *DemoCem) Debug(args ...interface{}) {
+	d.print("DEBUG", args...)
+}
+
+func (d *DemoCem) Debugf(format string, args ...interface{}) {
+	d.printFormat("DEBUG", format, args...)
+}
+
+func (d *DemoCem) Info(args ...interface{}) {
+	d.print("INFO ", args...)
+}
+
+func (d *DemoCem) Infof(format string, args ...interface{}) {
+	d.printFormat("INFO ", format, args...)
+}
+
+func (d *DemoCem) Error(args ...interface{}) {
+	d.print("ERROR", args...)
+}
+
+func (d *DemoCem) Errorf(format string, args ...interface{}) {
+	d.printFormat("ERROR", format, args...)
+}
+
+func (d *DemoCem) currentTimestamp() string {
+	return time.Now().Format("2006-01-02 15:04:05")
+}
+
+func (d *DemoCem) print(msgType string, args ...interface{}) {
+	value := fmt.Sprintln(args...)
+	fmt.Printf("%s %s %s", d.currentTimestamp(), msgType, value)
+}
+
+func (d *DemoCem) printFormat(msgType, format string, args ...interface{}) {
+	value := fmt.Sprintf(format, args...)
+	fmt.Println(d.currentTimestamp(), msgType, value)
+}

cmd/main.go

@@ -16,6 +16,7 @@ import (
 	"github.com/enbility/cemd/cmd/democem"
 	eebusapi "github.com/enbility/eebus-go/api"
 	"github.com/enbility/ship-go/cert"
+	"github.com/enbility/ship-go/mdns"
 	"github.com/enbility/spine-go/model"
 )
 
@@ -65,10 +66,10 @@ func main() {
 	}
 
 	configuration, err := eebusapi.NewConfiguration(
-		"Demo",
-		"Demo",
-		"HEMS",
-		"123456789",
+		"eSystems",
+		"eSystems",
+		"Wallbox",
+		"00000573",
 		model.DeviceTypeTypeEnergyManagementSystem,
 		[]model.EntityTypeType{model.EntityTypeTypeCEM},
 		*port,
@@ -80,13 +81,17 @@ func main() {
 		return
 	}
 
+	configuration.SetAlternateIdentifier("eSystems-Wallbox-00000573")
+	configuration.SetMdnsProviderSelection(mdns.MdnsProviderSelectionGoZeroConfOnly)
+
 	if iface != nil && *iface != "" {
 		ifaces := []string{*iface}
 
 		configuration.SetInterfaces(ifaces)
 	}
 
-	demo := democem.NewDemoCem(configuration)
+	demo := democem.NewDemoCem(configuration, *remoteSki)
+
 	if err := demo.Setup(); err != nil {
 		fmt.Println("Error setting up cem: ", err)
 		return