fix json and timestamp

Author: algertc

lib/mqtt-client.js

@@ -102,18 +102,23 @@ async function buildMqttPayload(
   isTest = false
 ) {
   if (isTest) {
-    return "This is a test MQTT notification";
+    return JSON.stringify({
+      plate_number: "TEST123",
+      camera: "Test Camera",
+      timestamp: new Date().toLocaleString(),
+      message: "This is a test MQTT notification",
+    });
   }
 
   // Get camera name and timestamp from plateData
   const cameraName =
     plateData?.camera_name || plateData?.camera || "Unknown Camera";
-  const detectionTime = plateData?.timestamp
+  const timestamp = plateData?.timestamp
     ? new Date(plateData.timestamp).toLocaleString()
     : new Date().toLocaleString();
 
   let plateDisplayName = plateNumber;
-  let tagsText = "";
+  let tags = [];
 
   // Fetch known plate info and tags
   try {
@@ -127,22 +132,31 @@ async function buildMqttPayload(
     }
 
     if (knownPlate && knownPlate.tags && knownPlate.tags.length > 0) {
-      const tagNames = knownPlate.tags.map((tag) => tag.name || tag).join(", ");
-      tagsText = `. Tags: ${tagNames}`;
+      tags = knownPlate.tags.map((tag) => tag.name || tag);
     }
   } catch (error) {
     console.error("Error fetching known plate info for MQTT:", error);
   }
 
-  // Create simple text message
-  let message = `${plateDisplayName} detected on ${cameraName} at ${detectionTime}${tagsText}`;
+  // Create JSON payload similar to Blue Iris format
+  const payload = {
+    plate_name: plateDisplayName !== plateNumber ? plateDisplayName : null,
+    plate_number: plateNumber,
+    camera: cameraName,
+    timestamp: timestamp,
+  };
+
+  // Add tags if available
+  if (tags.length > 0) {
+    payload.tags = tags;
+  }
 
   // Add custom message if provided
   if (notificationConfig.message && notificationConfig.message.trim()) {
-    message += `. ${notificationConfig.message.trim()}`;
+    payload.message = notificationConfig.message.trim();
   }
 
-  return message;
+  return JSON.stringify(payload);
 }
 
 export async function sendMqttNotification(
@@ -198,7 +212,7 @@ export async function sendMqttNotification(
       isTest
     );
 
-    // Publish message
+    // Publish message (payload is already a JSON string)
     await new Promise((resolve, reject) => {
       client.publish(brokerInfo.topic, payload, { qos: 1 }, (error) => {
         if (error) {