-
Notifications
You must be signed in to change notification settings - Fork 0
/
build.go
119 lines (103 loc) · 2.59 KB
/
build.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
package jenkins
import (
"bufio"
"regexp"
)
type BuildItem struct {
*Item
ID int
}
func NewBuildItem(url, class string, client *Client) *BuildItem {
return &BuildItem{Item: NewItem(url, class, client), ID: parseId(url)}
}
func (b *BuildItem) LoopLog(f func(line string) error) error {
resp, err := b.Request("GET", "consoleText", ReqParams{})
if err != nil {
return err
}
defer resp.Response().Body.Close()
scanner := bufio.NewScanner(resp.Response().Body)
for scanner.Scan() {
if err := f(scanner.Text()); err != nil {
return err
}
}
if err := scanner.Err(); err != nil {
return err
}
return nil
}
func (b *BuildItem) IsBuilding() (bool, error) {
var build struct {
Class string `json:"_class"`
Building bool `json:"building"`
}
err := b.BindAPIJson(ReqParams{"tree": "building"}, &build)
return build.Building, err
}
func (b *BuildItem) GetResult() (string, error) {
status := make(map[string]string)
err := b.BindAPIJson(ReqParams{"tree": "result"}, &status)
return status["result"], err
}
func (b *BuildItem) Delete() error {
_, err := b.Request("POST", "doDelete")
return err
}
func (b *BuildItem) Stop() error {
_, err := b.Request("POST", "stop")
return err
}
func (b *BuildItem) Kill() error {
_, err := b.Request("POST", "kill")
return err
}
func (b *BuildItem) Term() error {
_, err := b.Request("POST", "term")
return err
}
var re = regexp.MustCompile(`\w+[/]?$`)
func (b *BuildItem) GetJob() (*JobItem, error) {
jobName, _ := b.client.URL2Name(re.ReplaceAllLiteralString(b.URL, ""))
return b.client.GetJob(jobName)
}
func (b *BuildItem) LoopProgressiveLog(kind string, f func(line string) error) error {
var entry string
switch kind {
case "html":
entry = "logText/progressiveHtml"
case "text":
entry = "logText/progressiveText"
default:
panic("kind must be html or text")
}
start := "0"
for {
resp, err := b.Request("GET", entry, ReqParams{"start": start})
if err != nil {
return err
}
if start == resp.Response().Header.Get("X-Text-Size") {
continue
}
if err := f(resp.String()); err != nil {
return err
}
if resp.Response().Header.Get("X-More-Data") != "true" {
break
}
start = resp.Response().Header.Get("X-Text-Size")
}
return nil
}
func (b *BuildItem) GetDescription() (string, error) {
data := make(map[string]string)
if err := b.BindAPIJson(ReqParams{"tree": "description"}, &data); err != nil {
return "", err
}
return data["description"], nil
}
func (b *BuildItem) SetDescription(description string) error {
_, err := b.Request("POST", "submitDescription", ReqParams{"description": description})
return err
}