From 66e79044b6fbcdc3699acae76014042dbd997bfe Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andr=C3=A9=20Duffeck?= Date: Wed, 14 May 2025 14:46:44 +0200 Subject: [PATCH] Log error when failing to unmarshal messagepack --- services/activitylog/pkg/service/service.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/services/activitylog/pkg/service/service.go b/services/activitylog/pkg/service/service.go index db61abc323..8d4e0145a5 100644 --- a/services/activitylog/pkg/service/service.go +++ b/services/activitylog/pkg/service/service.go @@ -377,6 +377,7 @@ func (a *ActivitylogService) activities(rid *provider.ResourceId) ([]RawActivity var activities []RawActivity if err := msgpack.Unmarshal(records[0].Value, &activities); err != nil { + a.log.Debug().Err(err).Str("resourceID", resourceID).Msg("could not unmarshal messagepack, trying json") if err := json.Unmarshal(records[0].Value, &activities); err != nil { return nil, fmt.Errorf("could not unmarshal activities: %w", err) } @@ -463,6 +464,7 @@ func (a *ActivitylogService) storeActivity(resourceID string, activities []RawAc var existingActivities []RawActivity if len(records) > 0 { if err := msgpack.Unmarshal(records[0].Value, &existingActivities); err != nil { + a.log.Debug().Err(err).Str("resourceID", resourceID).Msg("could not unmarshal messagepack, trying json") if err := json.Unmarshal(records[0].Value, &existingActivities); err != nil { return err }