From 21aa735d5183aa63df8d6c1975a1fbdc72872682 Mon Sep 17 00:00:00 2001 From: Travis Shears Date: Thu, 25 Dec 2025 13:30:13 +0100 Subject: [PATCH] add password and user to mqtt login --- event_proxy/main.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/event_proxy/main.go b/event_proxy/main.go index 2f3c44a..050cb2e 100644 --- a/event_proxy/main.go +++ b/event_proxy/main.go @@ -26,13 +26,22 @@ func getMQTTClient() mqtt.Client { if mqttPort == "" { panic("MQTT_PORT environment variable not set") } + mqttUsername := os.Getenv("MQTT_USERNAME") + if mqttUsername == "" { + panic("MQTT_USERNAME environment variable not set") + } + mqttPassword := os.Getenv("MQTT_PASSWORD") + if mqttPassword == "" { + panic("MQTT_PASSWORD environment variable not set") + } brokerURL := "tcp://" + mqttHost + ":" + mqttPort slog.Info("Connecting to MQTT", "broker", brokerURL) - opts := mqtt.NewClientOptions(). AddBroker(brokerURL). - SetClientID("event-proxy") + SetClientID("event-proxy"). + SetUsername(mqttUsername). + SetPassword(mqttPassword) client := mqtt.NewClient(opts)