From fd8fa61b34d788c9d4cbf6eb13a3417c33da77e6 Mon Sep 17 00:00:00 2001 From: andig Date: Mon, 23 Oct 2023 09:11:27 +0200 Subject: [PATCH] Publish thresholds --- core/loadpoint.go | 3 +++ core/loadpoint_api.go | 6 ++++++ 2 files changed, 9 insertions(+) diff --git a/core/loadpoint.go b/core/loadpoint.go index e400ed976..f88e9d096 100644 --- a/core/loadpoint.go +++ b/core/loadpoint.go @@ -584,6 +584,9 @@ func (lp *Loadpoint) Prepare(uiChan chan<- util.Param, pushChan chan<- push.Even lp.publish(minCurrent, lp.MinCurrent) lp.publish(maxCurrent, lp.MaxCurrent) + lp.publish("enableThreshold", lp.Enable.Threshold) + lp.publish("disableThreshold", lp.Disable.Threshold) + lp.setConfiguredPhases(lp.ConfiguredPhases) lp.publish(phasesEnabled, lp.phases) lp.publish(phasesActive, lp.activePhases()) diff --git a/core/loadpoint_api.go b/core/loadpoint_api.go index 0ef979abb..97e3a7246 100644 --- a/core/loadpoint_api.go +++ b/core/loadpoint_api.go @@ -249,8 +249,11 @@ func (lp *Loadpoint) SetEnableThreshold(threshold float64) { lp.Lock() defer lp.Unlock() + lp.log.DEBUG.Println("set enable threshold:", threshold) + if lp.Enable.Threshold != threshold { lp.Enable.Threshold = threshold + lp.publish("enableThreshold", threshold) } } @@ -266,8 +269,11 @@ func (lp *Loadpoint) SetDisableThreshold(threshold float64) { lp.Lock() defer lp.Unlock() + lp.log.DEBUG.Println("set disable threshold:", threshold) + if lp.Disable.Threshold != threshold { lp.Disable.Threshold = threshold + lp.publish("disableThreshold", threshold) } }