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

fix: Initialize tls_verified and properly handle when mqtt_broker is None

Browse Source
This commit is contained in:
Rigear
2026-04-19 18:04:36 -07:00
parent 093ebc2873
commit 11f749e0e9
2 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
repeater/data_acquisition/mqtt_handler.py
+2
View File
@@ -125,6 +125,8 @@ class _BrokerConnection:
self.enabled = broker.get("enabled", False)
self.retain_status = broker.get("retain_status", False)
self._tls_verified = False
if self.base_topic is None:
if self.format == "mqtt":
self.base_topic = f"meshcore/repeater/{self.node_name}"
repeater/data_acquisition/storage_collector.py
+6 -3
View File
@@ -188,20 +188,23 @@ class StorageCollector:
def record_advert(self, advert_record: dict):
self.sqlite_handler.store_advert(advert_record)
self.mqtt_handler.publish_mqtt("advert", advert_record)
if self.mqtt_handler:
self.mqtt_handler.publish_mqtt("advert", advert_record)
self._publish_to_glass(advert_record, "advert")
def record_noise_floor(self, noise_floor_dbm: float):
noise_record = {"timestamp": time.time(), "noise_floor_dbm": noise_floor_dbm}
self.sqlite_handler.store_noise_floor(noise_record)
self.mqtt_handler.publish_mqtt("noise_floor", noise_record)
if self.mqtt_handler:
self.mqtt_handler.publish_mqtt("noise_floor", noise_record)
self._publish_to_glass(noise_record, "noise_floor")
def record_crc_errors(self, count: int):
"""Record a batch of CRC errors detected since last poll."""
crc_record = {"timestamp": time.time(), "count": count}
self.sqlite_handler.store_crc_errors(crc_record)
self.mqtt_handler.publish_mqtt("crc_errors", crc_record)
if self.mqtt_handler:
self.mqtt_handler.publish_mqtt("crc_errors", crc_record)
self._publish_to_glass(crc_record, "crc_errors")
def get_crc_error_count(self, hours: int = 24) -> int: