vh/NetAlertX
1
0
Fork 0
mirror of https://github.com/jokob-sk/NetAlertX.git synced 2026-04-04 17:21:23 -07:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

PLG: mqtt #1339

Browse Source 
Signed-off-by: jokob-sk <jokob.sk@gmail.com>
This commit is contained in:
jokob-sk
2025-12-11 20:45:10 +11:00
parent 4ab21f3705
commit 88904dc892
1 changed files with 19 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
front/plugins/_publisher_mqtt/mqtt.py
View File

@@ -347,7 +347,9 @@ def mqtt_create_client():
mytransport = 'tcp' # or 'websockets' mytransport = 'tcp' # or 'websockets'
def on_disconnect(mqtt_client, userdata, rc): def on_disconnect(mqtt_client, userdata, rc, properties=None, *args):
mylog('verbose', [f"[{pluginName}] MQTT disconnected: reasonCode={rc}"])
global mqtt_connected_to_broker global mqtt_connected_to_broker
@@ -562,9 +564,14 @@ def publish_notifications(db, mqtt_client):
return False return False
for notification in notifications: for notification in notifications:
# Use pre-built JSON payload if available # Use pre-built JSON payload if available in the 'JSON' column
if notification.get("Payload"): payload_str = notification["JSON"]
payload = notification["Payload"] if payload_str:
try:
payload = json.loads(payload_str) # Deserialize JSON string
except Exception as e:
mylog('minimal', [f"[{pluginName}] ⚠ ERROR decoding JSON for notification GUID {notification["GUID"]}: {e}"])
continue # skip this notification
else: else:
# fallback generic payload (like webhook does) # fallback generic payload (like webhook does)
payload = { payload = {
@@ -573,7 +580,7 @@ def publish_notifications(db, mqtt_client):
"attachments": [{ "attachments": [{
"title": "NetAlertX Notifications", "title": "NetAlertX Notifications",
"title_link": get_setting_value('REPORT_DASHBOARD_URL'), "title_link": get_setting_value('REPORT_DASHBOARD_URL'),
"text": notification.get("Text") or notification.get("HTML") or "" "text": notification["Text"] or notification["HTML"] or ""
}] }]
} }
@@ -581,13 +588,16 @@ def publish_notifications(db, mqtt_client):
payload["_meta"] = { payload["_meta"] = {
"published_at": timeNowDB(), "published_at": timeNowDB(),
"source": "NetAlertX", "source": "NetAlertX",
"notification_GUID": notification.get("GUID") "notification_GUID": notification["GUID"]
} }
# Publish to a single MQTT topic # Publish to a single MQTT topic safely
topic = f"{topic_root}/notifications/all" topic = f"{topic_root}/notifications/all"
mylog('debug', [f"[{pluginName}] Publishing notification GUID {notification.get('GUID')} to MQTT topic {topic}"]) mylog('debug', [f"[{pluginName}] Publishing notification GUID {notification["GUID"]} to MQTT topic {topic}"])
publish_mqtt(mqtt_client, topic, payload) try:
publish_mqtt(mqtt_client, topic, payload)
except Exception as e:
mylog('minimal', [f"[{pluginName}] ⚠ ERROR publishing MQTT notification GUID {notification["GUID"]}: {e}"])
return True return True