fix: mqtt: remove topic check

This check will never be true, as the topic is always either screens or
screens/${id}.

Record the topic in the current span, so it's also included as fields in
log statements, and log the raw payload in case it couldn't be parsed as
a Command.

Cargo.nix

@@ -475,6 +475,43 @@ rec {
         ];
 
       };
+      "bstr" = rec {
+        crateName = "bstr";
+        version = "1.9.1";
+        edition = "2021";
+        sha256 = "01ipr5rncw3kf4dyc1p2g00njn1df2b0xpviwhb8830iv77wbvq5";
+        authors = [
+          "Andrew Gallant <jamslam@gmail.com>"
+        ];
+        dependencies = [
+          {
+            name = "memchr";
+            packageId = "memchr";
+            usesDefaultFeatures = false;
+          }
+          {
+            name = "regex-automata";
+            packageId = "regex-automata 0.4.7";
+            optional = true;
+            usesDefaultFeatures = false;
+            features = [ "dfa-search" ];
+          }
+          {
+            name = "serde";
+            packageId = "serde";
+            optional = true;
+            usesDefaultFeatures = false;
+          }
+        ];
+        features = {
+          "alloc" = [ "memchr/alloc" "serde?/alloc" ];
+          "default" = [ "std" "unicode" ];
+          "serde" = [ "dep:serde" ];
+          "std" = [ "alloc" "memchr/std" "serde?/std" ];
+          "unicode" = [ "dep:regex-automata" ];
+        };
+        resolvedDefaultFeatures = [ "alloc" "default" "std" "unicode" ];
+      };
       "byteorder" = rec {
         crateName = "byteorder";
         version = "1.5.0";
@@ -1691,6 +1728,10 @@ rec {
         ];
         src = lib.cleanSourceWith { filter = sourceFilter; src = ./.; };
         dependencies = [
+          {
+            name = "bstr";
+            packageId = "bstr";
+          }
           {
             name = "clap";
             packageId = "clap";
@@ -5022,7 +5063,7 @@ rec {
           "unicode-script" = [ "regex-syntax?/unicode-script" ];
           "unicode-segment" = [ "regex-syntax?/unicode-segment" ];
         };
-        resolvedDefaultFeatures = [ "alloc" "meta" "nfa-pikevm" "nfa-thompson" "std" "syntax" "unicode-case" "unicode-perl" "unicode-word-boundary" ];
+        resolvedDefaultFeatures = [ "alloc" "dfa-search" "meta" "nfa-pikevm" "nfa-thompson" "std" "syntax" "unicode-case" "unicode-perl" "unicode-word-boundary" ];
       };
       "regex-syntax 0.6.29" = rec {
         crateName = "regex-syntax";
@@ -5633,7 +5674,7 @@ rec {
           "derive" = [ "serde_derive" ];
           "serde_derive" = [ "dep:serde_derive" ];
         };
-        resolvedDefaultFeatures = [ "default" "derive" "serde_derive" "std" ];
+        resolvedDefaultFeatures = [ "alloc" "default" "derive" "serde_derive" "std" ];
       };
       "serde_derive" = rec {
         crateName = "serde_derive";

Cargo.toml

@@ -4,6 +4,7 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
+bstr = "1.9.1"
 clap = { version = "4.5.9", features = ["derive"] }
 color-eyre = "0.6.3"
 eyre = "0.6.12"

src/mqtt.rs

@@ -1,8 +1,8 @@
-use std::{sync::mpsc::Sender, thread, time::Duration};
-
+use bstr::BStr;
 use fossbeamer::Command;
 use rumqttc::{Client, ClientError, MqttOptions, Packet, Publish};
-use tracing::{debug, warn};
+use std::{sync::mpsc::Sender, thread, time::Duration};
+use tracing::{debug, info, warn, Span};
 
 pub(crate) struct Listener {
     pub id: String,
@@ -28,14 +28,16 @@ impl Listener {
                             payload,
                             ..
                         })) => {
-                            if topic == "commands" {
-                                if let Ok(command) = serde_json::from_slice::<Command>(&payload) {
-                                    debug!(?command, "received command");
+                            Span::current().record("topic", &topic);
+                            match serde_json::from_slice::<Command>(&payload) {
+                                Ok(command) => {
+                                    info!(?command, "received command");
 
                                     self.sender.send(command).unwrap();
                                 }
-                            } else {
-                                debug!(?topic, "received other topic");
+                                Err(e) => {
+                                    warn!(err=%e, payload=%BStr::new(&payload), "received payload that couldn't be parsed");
+                                }
                             }
                         }
                         rumqttc::Event::Incoming(incoming) => {