提交 1e10cd45 编写于 作者: LinuxSuRen's avatar LinuxSuRen

Add queue as subcmd

上级 cda23f29
package cmd
import (
"fmt"
"log"
"github.com/linuxsuren/jenkins-cli/client"
"github.com/spf13/cobra"
)
type QueueOption struct {
OutputOption
}
var queueOption QueueOption
func init() {
rootCmd.AddCommand(queueCmd)
queueCmd.PersistentFlags().StringVarP(&queueOption.Format, "output", "o", "json", "Format the output")
}
var queueCmd = &cobra.Command{
Use: "queue",
Short: "Print the queue of your Jenkins",
Long: `Print the queue of your Jenkins`,
Run: func(cmd *cobra.Command, args []string) {
jenkins := getCurrentJenkins()
jclient := &client.QueueClient{}
jclient.URL = jenkins.URL
jclient.UserName = jenkins.UserName
jclient.Token = jenkins.Token
if status, err := jclient.Get(); err == nil {
var data []byte
if data, err = Format(status, queueOption.Format); err == nil {
fmt.Printf("%s\n", string(data))
} else {
log.Fatal(err)
}
} else {
log.Fatal(err)
}
},
}
package client
import (
"crypto/tls"
"encoding/json"
"fmt"
"io/ioutil"
"log"
"net/http"
)
type QueueClient struct {
JenkinsCore
}
func (q *QueueClient) Get() (status *JobQueue, err error) {
api := fmt.Sprintf("%s/queue/api/json", q.URL)
var (
req *http.Request
response *http.Response
)
req, err = http.NewRequest("GET", api, nil)
if err == nil {
q.AuthHandle(req)
} else {
return
}
tr := &http.Transport{
TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
}
client := &http.Client{Transport: tr}
if response, err = client.Do(req); err == nil {
code := response.StatusCode
var data []byte
data, err = ioutil.ReadAll(response.Body)
if code == 200 {
if err == nil {
status = &JobQueue{}
err = json.Unmarshal(data, status)
}
} else {
log.Fatal(string(data))
}
} else {
log.Fatal(err)
}
return
}
type JobQueue struct {
Items []QueueItem
}
type QueueItem struct {
Blocked bool
Buildable bool
ID int
Params string
Pending bool
Stuck bool
URL string
Why string
BuildableStartMilliseconds int64
InQueueSince int64
Actions []CauseAction
}
type CauseAction struct {
Causes []Cause
}
type Cause struct {
UpstreamUrl string
UpstreamProject string
UpstreamBuild int
ShortDescription string
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册