add queue pause and resume

drone/build/build.go

@@ -14,7 +14,6 @@ var Command = cli.Command{
 		buildStartCmd,
 		buildApproveCmd,
 		buildDeclineCmd,
-		buildQueueCmd,
 		buildPromoteCmd,
 		buildRollbackCmd,
 	},

drone/build/build_queue.go

@@ -1,63 +1,63 @@
 package build
 
-import (
-	"fmt"
-	"os"
-	"text/template"
-
-	"github.com/drone/drone-cli/drone/internal"
-	"github.com/urfave/cli"
-)
-
-var buildQueueCmd = cli.Command{
-	Name:      "queue",
-	Usage:     "show build queue",
-	ArgsUsage: " ",
-	Action:    buildQueue,
-	Flags: []cli.Flag{
-		cli.StringFlag{
-			Name:  "format",
-			Usage: "format output",
-			Value: tmplBuildQueue,
-		},
-	},
-}
-
-func buildQueue(c *cli.Context) error {
-
-	client, err := internal.NewClient(c)
-	if err != nil {
-		return err
-	}
-
-	builds, err := client.BuildQueue()
-	if err != nil {
-		return err
-	}
-
-	if len(builds) == 0 {
-		fmt.Println("there are no pending or running builds")
-		return nil
-	}
-
-	tmpl, err := template.New("_").Parse(c.String("format") + "\n")
-	if err != nil {
-		return err
-	}
-
-	for _, build := range builds {
-		tmpl.Execute(os.Stdout, build)
-	}
-	return nil
-}
-
-// template for build list information
-var tmplBuildQueue = "\x1b[33m{{ .FullName }} #{{ .Number }} \x1b[0m" + `
-Status: {{ .Status }}
-Event: {{ .Event }}
-Commit: {{ .Commit }}
-Branch: {{ .Branch }}
-Ref: {{ .Ref }}
-Author: {{ .Author }} {{ if .AuthorEmail }}<{{.AuthorEmail}}>{{ end }}
-Message: {{ .Message }}
-`
+// import (
+// 	"fmt"
+// 	"os"
+// 	"text/template"
+
+// 	"github.com/drone/drone-cli/drone/internal"
+// 	"github.com/urfave/cli"
+// )
+
+// var buildQueueCmd = cli.Command{
+// 	Name:      "queue",
+// 	Usage:     "show build queue",
+// 	ArgsUsage: " ",
+// 	Action:    buildQueue,
+// 	Flags: []cli.Flag{
+// 		cli.StringFlag{
+// 			Name:  "format",
+// 			Usage: "format output",
+// 			Value: tmplBuildQueue,
+// 		},
+// 	},
+// }
+
+// func buildQueue(c *cli.Context) error {
+
+// 	client, err := internal.NewClient(c)
+// 	if err != nil {
+// 		return err
+// 	}
+
+// 	builds, err := client.BuildQueue()
+// 	if err != nil {
+// 		return err
+// 	}
+
+// 	if len(builds) == 0 {
+// 		fmt.Println("there are no pending or running builds")
+// 		return nil
+// 	}
+
+// 	tmpl, err := template.New("_").Parse(c.String("format") + "\n")
+// 	if err != nil {
+// 		return err
+// 	}
+
+// 	for _, build := range builds {
+// 		tmpl.Execute(os.Stdout, build)
+// 	}
+// 	return nil
+// }
+
+// // template for build list information
+// var tmplBuildQueue = "\x1b[33m{{ .FullName }} #{{ .Number }} \x1b[0m" + `
+// Status: {{ .Status }}
+// Event: {{ .Event }}
+// Commit: {{ .Commit }}
+// Branch: {{ .Branch }}
+// Ref: {{ .Ref }}
+// Author: {{ .Author }} {{ if .AuthorEmail }}<{{.AuthorEmail}}>{{ end }}
+// Message: {{ .Message }}
+// `

drone/main.go

@@ -14,6 +14,7 @@ import (
 	"github.com/drone/drone-cli/drone/jsonnet"
 	"github.com/drone/drone-cli/drone/log"
 	"github.com/drone/drone-cli/drone/plugins"
+	"github.com/drone/drone-cli/drone/queue"
 	"github.com/drone/drone-cli/drone/repo"
 	"github.com/drone/drone-cli/drone/secret"
 	"github.com/drone/drone-cli/drone/server"
@@ -80,6 +81,7 @@ func main() {
 		user.Command,
 		secret.Command,
 		server.Command,
+		queue.Command,
 		autoscale.Command,
 		format.Command,
 		sign.Command,

drone/queue/queue.go

@@ -0,0 +1,14 @@
+package queue
+
+import "github.com/urfave/cli"
+
+// Command exports the queue command set.
+var Command = cli.Command{
+	Name:  "queue",
+	Usage: "queue operations",
+	Subcommands: []cli.Command{
+		queueListCmd,
+		queuePauseCmd,
+		queueResumeCmd,
+	},
+}

drone/queue/queue_list.go

@@ -0,0 +1,58 @@
+package queue
+
+import (
+	"fmt"
+	"os"
+	"text/template"
+
+	"github.com/drone/drone-cli/drone/internal"
+	"github.com/urfave/cli"
+)
+
+var queueListCmd = cli.Command{
+	Name:   "ls",
+	Usage:  "list queue items",
+	Action: queueList,
+	Flags: []cli.Flag{
+		cli.StringFlag{
+			Name:  "format",
+			Usage: "format output",
+			Value: tmplStage,
+		},
+	},
+}
+
+func queueList(c *cli.Context) (err error) {
+	client, err := internal.NewClient(c)
+	if err != nil {
+		return err
+	}
+	builds, err := client.Queue()
+	if err != nil {
+		return err
+	}
+
+	if len(builds) == 0 {
+		fmt.Println("there are no pending or running builds")
+		return nil
+	}
+
+	tmpl, err := template.New("_").Parse(c.String("format") + "\n")
+	if err != nil {
+		return err
+	}
+
+	for _, build := range builds {
+		tmpl.Execute(os.Stdout, build)
+	}
+	return nil
+}
+
+var tmplStage = "\x1b[33mitem #{{ .ID }} \x1b[0m" + `
+Status: {{ .Status }}
+Machine: {{ .Machine }}
+OS: {{ .OS }}
+Arch: {{ .Arch }}
+Variant: {{ .Variant }}
+Version: {{ .Kernel }}
+`

drone/queue/queue_pause.go

@@ -0,0 +1,20 @@
+package queue
+
+import (
+	"github.com/drone/drone-cli/drone/internal"
+	"github.com/urfave/cli"
+)
+
+var queuePauseCmd = cli.Command{
+	Name:   "pause",
+	Usage:  "pause queue operations",
+	Action: queuePause,
+}
+
+func queuePause(c *cli.Context) (err error) {
+	client, err := internal.NewClient(c)
+	if err != nil {
+		return err
+	}
+	return client.QueuePause()
+}

drone/queue/queue_resume.go

@@ -0,0 +1,20 @@
+package queue
+
+import (
+	"github.com/drone/drone-cli/drone/internal"
+	"github.com/urfave/cli"
+)
+
+var queueResumeCmd = cli.Command{
+	Name:   "resume",
+	Usage:  "resume queue operations",
+	Action: queueResume,
+}
+
+func queueResume(c *cli.Context) (err error) {
+	client, err := internal.NewClient(c)
+	if err != nil {
+		return err
+	}
+	return client.QueueResume()
+}