From 87cc3fb2050afcca3ea2e70cf2f21d57afe56534 Mon Sep 17 00:00:00 2001
From: Stefan Allius <stefan.allius@t-online.de>
Date: Wed, 22 May 2024 22:53:52 +0200
Subject: [PATCH] fix frong MQTT not found logs

---
 app/src/mqtt.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/app/src/mqtt.py b/app/src/mqtt.py
index 484d7df..2ce6333 100644
--- a/app/src/mqtt.py
+++ b/app/src/mqtt.py
@@ -129,8 +129,10 @@ class Mqtt(metaclass=Singleton):
     def each_inverter(self, message, func_name: str):
         topic = str(message.topic)
         node_id = topic.split('/')[1] + '/'
+        found = False
         for m in Message:
             if m.server_side and (m.node_id == node_id):
+                found = True
                 logger_mqtt.debug(f'Found: {node_id}')
                 fnc = getattr(m, func_name, None)
                 if callable(fnc):
@@ -138,7 +140,7 @@ class Mqtt(metaclass=Singleton):
                 else:
                     logger_mqtt.warning(f'Cmd not supported by: {node_id}')
 
-        else:
+        if not found:
             logger_mqtt.warning(f'Node_id: {node_id} not found')
 
     async def modbus_cmd(self, message, func, params=0, addr=0, val=0):