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
|
package packngo
import "fmt"
const eventBasePath = "/events"
// Event struct
type Event struct {
ID string `json:"id,omitempty"`
State string `json:"state,omitempty"`
Type string `json:"type,omitempty"`
Body string `json:"body,omitempty"`
Relationships []Href `json:"relationships,omitempty"`
Interpolated string `json:"interpolated,omitempty"`
CreatedAt *Timestamp `json:"created_at,omitempty"`
Href string `json:"href,omitempty"`
}
type eventsRoot struct {
Events []Event `json:"events,omitempty"`
Meta meta `json:"meta,omitempty"`
}
// EventService interface defines available event functions
type EventService interface {
List(*ListOptions) ([]Event, *Response, error)
Get(string, *GetOptions) (*Event, *Response, error)
}
// EventServiceOp implements EventService
type EventServiceOp struct {
client *Client
}
// List returns all events
func (s *EventServiceOp) List(listOpt *ListOptions) ([]Event, *Response, error) {
return listEvents(s.client, eventBasePath, listOpt)
}
// Get returns an event by ID
func (s *EventServiceOp) Get(eventID string, getOpt *GetOptions) (*Event, *Response, error) {
path := fmt.Sprintf("%s/%s", eventBasePath, eventID)
return get(s.client, path, getOpt)
}
// list helper function for all event functions
func listEvents(client *Client, path string, listOpt *ListOptions) (events []Event, resp *Response, err error) {
params := createListOptionsURL(listOpt)
path = fmt.Sprintf("%s?%s", path, params)
for {
subset := new(eventsRoot)
resp, err = client.DoRequest("GET", path, nil, subset)
if err != nil {
return nil, resp, err
}
events = append(events, subset.Events...)
if subset.Meta.Next != nil && (listOpt == nil || listOpt.Page == 0) {
path = subset.Meta.Next.Href
if params != "" {
path = fmt.Sprintf("%s&%s", path, params)
}
continue
}
return
}
}
// list helper function for all event functions
/*
func listEvents(client *Client, path string, listOpt *ListOptions) ([]Event, *Response, error) {
params := createListOptionsURL(listOpt)
root := new(eventsRoot)
path = fmt.Sprintf("%s?%s", path, params)
resp, err := client.DoRequest("GET", path, nil, root)
if err != nil {
return nil, resp, err
}
return root.Events, resp, err
}
*/
func get(client *Client, path string, getOpt *GetOptions) (*Event, *Response, error) {
params := createGetOptionsURL(getOpt)
event := new(Event)
path = fmt.Sprintf("%s?%s", path, params)
resp, err := client.DoRequest("GET", path, nil, event)
if err != nil {
return nil, resp, err
}
return event, resp, err
}
|
