From 8d69d79404db26c3d6b4b5850a4c1c34e18a217f Mon Sep 17 00:00:00 2001
From: Jaroslaw Konik <konikjar@gmail.com>
Date: Wed, 29 May 2024 20:55:37 +0200
Subject: [PATCH] fix

---
 src/main.rs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 7f9a2a7..32bb09d 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -27,6 +27,7 @@ use static_cell::make_static;
 
 const SSID: &str = env!("SSID");
 const PASSWORD: &str = env!("PASSWORD");
+const MQTT_USERNAME: &str = env!("MQTT_USERNAME");
 const MQTT_PASSWORD: &str = env!("MQTT_PASSWORD");
 
 const MQTT_TOPIC_NAME: &str = "home/doorbell/state";
@@ -115,7 +116,7 @@ async fn ring(stack: &'static Stack<WifiDevice<'static, WifiStaDevice>>) -> Resu
 
     socket.set_timeout(Some(embassy_time::Duration::from_secs(10)));
 
-    let remote_endpoint = (Ipv4Address::new(192, 168, 1, 3), 80);
+    let remote_endpoint = (Ipv4Address::new(192, 168, 1, 3), 1883);
     println!("connecting...");
     let r = socket.connect(remote_endpoint).await;
     if let Err(e) = r {
@@ -128,6 +129,7 @@ async fn ring(stack: &'static Stack<WifiDevice<'static, WifiStaDevice>>) -> Resu
         rust_mqtt::client::client_config::MqttVersion::MQTTv5,
         CountingRng(20000),
     );
+    config.add_username(MQTT_USERNAME);
     config.add_password(MQTT_PASSWORD);
 
     // Do we need those?
@@ -160,7 +162,7 @@ async fn ring(stack: &'static Stack<WifiDevice<'static, WifiStaDevice>>) -> Resu
     client
         .send_message(
             MQTT_TOPIC_NAME,
-            "\"event_type\": \"press\"".as_bytes(),
+            "{ \"event_type\": \"press\" }".as_bytes(),
             QualityOfService::QoS0,
             true,
         )