refactoring

1 files changed, 14 insertions, 10 deletions

diff --git a/weed/command/filer_replication.go b/weed/command/filer_replication.go
index 087a12059..3384e4023 100644
--- a/weed/command/filer_replication.go
+++ b/weed/command/filer_replication.go
@@ -41,16 +41,7 @@ func runFilerReplicate(cmd *Command, args []string) bool {
 
 	var notificationInput sub.NotificationInput
 
-	enabledInput := ""
-	for _, input := range sub.NotificationInputs {
-		if config.GetBool("notification." + input.GetName() + ".enabled") {
-			if enabledInput == "" {
-				enabledInput = input.GetName()
-			} else {
-				glog.Fatalf("Notification input is enabled for both %s and %s", enabledInput, input.GetName())
-			}
-		}
-	}
+	validateOneEnabledInput(config)
 
 	for _, input := range sub.NotificationInputs {
 		if config.GetBool("notification." + input.GetName() + ".enabled") {
@@ -133,3 +124,16 @@ func runFilerReplicate(cmd *Command, args []string) bool {
 
 	return true
 }
+
+func validateOneEnabledInput(config *viper.Viper) {
+	enabledInput := ""
+	for _, input := range sub.NotificationInputs {
+		if config.GetBool("notification." + input.GetName() + ".enabled") {
+			if enabledInput == "" {
+				enabledInput = input.GetName()
+			} else {
+				glog.Fatalf("Notification input is enabled for both %s and %s", enabledInput, input.GetName())
+			}
+		}
+	}
+}