14 "github.com/octo/kraftakt/app"
16 oauth2fitbit "golang.org/x/oauth2/fitbit"
17 "google.golang.org/appengine/log"
20 func oauthConfig() *oauth2.Config {
21 return &oauth2.Config{
22 ClientID: app.Config.FitbitClientID,
23 ClientSecret: app.Config.FitbitClientSecret,
24 Endpoint: oauth2fitbit.Endpoint,
25 RedirectURL: "https://kraftakt.octo.it/fitbit/grant",
35 func ParseToken(ctx context.Context, r *http.Request, u *app.User) error {
36 if state := r.FormValue("state"); state != u.Sign("Fitbit") {
37 return fmt.Errorf("invalid state parameter: %q", state)
40 tok, err := oauthConfig().Exchange(ctx, r.FormValue("code"))
45 return u.SetToken(ctx, "Fitbit", tok)
48 func CheckSignature(ctx context.Context, payload []byte, rawSig string) bool {
49 signatureGot, err := base64.StdEncoding.DecodeString(rawSig)
51 log.Errorf(ctx, "base64.StdEncoding.DecodeString(%q) = %v", rawSig, err)
55 mac := hmac.New(sha1.New, []byte(oauthConfig().ClientSecret+"&"))
57 signatureWant := mac.Sum(nil)
59 return hmac.Equal(signatureGot, signatureWant)
62 type Activity struct {
63 ActivityID int `json:"activityId"`
64 ActivityParentID int `json:"activityParentId"`
65 ActivityParentName string `json:"activityParentName"`
66 Calories int `json:"calories"`
67 Description string `json:"description"`
68 Distance float64 `json:"distance"`
69 Duration int `json:"duration"`
70 HasStartTime bool `json:"hasStartTime"`
71 IsFavorite bool `json:"isFavorite"`
72 LastModified time.Time `json:"lastModified"`
73 LogID int `json:"logId"`
74 Name string `json:"name"`
75 StartTime string `json:"startTime"`
76 StartDate string `json:"startDate"`
77 Steps int `json:"steps"`
80 type Distance struct {
81 Activity string `json:"activity"`
82 Distance float64 `json:"distance"`
85 type HeartRateZone struct {
86 Name string `json:"name"`
89 Minutes int `json:"minutes"`
90 CaloriesOut float64 `json:"caloriesOut"`
93 type ActivitySummary struct {
94 Activities []Activity `json:"activities"`
96 CaloriesOut int `json:"caloriesOut"`
97 Distance float64 `json:"distance"`
98 Floors int `json:"floors"`
99 Steps int `json:"steps"`
102 ActiveScore int `json:"activeScore"`
103 ActivityCalories int `json:"activityCalories"`
104 CaloriesBMR int `json:"caloriesBMR"`
105 CaloriesOut float64 `json:"caloriesOut"`
106 Distances []Distance `json:"distances"`
107 Elevation float64 `json:"elevation"`
108 Floors int `json:"floors"`
109 HeartRateZones []HeartRateZone `json:"heartRateZones"`
110 CustomHeartRateZones []HeartRateZone `json:"customHeartRateZones"`
111 MarginalCalories int `json:"marginalCalories"`
112 RestingHeartRate int `json:"restingHeartRate"`
113 Steps int `json:"steps"`
114 SedentaryMinutes int `json:"sedentaryMinutes"`
115 LightlyActiveMinutes int `json:"lightlyActiveMinutes"`
116 FairlyActiveMinutes int `json:"fairlyActiveMinutes"`
117 VeryActiveMinutes int `json:"veryActiveMinutes"`
121 type Subscription struct {
122 CollectionType string `json:"collectionType"`
123 Date string `json:"date"`
124 OwnerID string `json:"ownerId"`
125 OwnerType string `json:"ownerType"`
126 SubscriptionID string `json:"subscriptionId"`
135 func NewClient(ctx context.Context, fitbitUserID string, u *app.User) (*Client, error) {
136 if fitbitUserID == "" {
140 c, err := u.OAuthClient(ctx, "Fitbit", oauthConfig())
146 fitbitUserID: fitbitUserID,
152 func (c *Client) AuthURL(ctx context.Context) string {
153 return oauthConfig().AuthCodeURL(c.appUser.Sign("Fitbit"), oauth2.AccessTypeOffline)
156 func (c *Client) ActivitySummary(ctx context.Context, date string) (*ActivitySummary, error) {
157 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/activities/date/%s.json",
158 c.fitbitUserID, date)
160 res, err := c.client.Get(url)
164 defer res.Body.Close()
166 data, _ := ioutil.ReadAll(res.Body)
167 log.Debugf(ctx, "GET %s -> %s", url, data)
169 var summary ActivitySummary
170 if err := json.Unmarshal(data, &summary); err != nil {
177 func (c *Client) Subscribe(ctx context.Context, collection string) error {
178 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/%s/apiSubscriptions/%s.json",
179 c.fitbitUserID, collection, c.appUser.ID)
180 res, err := c.client.Post(url, "", nil)
184 defer res.Body.Close()
186 if res.StatusCode >= 400 && res.StatusCode != http.StatusConflict {
187 data, _ := ioutil.ReadAll(res.Body)
188 log.Errorf(ctx, "creating %q subscription failed: status %d %q", collection, res.StatusCode, data)
189 return fmt.Errorf("creating %q subscription failed", collection)
195 func (c *Client) Unsubscribe(ctx context.Context, collection string) error {
196 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/%s/apiSubscriptions/%s.json",
197 c.fitbitUserID, collection, c.appUser.ID)
198 req, err := http.NewRequest(http.MethodDelete, url, nil)
203 res, err := c.client.Do(req.WithContext(ctx))
207 defer res.Body.Close()
209 if res.StatusCode >= 400 && res.StatusCode != http.StatusNotFound {
210 data, _ := ioutil.ReadAll(res.Body)
211 log.Errorf(ctx, "deleting %q subscription failed: status %d %q", collection, res.StatusCode, data)
212 return fmt.Errorf("deleting %q subscription failed", collection)
218 func (c *Client) DeleteToken(ctx context.Context) error {
219 return c.appUser.DeleteToken(ctx, "Fitbit")
222 type Profile struct {
224 Timezone *time.Location
227 func (c *Client) Profile(ctx context.Context) (*Profile, error) {
228 res, err := c.client.Get("https://api.fitbit.com/1/user/-/profile.json")
232 defer res.Body.Close()
234 if res.StatusCode >= 400 {
235 data, _ := ioutil.ReadAll(res.Body)
236 log.Errorf(ctx, "reading profile failed: %s", data)
237 return nil, fmt.Errorf("HTTP %d error", res.StatusCode)
243 OffsetFromUTCMillis int
247 if err := json.NewDecoder(res.Body).Decode(&data); err != nil {
251 loc, err := time.LoadLocation(data.User.Timezone)
253 loc = time.FixedZone("Fitbit preference", data.User.OffsetFromUTCMillis/1000)
257 Name: data.User.FullName,