From 7b2390cbf6453fffd261a05feb1e19f2b30965e2 Mon Sep 17 00:00:00 2001 From: Hein Date: Tue, 30 Dec 2025 00:19:49 +0200 Subject: [PATCH] Mqtt logging --- pkg/eventlogger/eventlogger.go | 1 + pkg/eventlogger/mqtt_target.go | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/eventlogger/eventlogger.go b/pkg/eventlogger/eventlogger.go index 5825c5c..2855539 100644 --- a/pkg/eventlogger/eventlogger.go +++ b/pkg/eventlogger/eventlogger.go @@ -73,6 +73,7 @@ func NewLogger(cfg config.EventLoggerConfig, dbConfig config.DatabaseConfig, waM logging.Info("Event logger PostgreSQL target initialized") case "mqtt": + logging.Info("Initializing MQTT event logger target", "broker", cfg.MQTT.Broker) mqttTarget, err := NewMQTTTarget(cfg.MQTT, waManager) if err != nil { logging.Error("Failed to initialize MQTT target", "error", err) diff --git a/pkg/eventlogger/mqtt_target.go b/pkg/eventlogger/mqtt_target.go index 2c75697..95b4c4b 100644 --- a/pkg/eventlogger/mqtt_target.go +++ b/pkg/eventlogger/mqtt_target.go @@ -82,16 +82,18 @@ func NewMQTTTarget(cfg config.MQTTConfig, waManager WhatsAppManager) (*MQTTTarge if cfg.Subscribe { // Subscribe to send command topic for all accounts topic := fmt.Sprintf("%s/+/send", cfg.TopicPrefix) + logging.Info("Starting MQTT subscription", "topic", topic, "qos", cfg.QoS) if token := client.Subscribe(topic, byte(cfg.QoS), target.handleSendMessage); token.Wait() && token.Error() != nil { logging.Error("Failed to subscribe to MQTT topic", "topic", topic, "error", token.Error()) } else { - logging.Info("Subscribed to MQTT send topic", "topic", topic) + logging.Info("Successfully subscribed to MQTT send topic", "topic", topic) } } }) // Create and connect the client client := mqtt.NewClient(opts) + logging.Info("Starting MQTT connection", "broker", cfg.Broker, "client_id", cfg.ClientID) if token := client.Connect(); token.Wait() && token.Error() != nil { return nil, fmt.Errorf("failed to connect to MQTT broker: %w", token.Error()) }