Skip to content

Commit 86de12b

Browse files
committed
fix review
1 parent 58052ef commit 86de12b

File tree

1 file changed

+8
-54
lines changed

1 file changed

+8
-54
lines changed

api/domain/v2beta1/domain_utils.go

Lines changed: 8 additions & 54 deletions
Original file line numberDiff line numberDiff line change
@@ -158,31 +158,16 @@ func (s *RegistrarAPI) WaitForOrderDomain(
158158
retryInterval = *req.RetryInterval
159159
}
160160

161-
// Terminal statuses indicating success
161+
// Terminal statuses indicating success or error.
162162
terminalStatuses := map[DomainStatus]struct{}{
163-
DomainStatusActive: {},
164-
DomainStatusExpired: {},
165-
DomainStatusExpiring: {},
166-
DomainStatusLocked: {},
167-
}
168-
169-
// Terminal statuses indicating errors
170-
errorStatuses := map[DomainStatus]struct{}{
163+
DomainStatusActive: {},
164+
DomainStatusExpired: {},
165+
DomainStatusLocked: {},
171166
DomainStatusCreateError: {},
172167
DomainStatusRenewError: {},
173168
DomainStatusXferError: {},
174169
}
175170

176-
// Transient statuses
177-
transientStatuses := map[DomainStatus]struct{}{
178-
DomainStatusCreating: {},
179-
DomainStatusRenewing: {},
180-
DomainStatusXfering: {},
181-
DomainStatusUpdating: {},
182-
DomainStatusChecking: {},
183-
DomainStatusDeleting: {},
184-
}
185-
186171
var lastStatus DomainStatus
187172

188173
domain, err := async.WaitSync(&async.WaitSyncConfig{
@@ -196,29 +181,16 @@ func (s *RegistrarAPI) WaitForOrderDomain(
196181

197182
lastStatus = resp.Status
198183

199-
// Terminal success statuses
200184
if _, isTerminal := terminalStatuses[resp.Status]; isTerminal {
201185
return resp, true, nil
202186
}
203-
204-
// Terminal error statuses
205-
if _, isError := errorStatuses[resp.Status]; isError {
206-
return nil, true, errors.New("domain entered error status: " + string(resp.Status))
207-
}
208-
209-
// Transient statuses
210-
if _, isTransient := transientStatuses[resp.Status]; isTransient {
211-
return resp, false, nil
212-
}
213-
214-
// Unexpected status
215-
return nil, false, errors.New("unexpected domain status: " + string(resp.Status))
187+
return resp, false, nil
216188
},
217189
Timeout: timeout,
218190
IntervalStrategy: async.LinearIntervalStrategy(retryInterval),
219191
})
220192
if err != nil {
221-
return nil, errors.Wrap(err, "waiting for domain %s failed, last known status: %s", req.Domain, lastStatus)
193+
return nil, errors.Wrap(err, fmt.Sprintf("waiting for domain %s failed, last known status: %s", req.Domain, lastStatus))
222194
}
223195

224196
return domain.(*Domain), nil
@@ -249,33 +221,23 @@ func (s *RegistrarAPI) WaitForAutoRenewStatus(req *WaitForAutoRenewStatusRequest
249221
DomainFeatureStatusEnabled: {},
250222
DomainFeatureStatusDisabled: {},
251223
}
252-
// Transient statuses for auto_renew: enabling or disabling.
253-
transientStatuses := map[DomainFeatureStatus]struct{}{
254-
DomainFeatureStatusEnabling: {},
255-
DomainFeatureStatusDisabling: {},
256-
}
257224

258225
var lastStatus DomainFeatureStatus
259226

260227
domainResult, err := async.WaitSync(&async.WaitSyncConfig{
261228
Get: func() (interface{}, bool, error) {
262-
// Retrieve the domain.
263229
resp, err := s.GetDomain(&RegistrarAPIGetDomainRequest{
264230
Domain: req.Domain,
265231
}, opts...)
266232
if err != nil {
267233
return nil, false, err
268234
}
269235

270-
// Check the current auto_renew status.
271236
lastStatus = resp.AutoRenewStatus
272237
if _, isTerminal := terminalStatuses[resp.AutoRenewStatus]; isTerminal {
273238
return resp, true, nil
274239
}
275-
if _, isTransient := transientStatuses[resp.AutoRenewStatus]; isTransient {
276-
return resp, false, nil
277-
}
278-
return nil, false, errors.New("unexpected auto_renew status: " + string(resp.AutoRenewStatus))
240+
return resp, false, nil
279241
},
280242
Timeout: timeout,
281243
IntervalStrategy: async.LinearIntervalStrategy(retryInterval),
@@ -311,11 +273,6 @@ func (s *RegistrarAPI) WaitForDNSSECStatus(req *WaitForDNSSECStatusRequest, opts
311273
DomainFeatureStatusEnabled: {},
312274
DomainFeatureStatusDisabled: {},
313275
}
314-
// Transient statuses for DNSSEC: enabling or disabling.
315-
transientStatuses := map[DomainFeatureStatus]struct{}{
316-
DomainFeatureStatusEnabling: {},
317-
DomainFeatureStatusDisabling: {},
318-
}
319276

320277
var lastStatus DomainFeatureStatus
321278

@@ -334,10 +291,7 @@ func (s *RegistrarAPI) WaitForDNSSECStatus(req *WaitForDNSSECStatusRequest, opts
334291
if _, isTerminal := terminalStatuses[resp.Dnssec.Status]; isTerminal {
335292
return resp, true, nil
336293
}
337-
if _, isTransient := transientStatuses[resp.Dnssec.Status]; isTransient {
338-
return resp, false, nil
339-
}
340-
return nil, false, errors.New("unexpected dnssec status: " + string(resp.Dnssec.Status))
294+
return resp, false, nil
341295
},
342296
Timeout: timeout,
343297
IntervalStrategy: async.LinearIntervalStrategy(retryInterval),

0 commit comments

Comments
 (0)