From e9201d65a0dca9defe3feb66f750a092261cd469 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andr=C3=A9=20Duffeck?= Date: Thu, 5 Jun 2025 08:58:25 +0200 Subject: [PATCH] Fix comments --- services/activitylog/pkg/service/migrations.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/services/activitylog/pkg/service/migrations.go b/services/activitylog/pkg/service/migrations.go index 02e9f2c64c..c16ea169de 100644 --- a/services/activitylog/pkg/service/migrations.go +++ b/services/activitylog/pkg/service/migrations.go @@ -37,8 +37,8 @@ func (a *ActivitylogService) runMigrations(ctx context.Context, kv nats.KeyValue // migrateToV1 performs the data migration to version 1. // It iterates over all keys, expecting their values to be JSON arrays of strings. -// For each such key, it creates a new key in the format "originalKey:count:timestamp" -// and stores the original list of strings (re-marshalled to JSON) as its value. +// For each such key, it creates a new key in the format "originalKey.count.timestamp" +// and stores the original list of strings (re-marshalled to messagepack) as its value. // Finally, it sets the activitylog.version key to "1". func (a *ActivitylogService) migrateToV1(_ context.Context, kv nats.KeyValue) error { lister, err := kv.ListKeys() @@ -101,7 +101,7 @@ func (a *ActivitylogService) migrateToV1(_ context.Context, kv nats.KeyValue) er continue } - // Write the value (the list of strings, marshalled as JSON) under the new key + // Write the value (the list of strings, marshalled as messagepack) under the new key if _, err := kv.Put(newKey, newValue); err != nil { a.log.Error().Err(err).Str("newKey", newKey).Str("key", key).Msg("migrateToV1: Failed to put new key. Skipping.") skippedCount++