diff options
| author | Autumn <git@autumnfo.rest> | 2026-05-12 21:27:55 +0100 |
|---|---|---|
| committer | Autumn <git@autumnfo.rest> | 2026-05-12 21:27:55 +0100 |
| commit | bac3d4ea7a6e6e020585960414a9889cdc39a9bf (patch) | |
| tree | cb051c8caed6b1d08e90b0b8a762242cdf04b272 /src/lib/mqtt.ts | |
| parent | 3a2f938cfdfbd130db51ae64acf67e66b955a27f (diff) | |
[app] fixed MQTT listener
Diffstat (limited to 'src/lib/mqtt.ts')
| -rw-r--r-- | src/lib/mqtt.ts | 4 |
1 files changed, 3 insertions, 1 deletions
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) }) } |