Merge pull request #721 from bloxapp/migration-7

Migration 7: clean operator removals corruptions
ssvlabs · Oct 14, 2022 · 1c6339e · 1c6339e
2 parents e02092f + 5dd1489
commit 1c6339e
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/migrations/migration_7_clean_operator_removals_corruptions.go b/migrations/migration_7_clean_operator_removals_corruptions.go
@@ -0,0 +1,16 @@
+package migrations
+
+import (
+	"context"
+)
+
+var migrationCleanOperatorRemovalCorruptions = Migration{
+	Name: "migration_7_clean_operator_removal_corruptions",
+	Run: func(ctx context.Context, opt Options, key []byte) error {
+		nodeStorage := opt.nodeStorage()
+		if err := nodeStorage.CleanRegistryData(); err != nil {
+			return err
+		}
+		return opt.Db.Set(migrationsPrefix, key, migrationCompleted)
+	},
+}
diff --git a/migrations/migrations.go b/migrations/migrations.go
@@ -25,6 +25,7 @@ var (
 		migrationCleanExporterRegistryData,
 		migrationCleanValidatorRegistryData,
 		migrationCleanSyncOffset,
+		migrationCleanOperatorRemovalCorruptions,
 	}
 )