mqtt: subscribe

fooker · Mar 16, 2024 · d681fa3 · d681fa3
1 parent 5d9a40a
commit d681fa3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/interface-mqtt/src/lib.rs b/interface-mqtt/src/lib.rs
@@ -67,6 +67,9 @@ impl Interface for MQTT<'_> {
         for input in introspection.inputs.values() {
             let topic = realm.topic(format!("input/{}/set", input.name));
             topics.insert(topic, input);
+
+            client.subscribe(topic.to_owned(), QoS::AtLeastOnce).await?;
+            eprintln!("⇄ Subscribed to '{}' for input '{}' with type {}", topic, input.name, input.value_type);
         }
 
         while let Ok(event) = event_loop.poll().await {