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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
|
package fastly
import (
"fmt"
"github.com/dnaeon/go-vcr/recorder"
"sync"
"testing"
)
// testClient is the test client.
var testClient = DefaultClient()
// testStatsClient is the test client for realtime stats.
var testStatsClient = NewRealtimeStatsClient()
// testServiceID is the ID of the testing service.
var testServiceID = "7i6HN3TK9wS159v2gPAZ8A"
// testVersionLock is a lock around version creation because the Fastly API
// kinda dies on concurrent requests to create a version.
var testVersionLock sync.Mutex
func record(t *testing.T, fixture string, f func(*Client)) {
r, err := recorder.New("fixtures/" + fixture)
if err != nil {
t.Fatal(err)
}
defer func() {
if err := r.Stop(); err != nil {
t.Fatal(err)
}
}()
client := DefaultClient()
client.HTTPClient.Transport = r
f(client)
}
func recordRealtimeStats(t *testing.T, fixture string, f func(*RTSClient)) {
r, err := recorder.New("fixtures/" + fixture)
if err != nil {
t.Fatal(err)
}
defer func() {
if err := r.Stop(); err != nil {
t.Fatal(err)
}
}()
client := NewRealtimeStatsClient()
client.client.HTTPClient.Transport = r
f(client)
}
func createTestService(t *testing.T, serviceFixture string, serviceNameSuffix string) *Service {
var err error
var service *Service
record(t, serviceFixture, func(client *Client) {
service, err = client.CreateService(&CreateServiceInput{
Name: fmt.Sprintf("test_service_%s", serviceNameSuffix),
Comment: "go-fastly client test",
})
})
if err != nil {
t.Fatal(err)
}
return service
}
// testVersion is a new, blank version suitable for testing.
func testVersion(t *testing.T, c *Client) *Version {
testVersionLock.Lock()
defer testVersionLock.Unlock()
v, err := c.CreateVersion(&CreateVersionInput{
Service: testServiceID,
})
if err != nil {
t.Fatal(err)
}
return v
}
func createTestVersion(t *testing.T, versionFixture string, serviceId string) *Version {
var err error
var version *Version
record(t, versionFixture, func(client *Client) {
testVersionLock.Lock()
defer testVersionLock.Unlock()
version, err = client.CreateVersion(&CreateVersionInput{
Service: serviceId,
})
if err != nil {
t.Fatal(err)
}
})
return version
}
func createTestDictionary(t *testing.T, dictionaryFixture string, serviceId string, version int, dictionaryNameSuffix string) *Dictionary {
var err error
var dictionary *Dictionary
record(t, dictionaryFixture, func(client *Client) {
dictionary, err = client.CreateDictionary(&CreateDictionaryInput{
Service: serviceId,
Version: version,
Name: fmt.Sprintf("test_dictionary_%s", dictionaryNameSuffix),
})
})
if err != nil {
t.Fatal(err)
}
return dictionary
}
func deleteTestDictionary(t *testing.T, dictionary *Dictionary, deleteFixture string) {
var err error
record(t, deleteFixture, func(client *Client) {
err = client.DeleteDictionary(&DeleteDictionaryInput{
Service: dictionary.ServiceID,
Version: dictionary.Version,
Name: dictionary.Name,
})
})
if err != nil {
t.Fatal(err)
}
}
func createTestACL(t *testing.T, createFixture string, serviceId string, version int, aclNameSuffix string) *ACL {
var err error
var acl *ACL
record(t, createFixture, func(client *Client) {
acl, err = client.CreateACL(&CreateACLInput{
Service: serviceId,
Version: version,
Name: fmt.Sprintf("test_acl_%s", aclNameSuffix),
})
})
if err != nil {
t.Fatal(err)
}
return acl
}
func deleteTestACL(t *testing.T, acl *ACL, deleteFixture string) {
var err error
record(t, deleteFixture, func(client *Client) {
err = client.DeleteACL(&DeleteACLInput{
Service: acl.ServiceID,
Version: acl.Version,
Name: acl.Name,
})
})
if err != nil {
t.Fatal(err)
}
}
func deleteTestService(t *testing.T, cleanupFixture string, serviceId string){
var err error
record(t, cleanupFixture, func(client *Client) {
err = client.DeleteService(&DeleteServiceInput{
ID: serviceId,
})
})
if err != nil {
t.Fatal(err)
}
}
// privatekey returns a ASN.1 DER encoded key suitable for testing.
func privateKey() string {
return `-----BEGIN PRIVATE KEY-----
MIICXAIBAAKBgQCukSu6ece/5jlgnNiLK7mIxJuLLeZ1FI/rn0PK8XTO+vSZjV+o
vXpiSiXavXv2XhQymAf/tOpDV+uBxIzM3E1wyQ2qUxFjZ1zJHqBlmK+QJeg7pKmD
gVQrzdtfUYGTlpizMiucWyYJYHNdfIkoD9N+wSw/cM/kxHa8fYtGsN3M7wIDAQAB
AoGAOXiBtPqy0HKzISOCBw92HZjcvI13+cOzPhdI8l9b3WixbnwkqiD3UbSnkcQg
M5P1glKbD4w4M8OWPTrAQBGnTJa2iA7z9IqTGL7dwhVnQ04NYq14CpPs+XCKwOxK
O0gEjgbjlPNyE3OsMNBFMB5rnsVEI8uUukBmm/h6l8x7HUECQQDCeatYbfZZ8ra3
twTCmuc4qEXMzLhxBq7Ogyst90mC1fhfxFKiXwu0WVJqeGSFrK1upHPDfPJ3JN75
CDskG9YzAkEA5csoxhmPblUOG3e/Vt8dzjPlk/ZTgxEOKPb86BUprsR2J1aJVHVH
EoZjlAj5yo7iNSphp4cVXJd8I+ZsYSeaVQJBAJIF+5N9lcG6Tlop0SgyWbWgHDEH
8uHjS7SCpxRvnsHf2gxGhGmpBkfX3dtWJNx+aQcv8kBx/Dlb9RR2irm1MSMCQCmM
xICdWovuoTBiRJymlzMTuy032v3V9aN+lVg5i2HocBzIzugQlJtK5XJ89P2lPE20
rhemmzw0v+OV5H7ktEkCQDqLUZyqnGHX6qV+8eJMafLyy1AUfzSkbuZ/nX6hed8T
cfzsfBxi4bN4JOkJcA77FpXDecX/GDwzRN+yfwNs3+0=
-----END PRIVATE KEY-----
`
}
|
