14 "github.com/octo/kraftakt/app"
16 oauth2fitbit "golang.org/x/oauth2/fitbit"
17 "google.golang.org/appengine/log"
21 func oauthConfig() *oauth2.Config {
22 return &oauth2.Config{
23 ClientID: app.Config.FitbitClientID,
24 ClientSecret: app.Config.FitbitClientSecret,
25 Endpoint: oauth2fitbit.Endpoint,
26 RedirectURL: "https://kraftakt.octo.it/fitbit/grant",
36 const csrfToken = "@CSRFTOKEN@"
38 func AuthURL() string {
39 return oauthConfig().AuthCodeURL(csrfToken, oauth2.AccessTypeOffline)
42 func ParseToken(ctx context.Context, r *http.Request, u *app.User) error {
43 if state := r.FormValue("state"); state != csrfToken {
44 return fmt.Errorf("invalid state parameter: %q", state)
47 tok, err := oauthConfig().Exchange(ctx, r.FormValue("code"))
52 return u.SetToken(ctx, "Fitbit", tok)
55 func CheckSignature(ctx context.Context, payload []byte, rawSig string) bool {
56 signatureGot, err := base64.StdEncoding.DecodeString(rawSig)
58 log.Errorf(ctx, "base64.StdEncoding.DecodeString(%q) = %v", rawSig, err)
62 mac := hmac.New(sha1.New, []byte(oauthConfig().ClientSecret+"&"))
64 signatureWant := mac.Sum(nil)
66 return hmac.Equal(signatureGot, signatureWant)
69 type Activity struct {
70 ActivityID int `json:"activityId"`
71 ActivityParentID int `json:"activityParentId"`
72 ActivityParentName string `json:"activityParentName"`
73 Calories int `json:"calories"`
74 Description string `json:"description"`
75 Distance float64 `json:"distance"`
76 Duration int `json:"duration"`
77 HasStartTime bool `json:"hasStartTime"`
78 IsFavorite bool `json:"isFavorite"`
79 LastModified time.Time `json:"lastModified"`
80 LogID int `json:"logId"`
81 Name string `json:"name"`
82 StartTime string `json:"startTime"`
83 StartDate string `json:"startDate"`
84 Steps int `json:"steps"`
87 type Distance struct {
88 Activity string `json:"activity"`
89 Distance float64 `json:"distance"`
92 type HeartRateZone struct {
93 Name string `json:"name"`
96 Minutes int `json:"minutes"`
97 CaloriesOut float64 `json:"caloriesOut"`
100 type ActivitySummary struct {
101 Activities []Activity `json:"activities"`
103 CaloriesOut int `json:"caloriesOut"`
104 Distance float64 `json:"distance"`
105 Floors int `json:"floors"`
106 Steps int `json:"steps"`
109 ActiveScore int `json:"activeScore"`
110 ActivityCalories int `json:"activityCalories"`
111 CaloriesBMR int `json:"caloriesBMR"`
112 CaloriesOut float64 `json:"caloriesOut"`
113 Distances []Distance `json:"distances"`
114 Elevation float64 `json:"elevation"`
115 Floors int `json:"floors"`
116 HeartRateZones []HeartRateZone `json:"heartRateZones"`
117 CustomHeartRateZones []HeartRateZone `json:"customHeartRateZones"`
118 MarginalCalories int `json:"marginalCalories"`
119 RestingHeartRate int `json:"restingHeartRate"`
120 Steps int `json:"steps"`
121 SedentaryMinutes int `json:"sedentaryMinutes"`
122 LightlyActiveMinutes int `json:"lightlyActiveMinutes"`
123 FairlyActiveMinutes int `json:"fairlyActiveMinutes"`
124 VeryActiveMinutes int `json:"veryActiveMinutes"`
128 type Subscription struct {
129 CollectionType string `json:"collectionType"`
130 Date string `json:"date"`
131 OwnerID string `json:"ownerId"`
132 OwnerType string `json:"ownerType"`
133 SubscriptionID string `json:"subscriptionId"`
142 func NewClient(ctx context.Context, fitbitUserID string, u *app.User) (*Client, error) {
143 if fitbitUserID == "" {
147 c, err := u.OAuthClient(ctx, "Fitbit", oauthConfig())
153 fitbitUserID: fitbitUserID,
159 func (c *Client) ActivitySummary(ctx context.Context, date string) (*ActivitySummary, error) {
160 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/activities/date/%s.json",
161 c.fitbitUserID, date)
163 res, err := c.client.Get(url)
167 defer res.Body.Close()
169 data, _ := ioutil.ReadAll(res.Body)
170 log.Debugf(ctx, "GET %s -> %s", url, data)
172 var summary ActivitySummary
173 if err := json.Unmarshal(data, &summary); err != nil {
180 func (c *Client) Subscribe(ctx context.Context, collection string) error {
181 subscriberID, err := c.appUser.ID(ctx)
186 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/%s/apiSubscriptions/%s.json",
187 c.fitbitUserID, collection, subscriberID)
188 res, err := c.client.Post(url, "", nil)
192 defer res.Body.Close()
194 if res.StatusCode >= 400 && res.StatusCode != http.StatusConflict {
195 data, _ := ioutil.ReadAll(res.Body)
196 log.Errorf(ctx, "creating subscription failed: status %d %q", res.StatusCode, data)
197 return fmt.Errorf("creating subscription failed")
203 func (c *Client) Unsubscribe(ctx context.Context) error {
204 subscriberID, err := c.appUser.ID(ctx)
209 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/apiSubscriptions/%s.json",
210 c.fitbitUserID, subscriberID)
211 req, err := http.NewRequest(http.MethodDelete, url, nil)
216 res, err := c.client.Do(req.WithContext(ctx))
220 defer res.Body.Close()
222 if res.StatusCode >= 400 && res.StatusCode != http.StatusConflict {
223 data, _ := ioutil.ReadAll(res.Body)
224 log.Errorf(ctx, "creating subscription failed: status %d %q", res.StatusCode, data)
225 return fmt.Errorf("deleting subscription failed")
231 func (c *Client) DeleteToken(ctx context.Context) error {
232 return c.appUser.DeleteToken(ctx, "Fitbit")
235 type Profile struct {
237 Timezone *time.Location
240 func (c *Client) Profile(ctx context.Context) (*Profile, error) {
241 res, err := c.client.Get("https://api.fitbit.com/1/user/-/profile.json")
245 defer res.Body.Close()
247 if res.StatusCode >= 400 {
248 data, _ := ioutil.ReadAll(res.Body)
249 log.Errorf(ctx, "reading profile failed: %s", data)
250 return nil, fmt.Errorf("HTTP %d error", res.StatusCode)
256 OffsetFromUTCMillis int
260 if err := json.NewDecoder(res.Body).Decode(&data); err != nil {
264 loc, err := time.LoadLocation(data.User.Timezone)
266 loc = time.FixedZone("Fitbit preference", data.User.OffsetFromUTCMillis/1000)
270 Name: data.User.FullName,