From bac3d4ea7a6e6e020585960414a9889cdc39a9bf Mon Sep 17 00:00:00 2001
From: Autumn <git@autumnfo.rest>
Date: Tue, 12 May 2026 21:27:55 +0100
Subject: [app] fixed MQTT listener

---
 src/lib/mqtt.ts | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'src/lib/mqtt.ts')

diff --git a/src/lib/mqtt.ts b/src/lib/mqtt.ts
index f7dd82c..71ba553 100644
--- a/src/lib/mqtt.ts
+++ b/src/lib/mqtt.ts
@@ -47,7 +47,9 @@ export async function addListener(topic, callback) {
 
     // todo: error handling
 
-    client.on("message", (_, message) => {
+    client.on("message", (receivedTopic, message) => {
+        if (receivedTopic !== mqttTopic) return
+
         callback(message)
     })
 }
-- 
cgit v1.3