test: add tags copy test for mirror

cmd/suite_test.go

@@ -18,6 +18,7 @@
 package cmd
 
 import (
+	"bufio"
 	"bytes"
 	"crypto/md5"
 	"crypto/tls"
@@ -29,6 +30,7 @@ import (
 	"net/http"
 	"os"
 	"os/exec"
+	"reflect"
 	"runtime"
 	"runtime/debug"
 	"strconv"
@@ -166,6 +168,7 @@ func testsThatDependOnOneAnother(t *testing.T) {
 	// Mirror
 	MirrorTempDirectoryStorageClassReducedRedundancy(t)
 	MirrorTempDirectory(t)
+	MirrorMinio2MinioWithTagsCopy(t)
 
 	// General object tests
 	FindObjects(t)
@@ -778,6 +781,56 @@ func MirrorTempDirectory(t *testing.T) {
 	}
 }
 
+type tagListResult struct {
+	Tagset    map[string]string `json:"tagset"`
+	Status    string            `json:"status"`
+	URL       string            `json:"url"`
+	VersionID string            `json:"versionID"`
+}
+
+func MirrorMinio2MinioWithTagsCopy(t *testing.T) {
+	TargetBucket := CreateBucket(t)
+	out, err := RunMC(
+		"mirror",
+		mainTestBucket,
+		TargetBucket,
+	)
+	fatalIfErrorWMsg(err, out, t)
+
+	out, err = RunMC("tag", "list", TargetBucket, "-r")
+	fatalIfErrorWMsg(err, out, t)
+	var targetTagsList []tagListResult
+	outStrs := bufio.NewScanner(strings.NewReader(out))
+	for outStrs.Scan() {
+		outStr := outStrs.Text()
+		if outStr == "" {
+			continue
+		}
+		tagList := new(tagListResult)
+		if err := json.Unmarshal([]byte(outStr), tagList); err != nil {
+			fatalIfErrorWMsg(err, out, t)
+		}
+		targetTagsList = append(targetTagsList, *tagList)
+	}
+
+	for _, f := range fileMap {
+		fileFound := false
+
+		for _, o := range targetTagsList {
+			if strings.Contains(o.URL, f.fileNameWithPrefix) {
+				fileFound = true
+				if !reflect.DeepEqual(f.tags, o.Tagset) {
+					fatalMsgOnly(fmt.Sprintf("expecting tags (%s) but got tags (%s)", f.tags, o.Tagset), t)
+				}
+			}
+		}
+
+		if !fileFound {
+			t.Fatalf("File was not mirrored: %s", f.fileNameWithPrefix)
+		}
+	}
+}
+
 func CatObjectFromStdin(t *testing.T) {
 	objectName := "pipe-test-object"
 	CatEchoBucket := CreateBucket(t)