From 52b8a5bb13bc4d71323ca9f05158260e76016bf9 Mon Sep 17 00:00:00 2001 From: farmio Date: Mon, 18 Mar 2024 20:12:00 +0100 Subject: [PATCH] Remove debug logging; add comment; move up --- plugins/inputs/knx_listener/knx_listener.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/plugins/inputs/knx_listener/knx_listener.go b/plugins/inputs/knx_listener/knx_listener.go index c6c0e279cad39..f3ebf9bba35b2 100644 --- a/plugins/inputs/knx_listener/knx_listener.go +++ b/plugins/inputs/knx_listener/knx_listener.go @@ -132,6 +132,12 @@ func (kl *KNXListener) Stop() { func (kl *KNXListener) listen() { for msg := range kl.client.Inbound() { + if msg.Command == knx.GroupRead { + // Ignore GroupValue_Read requests as they would either + // - fail to unpack due to invalid data length (DPT != 1) or + // - create invalid `false` values as their data always unpacks `0` (DPT 1) + continue + } // Match GA to DataPointType and measurement name ga := msg.Destination.String() target, ok := kl.gaTargetMap[ga] @@ -142,10 +148,6 @@ func (kl *KNXListener) listen() { } continue } - if msg.Command == knx.GroupRead { - kl.Log.Debugf("Ignoring GroupRead for GA %q from %q", ga, msg.Source.String()) - continue - } // Extract the value from the data-frame err := target.datapoint.Unpack(msg.Data)