mc tag command

cmd/client-errors.go

@@ -56,6 +56,13 @@ func (e BucketNameEmpty) Error() string {
 	return "Bucket name cannot be empty."
 }
 
+// ObjectNameEmpty - object name empty.
+type ObjectNameEmpty struct{}
+
+func (e ObjectNameEmpty) Error() string {
+	return "Object name cannot be empty."
+}
+
 // BucketInvalid - bucket name invalid.
 type BucketInvalid struct {
 	Bucket string

cmd/client-fs.go

@@ -393,13 +393,13 @@ func (f *fsClient) put(reader io.Reader, size int64, metadata map[string][]strin
 				return totalWritten, probe.NewError(e)
 			}
 
-			ctime, e := strconv.ParseInt(attr["ctime"], 10, 64)
+			mtime, e := strconv.ParseInt(attr["mtime"], 10, 64)
 			if e != nil {
 				return totalWritten, probe.NewError(e)
 			}
 
-			// Attempt to change the access, modify and change time
-			if e := os.Chtimes(objectPath, time.Unix(atime, 0), time.Unix(ctime, 0)); e != nil {
+			// Attempt to change the access and modify time
+			if e := os.Chtimes(objectPath, time.Unix(atime, 0), time.Unix(mtime, 0)); e != nil {
 				return totalWritten, probe.NewError(e)
 			}
 		}

cmd/client-s3.go

@@ -2108,8 +2108,11 @@ func (c *s3Client) GetObjectTagging() (tagging.Tagging, *probe.Error) {
 	var err error
 	bucketName, objectName := c.url2BucketAndObject()
 	if bucketName == "" || objectName == "" {
-		err = errors.New("Bucket name or object name cannot be empty")
-		return tagging.Tagging{}, probe.NewError(err)
+		pErr := probe.NewError(BucketNameEmpty{})
+		if objectName == "" {
+			pErr = probe.NewError(ObjectNameEmpty{})
+		}
+		return tagging.Tagging{}, pErr
 	}
 	tagXML, err := c.api.GetObjectTagging(bucketName, objectName)
 	if err != nil {
@@ -2127,8 +2130,11 @@ func (c *s3Client) SetObjectTagging(tagMap map[string]string) *probe.Error {
 	var err error
 	bucket, object := c.url2BucketAndObject()
 	if bucket == "" || object == "" {
-		err = errors.New("Bucket name or object name cannot be empty")
-		return probe.NewError(err)
+		pErr := probe.NewError(BucketNameEmpty{})
+		if object == "" {
+			pErr = probe.NewError(ObjectNameEmpty{})
+		}
+		return pErr
 	}
 	if err = c.api.PutObjectTagging(bucket, object, tagMap); err != nil {
 		return probe.NewError(err)
@@ -2140,8 +2146,11 @@ func (c *s3Client) SetObjectTagging(tagMap map[string]string) *probe.Error {
 func (c *s3Client) DeleteObjectTagging() *probe.Error {
 	bucket, object := c.url2BucketAndObject()
 	if bucket == "" || object == "" {
-		err := errors.New("Bucket name or object name cannot be empty")
-		return probe.NewError(err)
+		pErr := probe.NewError(BucketNameEmpty{})
+		if object == "" {
+			pErr = probe.NewError(ObjectNameEmpty{})
+		}
+		return pErr
 	}
 	if err := c.api.RemoveObjectTagging(bucket, object); err != nil {
 		return probe.NewError(err)

cmd/tag-list.go

@@ -66,7 +66,8 @@ type tagList struct {
 // tagsetListMessage container for displaying tag
 type tagsetListMessage struct {
 	Tags   []tagList `json:"tagset,omitempty"`
-	Status string    `json:"status,omitempty"`
+	Status string    `json:"status"`
+	Name   string    `json:"name"`
 }
 
 func (t tagsetListMessage) JSON() string {
@@ -90,19 +91,20 @@ const (
 	tagPrintMsgTheme string = "Tag-PrintMsg"
 )
 
-// tagStr is in the format key1=value1&key1=value2
+// parseTagListMessage parses the tags(string) and initializes the structure tagsetListMessage.
+// tags(string) is in the format key1=value1&key1=value2
 func parseTagListMessage(tags string, urlStr string) tagsetListMessage {
 	var t tagsetListMessage
 	var tagStr string
 	var kvPairStr []string
 	tagStr = strings.Replace(tags, "\\u0026", "&", -1)
+	t.Name = getTagObjectName(urlStr)
 	if tagStr != "" {
 		kvPairStr = strings.SplitN(tagStr, "&", -1)
+		t.Status = "success"
+	} else {
+		t.Status = "error"
 	}
-	if len(kvPairStr) == 0 {
-		t.Status = "Tags not added or not available."
-	}
-
 	for _, kvPair := range kvPairStr {
 		kvPairSplit := splitStr(kvPair, "=", 2)
 		t.Tags = append(t.Tags, tagList{Key: kvPairSplit[0], Value: kvPairSplit[1]})
@@ -134,22 +136,25 @@ func checkListTagSyntax(ctx *cli.Context) {
 	}
 }
 
+func getTagObjectName(urlStr string) string {
+	if !strings.Contains(urlStr, "/") {
+		urlStr = filepath.ToSlash(urlStr)
+	}
+	splits := splitStr(urlStr, "/", 3)
+	object := splits[2]
+
+	return object
+}
+
 func listTagInfoFieldMultiple(urlStr string, kvpairs []tagging.Tag) {
-	var object string
-	var splits []string
 	padLen := len("Name")
 	for _, kv := range kvpairs {
 		if len(kv.Key) > padLen {
 			padLen = len(kv.Key)
 		}
 	}
 	padLen = listTagPaddingSpace(padLen)
-	if !strings.Contains(urlStr, "/") {
-		urlStr = filepath.ToSlash(urlStr)
-	}
-	splits = splitStr(urlStr, "/", 3)
-	object = splits[2]
-	objectName := fmt.Sprintf("%-*s:    %s", padLen, "Name", object)
+	objectName := fmt.Sprintf("%-*s:    %s", padLen, "Name", getTagObjectName(urlStr))
 	console.Println(console.Colorize(tagMainHeader, objectName))
 	for idx := 0; idx < len(kvpairs); idx++ {
 		displayField := fmt.Sprintf("%-*s:    %s", padLen, kvpairs[idx].Key, kvpairs[idx].Value)
@@ -176,26 +181,23 @@ func mainListTag(ctx *cli.Context) error {
 	setTagListColorScheme()
 	args := ctx.Args()
 	objectURL := args.Get(0)
-	tagObj, err := getObjTagging(objectURL)
-
-	if err != nil {
-		console.Errorln(err.Error() + ". Error getting tag for " + objectURL)
-		return err
+	var tagObj tagging.Tagging
+	var err error
+	if tagObj, err = getObjTagging(objectURL); err != nil {
+		fatal(probe.NewError(err), "Unable to get tags for target "+objectURL+".")
 	}
 
-	if globalJSON {
-		var tMsg tagsetListMessage
-		tMsg = parseTagListMessage(tagObj.String(), objectURL)
-		printMsg(tMsg)
-		return nil
-	}
 	switch len(tagObj.TagSet.Tags) {
 	case 0:
-		var tMsg tagsetListMessage
-		tMsg = parseTagListMessage(tagObj.String(), objectURL)
-		printMsg(tMsg)
+		errorIf(errDummy().Trace(objectURL), "Tags not set for "+getTagObjectName(objectURL)+".")
 	default:
-		listTagInfoFieldMultiple(objectURL, tagObj.TagSet.Tags)
+		if globalJSON {
+			var tMsg tagsetListMessage
+			tMsg = parseTagListMessage(tagObj.String(), objectURL)
+			printMsg(tMsg)
+		} else {
+			listTagInfoFieldMultiple(objectURL, tagObj.TagSet.Tags)
+		}
 	}
 
 	return nil

cmd/tag-main.go

@@ -29,7 +29,7 @@ var tagCmd = cli.Command{
 	Subcommands: []cli.Command{
 		tagListCmd,
 		tagRemoveCmd,
-		tagAddCmd,
+		tagSetCmd,
 	},
 }
 

cmd/tag-remove.go

@@ -20,7 +20,9 @@ import (
 	"os"
 
 	"github.com/minio/cli"
+	json "github.com/minio/mc/pkg/colorjson"
 	"github.com/minio/mc/pkg/probe"
+	"github.com/minio/minio/pkg/console"
 )
 
 var tagRemoveCmd = cli.Command{
@@ -42,29 +44,48 @@ DESCRIPTION:
    Remove object tags assigned to an object .
 
 EXAMPLES:
-  1. Remove the tags added to an existing object.
+  1. Remove the tags set to an existing object.
      {{.Prompt}} {{.HelpName}} s3/testbucket/testobject
 
 `,
 }
 
-func checkRemoveTagSyntax(ctx *cli.Context) {
-	if len(ctx.Args()) != 1 {
-		cli.ShowCommandHelp(ctx, "remove")
-		os.Exit(globalErrorExitStatus)
-	}
+// tagSetTagMessage structure will show message depending on the type of console.
+type tagRemoveMessage struct {
+	Status string `json:"status"`
+	Name   string `json:"name"`
+}
+
+// tagRemoveMessage console colorized output.
+func (t tagRemoveMessage) String() string {
+	return console.Colorize(tagPrintMsgTheme, "Tags removed for "+t.Name+".")
+}
+
+// JSON tagRemoveMessage.
+func (t tagRemoveMessage) JSON() string {
+	msgBytes, e := json.MarshalIndent(t, "", " ")
+	fatalIf(probe.NewError(e), "Unable to marshal into JSON.")
+	return string(msgBytes)
 }
 
-func parseTagRemoveMessage(tags string, urlStr string, err error) tagsetListMessage {
-	var t tagsetListMessage
+func parseTagRemoveMessage(tags string, urlStr string, err error) tagRemoveMessage {
+	var t tagRemoveMessage
+	t.Name = getTagObjectName(urlStr)
 	if err != nil {
-		t.Status = "Remove tags to target " + urlStr + ". Error " + err.Error()
+		t.Status = "error"
 	} else {
-		t.Status = "Tags removed for " + urlStr + "."
+		t.Status = "success"
 	}
 	return t
 }
 
+func checkRemoveTagSyntax(ctx *cli.Context) {
+	if len(ctx.Args()) != 1 {
+		cli.ShowCommandHelp(ctx, "remove")
+		os.Exit(globalErrorExitStatus)
+	}
+}
+
 func mainRemoveTag(ctx *cli.Context) error {
 	checkRemoveTagSyntax(ctx)
 	setTagListColorScheme()
@@ -73,9 +94,9 @@ func mainRemoveTag(ctx *cli.Context) error {
 	clnt, pErr := newClient(objectURL)
 	fatalIf(pErr.Trace(objectURL), "Unable to initialize target "+objectURL+".")
 	pErr = clnt.DeleteObjectTagging()
-	fatalIf(pErr, "Failed to remove tags")
+	fatalIf(pErr.Trace(objectURL), "Failed to remove tags")
 	tagObj, err := getObjTagging(objectURL)
-	var tMsg tagsetListMessage
+	var tMsg tagRemoveMessage
 	tMsg = parseTagRemoveMessage(tagObj.String(), objectURL, err)
 	printMsg(tMsg)