-
Notifications
You must be signed in to change notification settings - Fork 2
/
Copy pathartifacts.go
72 lines (57 loc) · 1.99 KB
/
artifacts.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
package gocd
import (
"encoding/json"
"net/http"
"github.com/jinzhu/copier"
"github.com/nikhilsbhat/gocd-sdk-go/pkg/errors"
)
// UpdateArtifactConfig updates the artifact config with the latest config provided.
func (conf *client) UpdateArtifactConfig(info ArtifactInfo) (ArtifactInfo, error) {
newClient := &client{}
if err := copier.CopyWithOption(newClient, conf, copier.Option{IgnoreEmpty: true, DeepCopy: true}); err != nil {
return ArtifactInfo{}, err
}
var artifactInfo ArtifactInfo
resp, err := newClient.httpClient.R().
SetHeaders(map[string]string{
"Accept": HeaderVersionOne,
"Content-Type": ContentJSON,
"If-Match": info.ETAG,
}).
SetBody(info).
Put(ArtifactInfoEndpoint)
if err != nil {
return ArtifactInfo{}, &errors.APIError{Err: err, Message: "update artifacts info"}
}
if resp.StatusCode() != http.StatusOK {
return ArtifactInfo{}, &errors.NonOkError{Code: resp.StatusCode(), Response: resp}
}
if err = json.Unmarshal(resp.Body(), &artifactInfo); err != nil {
return ArtifactInfo{}, &errors.MarshalError{Err: err}
}
return artifactInfo, nil
}
// GetArtifactConfig fetches the latest artifact config available from GoCD.
func (conf *client) GetArtifactConfig() (ArtifactInfo, error) {
newClient := &client{}
if err := copier.CopyWithOption(newClient, conf, copier.Option{IgnoreEmpty: true, DeepCopy: true}); err != nil {
return ArtifactInfo{}, err
}
var artifactInfo ArtifactInfo
resp, err := newClient.httpClient.R().
SetHeaders(map[string]string{
"Accept": HeaderVersionOne,
}).
Get(ArtifactInfoEndpoint)
if err != nil {
return ArtifactInfo{}, &errors.APIError{Err: err, Message: "get artifacts info"}
}
if resp.StatusCode() != http.StatusOK {
return ArtifactInfo{}, &errors.NonOkError{Code: resp.StatusCode(), Response: resp}
}
if err = json.Unmarshal(resp.Body(), &artifactInfo); err != nil {
return ArtifactInfo{}, &errors.MarshalError{Err: err}
}
artifactInfo.ETAG = resp.Header().Get("ETag")
return artifactInfo, nil
}