Add lsticket subcommand

cmd/gocmd.go

@@ -79,6 +79,7 @@ func main() {
 	subcmd.AddSvrinfoCommand(rootCmd)
 	subcmd.AddPsCommand(rootCmd)
 	subcmd.AddCopySftpIdCommand(rootCmd)
+	subcmd.AddLsticketCommand(rootCmd)
 
 	err := Execute()
 	if err != nil {

cmd/subcmd/lsticket.go

@@ -0,0 +1,147 @@
+package subcmd
+
+import (
+	"fmt"
+	"os"
+
+	irodsclient_fs "github.com/cyverse/go-irodsclient/fs"
+	"github.com/cyverse/gocommands/commons"
+	log "github.com/sirupsen/logrus"
+	"github.com/spf13/cobra"
+)
+
+var lsticketCmd = &cobra.Command{
+	Use:   "lsticket [ticket_string1] [ticket_string2] ...",
+	Short: "List tickets for the user",
+	Long:  `This lists tickets for the user.`,
+	RunE:  processLsticketCommand,
+}
+
+func AddLsticketCommand(rootCmd *cobra.Command) {
+	// attach common flags
+	commons.SetCommonFlags(lsticketCmd)
+
+	rootCmd.AddCommand(lsticketCmd)
+}
+
+func processLsticketCommand(command *cobra.Command, args []string) error {
+	logger := log.WithFields(log.Fields{
+		"package":  "main",
+		"function": "processLsticketCommand",
+	})
+
+	cont, err := commons.ProcessCommonFlags(command)
+	if err != nil {
+		fmt.Fprintln(os.Stderr, err.Error())
+		return nil
+	}
+
+	if !cont {
+		return nil
+	}
+
+	// handle local flags
+	_, err = commons.InputMissingFields()
+	if err != nil {
+		logger.Error(err)
+		fmt.Fprintln(os.Stderr, err.Error())
+		return nil
+	}
+
+	// Create a file system
+	account := commons.GetAccount()
+	filesystem, err := commons.GetIRODSFSClient(account)
+	if err != nil {
+		logger.Error(err)
+		fmt.Fprintln(os.Stderr, err.Error())
+		return nil
+	}
+
+	defer filesystem.Release()
+
+	if len(args) == 0 {
+		err = listTickets(filesystem)
+		if err != nil {
+			logger.Error(err)
+			fmt.Fprintln(os.Stderr, err.Error())
+			return nil
+		}
+	} else {
+		for _, ticket := range args {
+			err = getTicket(filesystem, ticket)
+			if err != nil {
+				logger.Error(err)
+				fmt.Fprintln(os.Stderr, err.Error())
+				return nil
+			}
+		}
+	}
+
+	return nil
+}
+
+func listTickets(filesystem *irodsclient_fs.FileSystem) error {
+	logger := log.WithFields(log.Fields{
+		"package":  "main",
+		"function": "listTickets",
+	})
+
+	logger.Debug("listing tickets")
+
+	/*
+		// sort by name
+		sort.SliceStable(objs, func(i int, j int) bool {
+			return objs[i].Name < objs[j].Name
+		})
+
+
+		// print data objects first
+		for _, entry := range objs {
+			if veryLongFormat {
+				for _, replica := range entry.Replicas {
+					modTime := commons.MakeDateTimeString(replica.ModifyTime)
+					fmt.Printf("  %s\t%d\t%s\t%d\t%s\t&\t%s\n", replica.Owner, replica.Number, replica.ResourceHierarchy, entry.Size, modTime, entry.Name)
+					fmt.Printf("    %s\t%s\n", replica.CheckSum, replica.Path)
+				}
+			} else if longFormat {
+				for _, replica := range entry.Replicas {
+					modTime := commons.MakeDateTimeString(replica.ModifyTime)
+					fmt.Printf("  %s\t%d\t%s\t%d\t%s\t&\t%s\n", replica.Owner, replica.Number, replica.ResourceHierarchy, entry.Size, modTime, entry.Name)
+				}
+			} else {
+				fmt.Printf("  %s\n", entry.Name)
+			}
+		}
+	*/
+
+	return nil
+}
+
+func getTicket(filesystem *irodsclient_fs.FileSystem, ticket string) error {
+	logger := log.WithFields(log.Fields{
+		"package":  "main",
+		"function": "getTicket",
+	})
+
+	logger.Debugf("get ticket: %s", ticket)
+
+	ticketInfo, err := filesystem.GetTicketForAnonymousAccess(ticket)
+	if err != nil {
+		return err
+	}
+
+	fmt.Printf("[%s]\n", ticketInfo.Name)
+	fmt.Printf("  id: %d\n", ticketInfo.ID)
+	fmt.Printf("  string: %s\n", ticketInfo.Name)
+
+	if ticketInfo.ExpireTime.IsZero() {
+		fmt.Print("  expiry time: none\n")
+	} else {
+		fmt.Printf("  expiry time: %s\n", ticketInfo.ExpireTime)
+	}
+
+	fmt.Printf("  ticket type: %s\n", ticketInfo.Type)
+	fmt.Printf("  collection name: %s\n", ticketInfo.Path)
+
+	return nil
+}