sv/tsun-gen3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix frong MQTT not found logs

Browse Source
This commit is contained in:
Stefan Allius
2024-05-22 22:53:52 +02:00
parent 8fc5eb3670
commit 87cc3fb205
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/mqtt.py
View File

@@ -129,8 +129,10 @@ class Mqtt(metaclass=Singleton):
def each_inverter(self, message, func_name: str): def each_inverter(self, message, func_name: str):
topic = str(message.topic) topic = str(message.topic)
node_id = topic.split('/')[1] + '/' node_id = topic.split('/')[1] + '/'
found = False
for m in Message: for m in Message:
if m.server_side and (m.node_id == node_id): if m.server_side and (m.node_id == node_id):
found = True
logger_mqtt.debug(f'Found: {node_id}') logger_mqtt.debug(f'Found: {node_id}')
fnc = getattr(m, func_name, None) fnc = getattr(m, func_name, None)
if callable(fnc): if callable(fnc):
@@ -138,7 +140,7 @@ class Mqtt(metaclass=Singleton):
else: else:
logger_mqtt.warning(f'Cmd not supported by: {node_id}') logger_mqtt.warning(f'Cmd not supported by: {node_id}')
else: if not found:
logger_mqtt.warning(f'Node_id: {node_id} 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): async def modbus_cmd(self, message, func, params=0, addr=0, val=0):