Skip keys that no longer exist and don't exit

Author: Jamie Curnow

README.md

@@ -70,6 +70,6 @@ go get github.com/jc21/redis-migrator
 
 ```bash
 git clone https://github.com/jc21/redis-migrator && cd redis-migrator
-go build -o bin/redis-migrator cmd/redis-migrator/main.go
+go build -v -ldflags="-X main.version=1.0.1" -o bin/redis-migrator cmd/redis-migrator/main.go
 ./bin/redis-migrator -h
 ```

cmd/redis-migrator/main.go

@@ -10,8 +10,10 @@ import (
 	"redismigrator/pkg/migrator"
 )
 
+var version string
+
 func main() {
-	argConfig := config.GetConfig()
+	argConfig := config.GetConfig(&version)
 	logger.Init(argConfig)
 	logger.Trace("Args: %+v", argConfig)
 

pkg/config/config.go

@@ -10,7 +10,8 @@ import (
 var appArguments model.ArgConfig
 
 // GetConfig returns the ArgConfig
-func GetConfig() model.ArgConfig {
+func GetConfig(version *string) model.ArgConfig {
+	model.SetVersion(version)
 	config.FromEnv().To(&appArguments)
 	arg.MustParse(&appArguments)
 	return appArguments

pkg/migrator/migrate.go

@@ -41,6 +41,7 @@ func DoMigration(sourceClient, destinationClient *redis.Client, keyFilter, keyPr
 	}
 
 	counter := 0
+	skipped := 0
 	for _, sourceKey := range keys {
 		destinationKey := keyPrefix + sourceKey
 
@@ -58,15 +59,19 @@ func DoMigration(sourceClient, destinationClient *redis.Client, keyFilter, keyPr
 			copyHash(sourceClient, destinationClient, sourceKey, destinationKey)
 		case "list":
 			copyList(sourceClient, destinationClient, sourceKey, destinationKey)
+		case "none":
+			// Key does not exist, or at least not anymore.
+			skipped++
 		default:
-			logger.Error("Key type not yet sypported: %s", keyType)
+			logger.Error("Key type not yet supported: %s", keyType)
+			logger.Error("Migration was NOT completed!")
 			os.Exit(1)
 		}
 
 		counter++
 	}
 
-	logger.Info("Migration completed with %d keys :)", counter)
+	logger.Info("Migration completed with %d keys, %d skipped :)", counter, skipped)
 	os.Exit(0)
 }
 

pkg/model/arg_config.go

@@ -2,6 +2,8 @@ package model
 
 import "fmt"
 
+var version *string
+
 // ArgConfig is the settings for passing arguments to the command
 type ArgConfig struct {
 	SourceHost         string `arg:"--source-host,required" help:"source redis server hostname"`
@@ -19,6 +21,16 @@ type ArgConfig struct {
 	Verbose            bool   `arg:"-v" help:"Print a lot more info"`
 }
 
+// SetVersion ...
+func SetVersion(ver *string) {
+	version = ver
+}
+
+// Version ...
+func (ArgConfig) Version() string {
+	return fmt.Sprintf("v%s", *version)
+}
+
 // Description returns a simple description of the command
 func (ArgConfig) Description() string {
 	return `Redis Migrator will take the keys from one server/db and