From bf789d6e52ae89dfa71a3aa8b4ff0bb97c9f2416 Mon Sep 17 00:00:00 2001
From: Christophe de Carvalho <christophe.dcpm@gmail.com>
Date: Mon, 7 Sep 2020 20:20:45 +0200
Subject: [PATCH] add 'ipfs repo migrate' command

this command allows to run the repo migration without starting the
daemon.

fixes #7471
---
 core/commands/repo.go | 41 +++++++++++++++++++++++++++++++++++++++--
 1 file changed, 39 insertions(+), 2 deletions(-)

diff --git a/core/commands/repo.go b/core/commands/repo.go
index 0a91648a88cf..5d5739b661dc 100644
--- a/core/commands/repo.go
+++ b/core/commands/repo.go
@@ -12,9 +12,11 @@ import (
 	"text/tabwriter"
 
 	humanize "github.com/dustin/go-humanize"
+	oldcmds "github.com/ipfs/go-ipfs/commands"
 	cmdenv "github.com/ipfs/go-ipfs/core/commands/cmdenv"
 	corerepo "github.com/ipfs/go-ipfs/core/corerepo"
 	fsrepo "github.com/ipfs/go-ipfs/repo/fsrepo"
+	migrate "github.com/ipfs/go-ipfs/repo/fsrepo/migrations"
 
 	cid "github.com/ipfs/go-cid"
 	bstore "github.com/ipfs/go-ipfs-blockstore"
@@ -39,6 +41,7 @@ var RepoCmd = &cmds.Command{
 		"fsck":    repoFsckCmd,
 		"version": repoVersionCmd,
 		"verify":  repoVerifyCmd,
+		"migrate": repoMigrateCmd,
 	},
 }
 
@@ -49,8 +52,9 @@ type GcResult struct {
 }
 
 const (
-	repoStreamErrorsOptionName = "stream-errors"
-	repoQuietOptionName        = "quiet"
+	repoStreamErrorsOptionName   = "stream-errors"
+	repoQuietOptionName          = "quiet"
+	repoAllowDowngradeOptionName = "allow-downgrade"
 )
 
 var repoGcCmd = &cmds.Command{
@@ -371,3 +375,36 @@ var repoVersionCmd = &cmds.Command{
 		}),
 	},
 }
+
+var repoMigrateCmd = &cmds.Command{
+	Helptext: cmds.HelpText{
+		Tagline: "Apply any outstanding migrations to the repo.",
+	},
+	Options: []cmds.Option{
+		cmds.BoolOption(repoAllowDowngradeOptionName, "Allow downgrading to a lower repo version"),
+	},
+	NoRemote: true,
+	Run: func(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment) error {
+		cctx := env.(*oldcmds.Context)
+
+		_, err := fsrepo.Open(cctx.ConfigRoot)
+		if err != fsrepo.ErrNeedMigration {
+			fmt.Println("Repo does not require migration")
+			return nil
+		}
+
+		fmt.Println("Found outdated fs-repo, starting migration.")
+
+		err = migrate.RunMigration(fsrepo.RepoVersion)
+		if err != nil {
+			fmt.Println("The migrations of fs-repo failed:")
+			fmt.Printf("  %s\n", err)
+			fmt.Println("If you think this is a bug, please file an issue and include this whole log output.")
+			fmt.Println("  https://github.com/ipfs/fs-repo-migrations")
+			return err
+		}
+
+		fmt.Println("Repo migrated successfully.")
+		return nil
+	},
+}