Merge pull request #15 from stakwork/parse-ping-esp-demo-fix

two small fixes for the esp32 ping demo

broker/src/main.rs

@@ -24,7 +24,7 @@ fn main() {
     rt.build().unwrap().block_on(async {
         let (msg_tx, mut msg_rx): (mpsc::UnboundedSender<Vec<u8>>, mpsc::UnboundedReceiver<Vec<u8>>) = mpsc::unbounded_channel();
         let (mut tx, mut rx) = builder.connect("localclient", 200).await.unwrap();
-        tx.subscribe([SUB_TOPIC, TRIGGER_TOPIC]).await.unwrap();
+        tx.subscribe([TRIGGER_TOPIC]).await.unwrap();
 
         let console_task = tokio::spawn(console);
 

sphinx-key/src/conn/mqtt.rs

@@ -78,7 +78,7 @@ pub fn start_listening(
     client.subscribe(TOPIC, QoS::AtMostOnce)?;
 
     client.publish(
-        TOPIC,
+        RETURN_TOPIC,
         QoS::AtMostOnce,
         false,
         format!("Hello from {}!", CLIENT_ID).as_bytes(),