-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathclient_test.go
More file actions
246 lines (230 loc) · 6.29 KB
/
client_test.go
File metadata and controls
246 lines (230 loc) · 6.29 KB
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
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
package volcengine
import (
"context"
"net/http"
"testing"
"github.com/libdns/libdns"
)
func Test_ListZones(t *testing.T) {
// Test ListZones API to get zone list
err := p0.getClient()
if err != nil {
t.Log("err:", err)
return
}
zones, err := p0.listZones(context.TODO(), 1, 10)
t.Log("zones:", zones, "err:", err)
if err != nil {
t.Log("err:", err)
return
}
for _, zone := range zones {
t.Logf("Zone: %s, ZID: %d", zone.ZoneName, zone.ZID)
}
}
func Test_ClientAPIReq(t *testing.T) {
// Use ListRecords API to get DNS record list
// Note: ZID should be obtained from query results, using example value for testing here
zid := int64(304092) // Example ZID, should be obtained by querying records in actual use
err := p0.getClient()
if err != nil {
t.Log("err:", err)
return
}
p0.client.SetAction("ListRecords")
p0.client.SetRequestBody("ZID", zid)
p0.client.SetRequestBody("PageSize", 10)
var rspData volcRecordListResult
err = p0.client.doAPIRequest(context.TODO(), &rspData, http.MethodGet)
t.Log("req", p0.client.schema, "data", rspData, "err:", err)
}
func Test_QueryDomainRecord(t *testing.T) {
r0, err := p0.queryDomainRecord(context.TODO(), "*", "example.com", "A", "1.1.1.1")
t.Log("result:", r0)
if err != nil {
t.Log("err:", err)
t.Fail()
return
}
t.Log("result with A rec:", r0, "err:", err)
}
func Test_QueryDomainRecords(t *testing.T) {
// Test method 1: Query using ZID (if Provider.ZID is set)
if p0.ZID > 0 {
r0, err := p0.queryDomainRecords(context.TODO(), p0.ZID)
t.Log("result (by ZID):", r0, "err:", err)
return
}
// Test method 2: Query using domain name (look up ZID via ListZones)
zone := "example.com" // Example domain name, replace with real domain name in actual use
zid, err := p0.getZIDByZone(context.TODO(), zone)
if err != nil {
t.Log("err:", err)
return
}
r0, err := p0.queryDomainRecords(context.TODO(), zid)
t.Log("result (by zone):", r0, "err:", err)
}
func Test_DomainRecordOp(t *testing.T) {
// Test DNS record CRUD operations
// Supports three methods: 1. Use ZID (Provider.ZID) 2. Use Zone (Provider.Zone) 3. Use zone parameter
// Priority: ZID > Zone > zone parameter
var zid int64
var err error
if p0.ZID > 0 {
zid = p0.ZID
t.Log("Using ZID:", zid)
} else if p0.Zone != "" {
// Use Provider.Zone, automatically look up ZID via getZID
zid, err = p0.getZID(context.TODO(), "")
if err != nil {
t.Log("err:", err)
return
}
t.Log("Using Zone:", p0.Zone, "ZID:", zid)
} else {
// Look up ZID by domain name
zone := "example.com" // Example domain name, replace with real domain name in actual use
zid, err = p0.getZIDByZone(context.TODO(), zone)
if err != nil {
t.Log("err:", err)
return
}
t.Log("Using zone:", zone, "ZID:", zid)
}
err = p0.getClient()
if err != nil {
t.Log("err:", err)
return
}
dr0 := volcDomainRecord{
DomainName: "example.com",
Host: "test",
DomainType: "A",
Value: "1.1.1.1",
TTL: 600,
ZID: zid,
}
r0, err := p0.addDomainRecord(context.TODO(), dr0)
t.Log("add result:", r0, "err:", err)
if err != nil {
return
}
dr0.RecordID = r0
dr0, err = p0.getDomainRecord(context.TODO(), r0)
t.Log("get result:", dr0, "err:", err)
if err != nil {
return
}
dr0.Host = "test2"
r0, err = p0.setDomainRecord(context.TODO(), dr0)
t.Log("set result:", r0, "err:", err)
if err != nil {
return
}
r0, err = p0.delDomainRecord(context.TODO(), dr0)
t.Log("del result:", r0, "err:", err)
}
func Test_GetRecordsByZone(t *testing.T) {
// Test getting DNS record list by domain name
zone := "example.com" // Example domain name, replace with real domain name in actual use
records, err := p0.GetRecords(context.TODO(), zone)
t.Log("records:", records, "err:", err)
if err != nil {
t.Log("err:", err)
return
}
for _, record := range records {
tmp := record.RR()
t.Logf("Record: %s, Type: %s, Value: %s", tmp.Name, tmp.Type, tmp.Data)
}
}
func Test_DeleteRecords(t *testing.T) {
// Test deleting DNS records using DeleteRecords method
// Supports three methods: 1. Use ZID (Provider.ZID) 2. Use Zone (Provider.Zone) 3. Use zone parameter
// Priority: ZID > Zone > zone parameter
var zid int64
var err error
var zone string
// Get ZID using priority order
if p0.ZID > 0 {
zid = p0.ZID
t.Log("Using ZID:", zid)
// Get zone name from ZID for testing
err = p0.getClient()
if err != nil {
t.Log("err:", err)
return
}
zones, err := p0.listZones(context.TODO(), 1, 100)
if err != nil {
t.Log("err:", err)
return
}
for _, z := range zones {
if z.ZID == zid {
zone = z.ZoneName
break
}
}
if zone == "" {
t.Log("Zone not found for ZID:", zid)
return
}
} else if p0.Zone != "" {
zone = p0.Zone
zid, err = p0.getZID(context.TODO(), "")
if err != nil {
t.Log("err:", err)
return
}
t.Log("Using Zone:", zone, "ZID:", zid)
} else {
zone = "example.com" // Example domain name, replace with real domain name in actual use
zid, err = p0.getZIDByZone(context.TODO(), zone)
if err != nil {
t.Log("err:", err)
return
}
t.Log("Using zone:", zone, "ZID:", zid)
}
// Step 1: Create a test record first
err = p0.getClient()
if err != nil {
t.Log("err:", err)
return
}
testHost := "_test_delete"
testValue := "test-delete-value"
// Step 2: Construct libdns.Record directly from the created record
// Use DomainRecord which implements libdns.Record interface
recordToDelete := DomainRecord{
Type: "TXT",
Name: testHost + "." + zone, // Full domain name
Value: testValue,
// TTL: 600,
}
// Step 3: Delete the record using DeleteRecords method
deletedRecords, err := p0.DeleteRecords(context.TODO(), zone, []libdns.Record{recordToDelete})
if err != nil {
t.Fatal("Failed to delete record:", err)
return
}
t.Log("Successfully deleted record:", deletedRecords)
// Step 4: Verify the record is deleted by querying again
recordsAfterDelete, err := p0.GetRecords(context.TODO(), zone)
if err != nil {
t.Log("Failed to verify deletion:", err)
return
}
for _, rec := range recordsAfterDelete {
recRR := rec.RR()
if recRR.Name == testHost+"."+zone || recRR.Name == testHost {
if recRR.Type == "TXT" && recRR.Data == `"`+testValue+`"` {
t.Log("WARNING: Record still exists after deletion!")
return
}
}
}
t.Log("Verification passed: Record successfully deleted")
}