use new code to start a repo migration

ipfs · Apr 3, 2021 · 2455742 · 2455742
1 parent 4fac5e3
commit 2455742
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/core/commands/repo.go b/core/commands/repo.go
@@ -400,7 +400,9 @@ var repoMigrateCmd = &cmds.Command{
 
 		fmt.Println("Found outdated fs-repo, starting migration.")
 
-		err = migrate.RunMigration(fsrepo.RepoVersion, allowDowngrade)
+		// Fetch migrations from current distribution, or location from environ
+		fetcher := migrate.NewHttpFetcher(migrate.GetDistPathEnv(migrate.CurrentIpfsDist), "", "go-ipfs", 0)
+		err = migrate.RunMigration(cctx.Context(), fetcher, fsrepo.RepoVersion, "", allowDowngrade)
 		if err != nil {
 			fmt.Println("The migrations of fs-repo failed:")
 			fmt.Printf("  %s\n", err)