From 2a436071bf28a82873d30848ae7c826fd464b043 Mon Sep 17 00:00:00 2001
From: Dreaded_X <tim@huizinga.dev>
Date: Mon, 28 Aug 2023 02:41:40 +0200
Subject: [PATCH] Also load MQTT port from environment

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

diff --git a/src/main.rs b/src/main.rs
index 2772f0f..e719aab 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -12,7 +12,7 @@ use embassy_futures::{
     select::{select, Either},
     yield_now,
 };
-use embassy_net::{tcp::TcpSocket, Config, Ipv4Address, Stack, StackResources};
+use embassy_net::{tcp::TcpSocket, Config, IpEndpoint, Stack, StackResources};
 use embassy_rp::{
     bind_interrupts,
     clocks::RoscRng,
@@ -212,7 +212,7 @@ async fn main(spawner: Spawner) {
 
     let mut socket = TcpSocket::new(stack, &mut rx_buffer, &mut tx_buffer);
     // socket.set_timeout(Some(Duration::from_secs(10)));
-    let addr = (Ipv4Address::from_str(env!("MQTT_IP")).unwrap(), 1883);
+    let addr = IpEndpoint::from_str(env!("MQTT_ADDRESS")).unwrap();
 
     while let Err(e) = socket.connect(addr).await {
         warn!("Connect error: {:?}", e);