/
subscription.go
77 lines (66 loc) · 2.32 KB
/
subscription.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
package fitbit
import (
"encoding/json"
"errors"
"fmt"
)
// Subscription contains response and request data of fitbit eventsx
type Subscription struct {
CollectionType string `json:"collectionType"`
Date string `json:"date,omitempty"`
OwnerID string `json:"ownerId"`
OwnerType string `json:"ownerType"`
SubscriberID string `json:"subscriberId"`
SubscriptionID string `json:"subscriptionId"`
}
// SubscriptionList contains a list of current active subscriptions
type SubscriptionList struct {
APISubscriptions []Subscription `json:"apiSubscriptions"`
}
// AddSubscription adds a new subscription where fitbit sends a request on changes caused by the user
func (m *Session) AddSubscription(collectionPath string, uniqueID int) (bool, Subscription, error) {
if uniqueID == 0 {
return false, Subscription{}, errors.New("no unique subscription id given")
}
if collectionPath != "" {
collectionPath += "/"
}
contents, err := m.makePOSTRequest(fmt.Sprintf("https://api.fitbit.com/1/user/-/%sapiSubscriptions/%d.json", collectionPath, uniqueID), nil)
if err != nil {
return false, Subscription{}, err
}
subscription := Subscription{}
if err := json.Unmarshal(contents, &subscription); err != nil {
return false, Subscription{}, err
}
return true, subscription, nil
}
// RemoveSubscription removes a previously added subscription
func (m *Session) RemoveSubscription(collectionPath string, uniqueID int) (bool, error) {
if uniqueID == 0 {
return false, errors.New("no unique subscription id given")
}
if collectionPath != "" {
collectionPath += "/"
}
_, err := m.makeDELETERequest(fmt.Sprintf("https://api.fitbit.com/1/user/-/%sapiSubscriptions/%d.json", collectionPath, uniqueID))
if err != nil {
return false, err
}
return true, nil
}
// GetSubscriptions get's a list of current subscriptions
func (m *Session) GetSubscriptions(collectionPath string) (bool, SubscriptionList, error) {
if collectionPath != "" {
collectionPath += "/"
}
contents, err := m.makePOSTRequest(fmt.Sprintf("https://api.fitbit.com/1/user/-/%sapiSubscriptions.json", collectionPath), nil)
if err != nil {
return false, SubscriptionList{}, err
}
subscription := SubscriptionList{}
if err := json.Unmarshal(contents, &subscription); err != nil {
return false, SubscriptionList{}, err
}
return true, subscription, nil
}