From f1a4787d0cd8a91b274d67ff377979d466e459c2 Mon Sep 17 00:00:00 2001 From: H4S1NTH4 Date: Sat, 2 May 2026 08:00:58 +0530 Subject: [PATCH] fix: add logging for telemetry hits and publishing events in handlers --- services/hardware-service/handlers.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/services/hardware-service/handlers.go b/services/hardware-service/handlers.go index f4dff70..b381cef 100644 --- a/services/hardware-service/handlers.go +++ b/services/hardware-service/handlers.go @@ -689,6 +689,8 @@ func (h *Handler) handleTelemetry(_ mqtt.Client, msg mqtt.Message) { if payload.Timestamp.IsZero() { payload.Timestamp = time.Now().UTC() } + // Log MQTT telemetry hit + log.Printf("[INFO] mqtt_telemetry_hit: sensor=%s topic=%s readings=%d", payload.SensorID, msg.Topic(), len(payload.Readings)) if err := h.storeTelemetry(payload); err != nil { log.Printf("[ERROR] handleTelemetry: store error: %v", err) } @@ -712,11 +714,15 @@ func (h *Handler) publishTelemetryToRabbitMQ(payload TelemetryPayload) { if h.rmqPublisher != nil && h.rmqPublisher.IsConnected() { if err := h.rmqPublisher.PublishTelemetry(ctx, event); err != nil { log.Printf("[WARN] Failed to publish telemetry to RabbitMQ: %v", err) + } else { + log.Printf("[INFO] published_to_rmq: sensor=%s param=%s value=%.2f", event.SensorID, event.ParameterID, event.Value) } } if h.sbPublisher != nil && h.sbPublisher.IsConnected() { if err := h.sbPublisher.PublishTelemetry(ctx, event); err != nil { log.Printf("[WARN] Failed to publish telemetry to Service Bus: %v", err) + } else { + log.Printf("[INFO] published_to_sb: sensor=%s param=%s value=%.2f", event.SensorID, event.ParameterID, event.Value) } } }