forked from gophercloud/gophercloud
-
Notifications
You must be signed in to change notification settings - Fork 0
/
results.go
131 lines (111 loc) · 3.09 KB
/
results.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
package policies
import (
"encoding/json"
"github.com/chjlangzi/gophercloud"
"github.com/chjlangzi/gophercloud/internal"
"github.com/chjlangzi/gophercloud/pagination"
)
// Policy is an arbitrarily serialized policy engine rule
// set to be consumed by a remote service.
type Policy struct {
// ID is the unique ID of the policy.
ID string `json:"id"`
// Blob is the policy rule as a serialized blob.
Blob string `json:"blob"`
// Type is the MIME media type of the serialized policy blob.
Type string `json:"type"`
// Links contains referencing links to the policy.
Links map[string]interface{} `json:"links"`
// Extra is a collection of miscellaneous key/values.
Extra map[string]interface{} `json:"-"`
}
func (r *Policy) UnmarshalJSON(b []byte) error {
type tmp Policy
var s struct {
tmp
Extra map[string]interface{} `json:"extra"`
}
err := json.Unmarshal(b, &s)
if err != nil {
return err
}
*r = Policy(s.tmp)
// Collect other fields and bundle them into Extra
// but only if a field titled "extra" wasn't sent.
if s.Extra != nil {
r.Extra = s.Extra
} else {
var result interface{}
err := json.Unmarshal(b, &result)
if err != nil {
return err
}
if resultMap, ok := result.(map[string]interface{}); ok {
r.Extra = internal.RemainingKeys(Policy{}, resultMap)
}
}
return err
}
type policyResult struct {
gophercloud.Result
}
// CreateResult is the response from a Create operation. Call its Extract method
// to interpret it as a Policy
type CreateResult struct {
policyResult
}
// GetResult is the response from a Get operation. Call its Extract method
// to interpret it as a Policy.
type GetResult struct {
policyResult
}
// UpdateResult is the response from an Update operation. Call its Extract
// method to interpret it as a Policy.
type UpdateResult struct {
policyResult
}
// DeleteResult is the response from a Delete operation. Call its ExtractErr to
// determine if the request succeeded or failed.
type DeleteResult struct {
gophercloud.ErrResult
}
// PolicyPage is a single page of Policy results.
type PolicyPage struct {
pagination.LinkedPageBase
}
// IsEmpty determines whether or not a page of Policies contains any results.
func (r PolicyPage) IsEmpty() (bool, error) {
policies, err := ExtractPolicies(r)
return len(policies) == 0, err
}
// NextPageURL extracts the "next" link from the links section of the result.
func (r PolicyPage) NextPageURL() (string, error) {
var s struct {
Links struct {
Next string `json:"next"`
Previous string `json:"previous"`
} `json:"links"`
}
err := r.ExtractInto(&s)
if err != nil {
return "", err
}
return s.Links.Next, err
}
// ExtractPolicies returns a slice of Policies
// contained in a single page of results.
func ExtractPolicies(r pagination.Page) ([]Policy, error) {
var s struct {
Policies []Policy `json:"policies"`
}
err := (r.(PolicyPage)).ExtractInto(&s)
return s.Policies, err
}
// Extract interprets any policyResults as a Policy.
func (r policyResult) Extract() (*Policy, error) {
var s struct {
Policy *Policy `json:"policy"`
}
err := r.ExtractInto(&s)
return s.Policy, err
}