correct forwarding topic format

fablabbcn · May 13, 2024 · 7710309 · 7710309
1 parent ff64f85
commit 7710309
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/app/lib/mqtt_forwarder.rb b/app/lib/mqtt_forwarder.rb
@@ -1,5 +1,5 @@
 class MQTTForwarder
-  def initialize(client, prefix="forward/devices", suffix="readings")
+  def initialize(client)
     @client = client
     @prefix = prefix
     @suffix = suffix
@@ -13,7 +13,7 @@ def forward_reading(token, device_id, reading)
   private
 
   def topic_path(token, device_id)
-    [prefix, token, device_id, suffix].join("/")
+    ["/forward", token, "device", device_id, "readings"].join("/")
   end
 
   attr_reader :client, :prefix, :suffix