Fix/add repo compatibility for cli

Makefile

@@ -44,4 +44,10 @@ ifdef PRIVATE_REGISTRY
 endif
 
 docker-push: docker
+ifdef PRIVATE_REGISTRY
 	docker push $(PRIVATE_REGISTRY)/filvenus/sophon-messager:$(TAG)
+else
+	docker push filvenus/sophon-messager:$(TAG)
+	docker tag filvenus/sophon-messager:$(TAG) filvenus/sophon-messager:latest
+	docker push filvenus/sophon-messager:latest
+endif

cli/cmd.go

@@ -2,6 +2,9 @@ package cli
 
 import (
 	"context"
+	"errors"
+	"fmt"
+	"os"
 
 	"github.com/filecoin-project/go-jsonrpc"
 	v1 "github.com/filecoin-project/venus/venus-shared/api/chain/v1"
@@ -15,6 +18,11 @@ import (
 	"github.com/filecoin-project/venus/venus-shared/api/messager"
 )
 
+const (
+	OldRepoPath = "~/.venus-messager"
+	DefRepoPath = "~/.sophon-messager"
+)
+
 func getAPI(ctx *cli.Context) (messager.IMessager, jsonrpc.ClientCloser, error) {
 	repo, err := getRepo(ctx)
 	if err != nil {
@@ -61,7 +69,7 @@ func LoadBuiltinActors(ctx context.Context, nodeAPI v1.FullNode) error {
 }
 
 func getRepo(ctx *cli.Context) (filestore.FSRepo, error) {
-	repoPath, err := homedir.Expand(ctx.String("repo"))
+	repoPath, err := GetRepoPath(ctx)
 	if err != nil {
 		return nil, err
 	}
@@ -71,3 +79,44 @@ func getRepo(ctx *cli.Context) (filestore.FSRepo, error) {
 	}
 	return repo, nil
 }
+
+func GetRepoPath(cctx *cli.Context) (string, error) {
+	repoPath, err := homedir.Expand(cctx.String("repo"))
+	if err != nil {
+		return "", err
+	}
+	has, err := hasFSRepo(repoPath)
+	if err != nil {
+		return "", err
+	}
+	if !has {
+		// check old repo path
+		rPath, err := homedir.Expand(OldRepoPath)
+		if err != nil {
+			return "", err
+		}
+		has, err = hasFSRepo(rPath)
+		if err != nil {
+			return "", err
+		}
+		if has {
+			return rPath, nil
+		}
+	}
+	return repoPath, nil
+}
+
+func hasFSRepo(repoPath string) (bool, error) {
+	fi, err := os.Stat(repoPath)
+	if err != nil {
+		if errors.Is(err, os.ErrNotExist) {
+			return false, nil
+		}
+		return false, err
+	}
+	if !fi.IsDir() {
+		return false, fmt.Errorf("%s is not a folder", repoPath)
+	}
+
+	return true, nil
+}

main.go

@@ -12,7 +12,6 @@ import (
 
 	"github.com/ipfs-force-community/sophon-messager/publisher"
 	"github.com/ipfs-force-community/sophon-messager/publisher/pubsub"
-	"github.com/mitchellh/go-homedir"
 
 	"github.com/filecoin-project/venus/fixtures/networks"
 	v1 "github.com/filecoin-project/venus/venus-shared/api/chain/v1"
@@ -38,11 +37,6 @@ import (
 	"github.com/ipfs-force-community/sophon-messager/version"
 )
 
-const (
-	oldRepoPath = "~/.venus-messager"
-	defRepoPath = "~/.sophon-messager"
-)
-
 var log = logging.Logger("main")
 
 func main() {
@@ -52,7 +46,7 @@ func main() {
 		Flags: []cli.Flag{
 			&cli.StringFlag{
 				Name:  "repo",
-				Value: defRepoPath,
+				Value: ccli.DefRepoPath,
 			},
 		},
 		Commands: []*cli.Command{