From 4f00849cab60eb3163d6f94a1861d3010decdd81 Mon Sep 17 00:00:00 2001 From: mcrakhman Date: Mon, 20 Jan 2025 18:36:38 +0100 Subject: [PATCH] Migrate space hash --- commonspace/spacestorage/migration/spacemigrator.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/commonspace/spacestorage/migration/spacemigrator.go b/commonspace/spacestorage/migration/spacemigrator.go index 2d585bfb..8c0414d9 100644 --- a/commonspace/spacestorage/migration/spacemigrator.go +++ b/commonspace/spacestorage/migration/spacemigrator.go @@ -160,9 +160,20 @@ func (s *spaceMigrator) MigrateId(ctx context.Context, id string, progress Progr if len(allErrors) > 0 { return fmt.Errorf("migration failed: %w", errors.Join(allErrors...)) } + if err := s.migrateHash(ctx, oldStorage, newStorage); err != nil { + log.Warn("migration: failed to migrate hash", zap.Error(err)) + } return s.setMigrated(ctx, newStorage.AnyStore()) } +func (s *spaceMigrator) migrateHash(ctx context.Context, oldStorage oldstorage.SpaceStorage, newStorage spacestorage.SpaceStorage) error { + spaceHash, err := oldStorage.ReadSpaceHash() + if err != nil { + return err + } + return newStorage.StateStorage().SetHash(ctx, spaceHash) +} + func (s *spaceMigrator) checkMigrated(ctx context.Context, id string) (bool, spacestorage.SpaceStorage) { storage, err := s.newProvider.WaitSpaceStorage(ctx, id) if err != nil {