From a67c904d4e3674488066b994137fc1afe98ec546 Mon Sep 17 00:00:00 2001 From: andig Date: Mon, 6 Oct 2025 14:37:28 +0200 Subject: [PATCH] chore: improve logging --- vehicle/bmw/cardata/mqtt.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/vehicle/bmw/cardata/mqtt.go b/vehicle/bmw/cardata/mqtt.go index e042dbf61..194fb9766 100644 --- a/vehicle/bmw/cardata/mqtt.go +++ b/vehicle/bmw/cardata/mqtt.go @@ -82,6 +82,8 @@ func (v *MqttConnector) runMqtt(ctx context.Context, token *oauth2.Token) error gcid := TokenExtra(token, "gcid") idToken := TokenExtra(token, "id_token") + v.log.DEBUG.Printf("connect streaming (using gcid %s/ id %s, valid until: %v)", gcid, idToken, token.Expiry.Round(time.Second)) + paho := mqtt.NewClient( mqtt.NewClientOptions(). AddBroker(StreamingURL). @@ -95,7 +97,7 @@ func (v *MqttConnector) runMqtt(ctx context.Context, token *oauth2.Token) error } else if err := t.Error(); err != nil { return fmt.Errorf("connect: %w", err) } - defer paho.Disconnect(0) + defer paho.Disconnect(1000) topic := fmt.Sprintf("%s/#", gcid)