refactoring

2 files changed, 3 insertions, 57 deletions

diff --git a/weed/shell/command_s3_bucket_create.go b/weed/shell/command_s3_bucket_create.go
index 78530ad3d..80c8a043b 100644
--- a/weed/shell/command_s3_bucket_create.go
+++ b/weed/shell/command_s3_bucket_create.go
@@ -4,14 +4,11 @@ import (
 	"context"
 	"flag"
 	"fmt"
+	"github.com/seaweedfs/seaweedfs/weed/pb/filer_pb"
+	"github.com/seaweedfs/seaweedfs/weed/s3api/s3bucket"
 	"io"
-	"net"
 	"os"
-	"strings"
 	"time"
-	"unicode"
-
-	"github.com/seaweedfs/seaweedfs/weed/pb/filer_pb"
 )
 
 func init() {
@@ -45,7 +42,7 @@ func (c *commandS3BucketCreate) Do(args []string, commandEnv *CommandEnv, writer
 		return fmt.Errorf("empty bucket name")
 	}
 
-	err = verifyS3BucketName(*bucketName)
+	err = s3bucket.VerifyS3BucketName(*bucketName)
 	if err != nil {
 		return err
 	}
@@ -86,35 +83,3 @@ func (c *commandS3BucketCreate) Do(args []string, commandEnv *CommandEnv, writer
 	return err
 
 }
-
-// https://docs.aws.amazon.com/AmazonS3/latest/userguide/bucketnamingrules.html
-func verifyS3BucketName(name string) (err error) {
-	if len(name) < 3 || len(name) > 63 {
-		return fmt.Errorf("bucket name must between [3, 63] characters")
-	}
-	for idx, ch := range name {
-		if !(unicode.IsLower(ch) || ch == '.' || ch == '-' || unicode.IsNumber(ch)) {
-			return fmt.Errorf("bucket name can only contain lower case characters, numbers, dots, and hyphens")
-		}
-		if idx > 0 && (ch == '.' && name[idx-1] == '.') {
-			return fmt.Errorf("bucket names must not contain two adjacent periods")
-		}
-		//TODO buckets with s3 transfer accleration cannot have . in name
-	}
-	if name[0] == '.' || name[0] == '-' {
-		return fmt.Errorf("name must start with number or lower case character")
-	}
-	if name[len(name)-1] == '.' || name[len(name)-1] == '-' {
-		return fmt.Errorf("name must end with number or lower case character")
-	}
-	if strings.HasPrefix(name, "xn--") {
-		return fmt.Errorf("prefix xn-- is a reserved and not allowed in bucket prefix")
-	}
-	if strings.HasSuffix(name, "-s3alias") {
-		return fmt.Errorf("suffix -s3alias is a reserved and not allowed in bucket suffix")
-	}
-	if net.ParseIP(name) != nil {
-		return fmt.Errorf("bucket name cannot be ip addresses")
-	}
-	return nil
-}
\ No newline at end of file
diff --git a/weed/shell/command_s3_bucket_create_test.go b/weed/shell/command_s3_bucket_create_test.go
deleted file mode 100644
index 13cbd76e8..000000000
--- a/weed/shell/command_s3_bucket_create_test.go
+++ /dev/null
@@ -1,19 +0,0 @@
-package shell
-
-import (
-	"github.com/stretchr/testify/assert"
-	"testing"
-)
-
-func Test_verifyBucketName(t *testing.T) {
-	invalidS3BucketNames := []string{"A9325325b", "123.12.153.10", "abc214..2", "d", ".ewfs3253543", "grehtrry-", "----------", "x@fdsgr032"}
-	for _, invalidName := range invalidS3BucketNames {
-		err := verifyS3BucketName(invalidName)
-		assert.NotNil(t, err)
-	}
-	validS3BucketName := []string{"a9325325b", "999.12.153.10", "abc214.2", "3d3d3d", "ewfs3253543", "grehtrry-a", "0----------0", "xafdsgr032"}
-	for _, invalidName := range validS3BucketName {
-		err := verifyS3BucketName(invalidName)
-		assert.Nil(t, err)
-	}
-}