forked from vmware-archive/fly
/
helpers.go
83 lines (69 loc) · 1.88 KB
/
helpers.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
package commands
import (
"errors"
"fmt"
"io/ioutil"
"log"
"net/http"
"github.com/concourse/atc"
"github.com/concourse/go-concourse/concourse"
)
func handleBadResponse(process string, resp *http.Response) {
b, err := ioutil.ReadAll(resp.Body)
resp.Body.Close()
if err != nil {
log.Fatalln("failed to read response when %s:", process, err)
}
log.Fatalf("bad response when %s:\n%s\n%s", process, resp.Status, b)
}
func GetBuild(client concourse.Client, jobName string, buildNameOrID string, pipelineName string) (atc.Build, error) {
if pipelineName != "" && jobName == "" {
log.Fatalln("job must be specified if pipeline is specified")
}
if pipelineName == "" && jobName != "" {
log.Fatalln("pipeline must be specified if job is specified")
}
if buildNameOrID != "" {
var build atc.Build
var err error
var found bool
if jobName != "" {
build, found, err = client.JobBuild(pipelineName, jobName, buildNameOrID)
} else {
build, found, err = client.Build(buildNameOrID)
}
if err != nil {
return atc.Build{}, fmt.Errorf("failed to get build %s", err)
}
if !found {
return atc.Build{}, errors.New("build not found")
}
return build, nil
} else if jobName != "" {
job, found, err := client.Job(pipelineName, jobName)
if err != nil {
return atc.Build{}, fmt.Errorf("failed to get job %s", err)
}
if !found {
return atc.Build{}, errors.New("job not found")
}
if job.NextBuild != nil {
return *job.NextBuild, nil
} else if job.FinishedBuild != nil {
return *job.FinishedBuild, nil
} else {
return atc.Build{}, errors.New("job has no builds")
}
} else {
allBuilds, err := client.AllBuilds()
if err != nil {
return atc.Build{}, fmt.Errorf("failed to get builds %s", err)
}
for _, build := range allBuilds {
if build.JobName == "" {
return build, nil
}
}
return atc.Build{}, errors.New("no builds match job")
}
}