This repository has been archived by the owner on Mar 23, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 1
/
deploy_test.go
127 lines (110 loc) · 2.83 KB
/
deploy_test.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
120
121
122
123
124
125
126
127
package rest
import (
"net/http"
"net/http/httptest"
"net/url"
"testing"
"time"
log "github.com/sirupsen/logrus"
"github.com/stretchr/testify/assert"
)
func TestDeploy(t *testing.T) {
t.Run("Doesn't return an error for a valid request", func(t *testing.T) {
deployRequest := DeployRequest{
Service: "my_service",
Description: "Deployed service",
Deployer: Deployer{
Email: "[email protected]",
},
Environment: "stage",
DeployedAt: time.Now(),
}
body := `
{
"result": "ok"
}
`
client, testServer := setupTest(202, body)
defer func() { testServer.Close() }()
err := client.Deploy(deployRequest, "uuid")
assert.NoError(t, err)
})
t.Run("Returns a Bad Request error on a 422", func(t *testing.T) {
deployRequest := DeployRequest{
Service: "my_service",
Description: "Deployed service",
Deployer: Deployer{
Email: "[email protected]",
},
Environment: "stage",
DeployedAt: time.Now(),
}
body := `
{
"errors":[
{"status":400,"title":"Deployed at Error","detail":"param is missing or the value is empty: deployed_at"}
]
}
`
client, testServer := setupTest(400, body)
defer func() { testServer.Close() }()
err := client.Deploy(deployRequest, "uuid")
assert.Error(t, err)
assert.Contains(t, err.Error(), "status 400")
})
t.Run("Returns a Something Went Wrong error on all other status codes", func(t *testing.T) {
deployRequest := DeployRequest{
Service: "my_service",
Description: "Deployed service",
Deployer: Deployer{
Email: "[email protected]",
},
Environment: "stage",
DeployedAt: time.Now(),
}
body := `
{
"errors":[
{"status":503,"title":"Service Unavailable"}
]
}
`
client, testServer := setupTest(503, body)
defer func() { testServer.Close() }()
err := client.Deploy(deployRequest, "uuid")
assert.Error(t, err)
assert.Contains(t, err.Error(), "status 503")
})
t.Run("Returns an error for an invalid request", func(t *testing.T) {
deployRequest := DeployRequest{
Service: "my_service",
Deployer: Deployer{
Email: "[email protected]",
},
DeployedAt: time.Now(),
}
body := `
{
"result": "ok"
}
`
client, testServer := setupTest(202, body)
defer func() { testServer.Close() }()
err := client.Deploy(deployRequest, "uuid")
assert.EqualError(t,
err,
"Key: 'DeployRequest.Description' Error:Field validation for 'Description' failed on the 'required' tag",
)
})
}
func setupTest(statusCode int, body string) (*Client, *httptest.Server) {
client := NewClient()
testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) {
res.WriteHeader(statusCode)
res.Write([]byte(body))
}))
testServerURL, _ := url.Parse(testServer.URL)
client.baseURL = testServerURL
log.SetLevel(log.DebugLevel)
return client, testServer
}