adam/pyMC_Repeater
1
0
Fork 0
mirror of https://github.com/pyMC-dev/pyMC_Repeater.git synced 2026-08-06 08:53:46 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: Fixed extra topic publishing to letsmesh

Browse Source
This commit is contained in:
Rigear
2026-04-21 21:21:13 -07:00
parent d318334288
commit c7b2b02316
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
repeater/data_acquisition/mqtt_handler.py
+1 -1
View File
@@ -806,7 +806,7 @@ class MeshCoreToMqttPusher:
return results
def publish_mqtt(self, subtopic: str, payload: dict, retain: bool = False, qos: int = 0):
def publish_mqtt(self, payload: dict, subtopic: str, retain: bool = False, qos: int = 0):
"""Publish message to all connected brokers"""
message = json.dumps(payload)
repeater/data_acquisition/storage_collector.py
+3 -3
View File
@@ -241,7 +241,7 @@ class StorageCollector:
def _publish_advert_sync(self, advert_record: dict):
if self.mqtt_handler:
self.mqtt_handler.publish("advert", advert_record)
self.mqtt_handler.publish_mqtt(advert_record, "advert")
self._publish_to_glass(advert_record, "advert")
def record_noise_floor(self, noise_floor_dbm: float):
@@ -263,7 +263,7 @@ class StorageCollector:
def _publish_noise_floor_sync(self, noise_record: dict):
if self.mqtt_handler:
self.mqtt_handler.publish("noise_floor", noise_record)
self.mqtt_handler.publish_mqtt(noise_record, "noise_floor")
self._publish_to_glass(noise_record, "noise_floor")
def record_crc_errors(self, count: int):
@@ -285,7 +285,7 @@ class StorageCollector:
def _publish_crc_errors_sync(self, crc_record: dict):
if self.mqtt_handler:
self.mqtt_handler.publish("crc_errors", crc_record)
self.mqtt_handler.publish_mqtt(crc_record, "crc_errors")
self._publish_to_glass(crc_record, "crc_errors")
def get_crc_error_count(self, hours: int = 24) -> int: