-
Notifications
You must be signed in to change notification settings - Fork 70
/
errors.go
151 lines (125 loc) · 4.05 KB
/
errors.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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
package papi
import (
"encoding/json"
"errors"
"fmt"
"io/ioutil"
"net/http"
"github.com/akamai/AkamaiOPEN-edgegrid-golang/v9/pkg/errs"
)
type (
// Error is a papi error interface
Error struct {
Type string `json:"type"`
Title string `json:"title,omitempty"`
Detail string `json:"detail"`
Instance string `json:"instance,omitempty"`
BehaviorName string `json:"behaviorName,omitempty"`
ErrorLocation string `json:"errorLocation,omitempty"`
StatusCode int `json:"statusCode,omitempty"`
Errors json.RawMessage `json:"errors,omitempty"`
Warnings json.RawMessage `json:"warnings,omitempty"`
LimitKey string `json:"limitKey,omitempty"`
Limit *int `json:"limit,omitempty"`
Remaining *int `json:"remaining,omitempty"`
}
// ActivationError represents errors returned in validation objects in include activation response
ActivationError struct {
Type string `json:"type"`
Title string `json:"title"`
Instance string `json:"instance"`
Status int `json:"status"`
Errors []ActivationErrorMessage `json:"errors"`
MessageID string `json:"messageId"`
Result string `json:"result"`
}
// ActivationErrorMessage represents detailed information about validation errors
ActivationErrorMessage struct {
Type string `json:"type"`
Title string `json:"title"`
Detail string `json:"detail"`
}
)
// Error parses an error from the response
func (p *papi) Error(r *http.Response) error {
var e Error
var body []byte
body, err := ioutil.ReadAll(r.Body)
if err != nil {
p.Log(r.Request.Context()).Errorf("reading error response body: %s", err)
e.StatusCode = r.StatusCode
e.Title = fmt.Sprintf("Failed to read error body")
e.Detail = err.Error()
return &e
}
if err := json.Unmarshal(body, &e); err != nil {
p.Log(r.Request.Context()).Errorf("could not unmarshal API error: %s", err)
e.Title = fmt.Sprintf("Failed to unmarshal error body. PAPI API failed. Check details for more information.")
e.Detail = errs.UnescapeContent(string(body))
}
e.StatusCode = r.StatusCode
return &e
}
func (e *Error) Error() string {
msg, err := json.MarshalIndent(e, "", "\t")
if err != nil {
return fmt.Sprintf("error marshaling API error: %s", err)
}
return fmt.Sprintf("API error: \n%s", msg)
}
func (e *ActivationError) Error() string {
msg, err := json.MarshalIndent(e, "", "\t")
if err != nil {
return fmt.Sprintf("error marshaling API error: %s", err)
}
return fmt.Sprintf("API error: \n%s", msg)
}
// Is handles error comparisons
func (e *Error) Is(target error) bool {
if errors.Is(target, ErrSBDNotEnabled) {
return e.isErrSBDNotEnabled()
}
if errors.Is(target, ErrDefaultCertLimitReached) {
return e.isErrDefaultCertLimitReached()
}
if errors.Is(target, ErrNotFound) {
return e.isErrNotFound()
}
var t *Error
if !errors.As(target, &t) {
return false
}
if e == t {
return true
}
if e.StatusCode != t.StatusCode {
return false
}
return e.Error() == t.Error()
}
// Is handles error comparisons for ActivationError type
func (e *ActivationError) Is(target error) bool {
if errors.Is(target, ErrMissingComplianceRecord) {
return e.MessageID == "missing_compliance_record"
}
var t *ActivationError
if !errors.As(target, &t) {
return false
}
if e == t {
return true
}
if e.Status != t.Status {
return false
}
return e.Error() == t.Error()
}
func (e *Error) isErrSBDNotEnabled() bool {
return e.StatusCode == http.StatusForbidden && e.Type == "https://problems.luna.akamaiapis.net/papi/v0/property-version-hostname/default-cert-provisioning-unavailable"
}
func (e *Error) isErrDefaultCertLimitReached() bool {
return e.StatusCode == http.StatusTooManyRequests && e.LimitKey == "DEFAULT_CERTS_PER_CONTRACT" && e.Remaining != nil && *e.Remaining == 0
}
func (e *Error) isErrNotFound() bool {
return e.StatusCode == http.StatusNotFound
}