15 "github.com/octo/gfitsync/app"
17 oauth2fitbit "golang.org/x/oauth2/fitbit"
18 "google.golang.org/appengine/log"
21 var oauth2Config = &oauth2.Config{
22 ClientID: "@FITBIT_CLIENT_ID@",
23 ClientSecret: "@FITBIT_CLIENT_SECRET@",
24 Endpoint: oauth2fitbit.Endpoint,
25 RedirectURL: "https://kraftakt.octo.it/fitbit/grant",
26 Scopes: []string{"activity", "heartrate", "profile"},
29 const csrfToken = "@CSRFTOKEN@"
31 func AuthURL() string {
32 return oauth2Config.AuthCodeURL(csrfToken, oauth2.AccessTypeOffline)
35 func ParseToken(ctx context.Context, r *http.Request, u *app.User) error {
36 if state := r.FormValue("state"); state != csrfToken {
37 return fmt.Errorf("invalid state parameter: %q", state)
40 tok, err := oauth2Config.Exchange(ctx, r.FormValue("code"))
45 return u.SetToken(ctx, "Fitbit", tok)
48 func CheckSignature(ctx context.Context, payload []byte, rawSig string) bool {
49 base64Sig, err := url.QueryUnescape(rawSig)
51 log.Errorf(ctx, "QueryUnescape(%q) = %v", rawSig, err)
54 signatureGot, err := base64.StdEncoding.DecodeString(base64Sig)
56 log.Errorf(ctx, "base64.StdEncoding.DecodeString(%q) = %v", base64Sig, err)
60 mac := hmac.New(sha1.New, []byte(oauth2Config.ClientSecret+"&"))
62 signatureWant := mac.Sum(nil)
64 return hmac.Equal(signatureGot, signatureWant)
67 type Activity struct {
68 ActivityID int `json:"activityId"`
69 ActivityParentID int `json:"activityParentId"`
70 Calories int `json:"calories"`
71 Description string `json:"description"`
72 Distance float64 `json:"distance"`
73 Duration int `json:"duration"`
74 HasStartTime bool `json:"hasStartTime"`
75 IsFavorite bool `json:"isFavorite"`
76 LogID int `json:"logId"`
77 Name string `json:"name"`
78 StartTime string `json:"startTime"`
79 Steps int `json:"steps"`
82 type Distance struct {
83 Activity string `json:"activity"`
84 Distance float64 `json:"distance"`
87 type HeartRateZone struct {
88 Name string `json:"name"`
91 Minutes int `json:"minutes"`
92 CaloriesOut float64 `json:"caloriesOut"`
95 type ActivitySummary struct {
96 Activities []Activity `json:"activities"`
98 CaloriesOut int `json:"caloriesOut"`
99 Distance float64 `json:"distance"`
100 Floors int `json:"floors"`
101 Steps int `json:"steps"`
104 ActiveScore int `json:"activeScore"`
105 ActivityCalories int `json:"activityCalories"`
106 CaloriesBMR int `json:"caloriesBMR"`
107 CaloriesOut float64 `json:"caloriesOut"`
108 Distances []Distance `json:"distances"`
109 Elevation float64 `json:"elevation"`
110 Floors int `json:"floors"`
111 HeartRateZones []HeartRateZone `json:"heartRateZones"`
112 CustomHeartRateZones []HeartRateZone `json:"customHeartRateZones"`
113 MarginalCalories int `json:"marginalCalories"`
114 RestingHeartRate int `json:"restingHeartRate"`
115 Steps int `json:"steps"`
116 SedentaryMinutes int `json:"sedentaryMinutes"`
117 LightlyActiveMinutes int `json:"lightlyActiveMinutes"`
118 FairlyActiveMinutes int `json:"fairlyActiveMinutes"`
119 VeryActiveMinutes int `json:"veryActiveMinutes"`
123 type Subscription struct {
124 CollectionType string `json:"collectionType"`
125 Date string `json:"date"`
126 OwnerID string `json:"ownerId"`
127 OwnerType string `json:"ownerType"`
128 SubscriptionID string `json:"subscriptionId"`
137 func NewClient(ctx context.Context, fitbitUserID string, u *app.User) (*Client, error) {
138 if fitbitUserID == "" {
142 c, err := u.OAuthClient(ctx, "Fitbit", oauth2Config)
148 fitbitUserID: fitbitUserID,
154 func (c *Client) ActivitySummary(t time.Time) (*ActivitySummary, error) {
155 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/activities/date/%s.json",
156 c.fitbitUserID, t.Format("2006-01-02"))
158 res, err := c.client.Get(url)
162 defer res.Body.Close()
164 var summary ActivitySummary
165 if err := json.NewDecoder(res.Body).Decode(&summary); err != nil {
172 func (c *Client) Subscribe(ctx context.Context, collection string) error {
173 subscriberID, err := c.appUser.ID(ctx)
178 url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/%s/apiSubscriptions/%s.json",
179 c.fitbitUserID, collection, subscriberID)
180 res, err := c.client.Post(url, "", nil)
184 defer res.Body.Close()
186 if res.StatusCode >= 400 {
187 data, _ := ioutil.ReadAll(res.Body)
188 log.Errorf(ctx, "creating subscription failed: status %d %q", res.StatusCode, data)
189 return fmt.Errorf("creating subscription failed")
195 type Profile struct {
197 Timezone *time.Location
200 func (c *Client) Profile(ctx context.Context) (*Profile, error) {
201 res, err := c.client.Get("https://api.fitbit.com/1/user/-/profile.json")
205 defer res.Body.Close()
207 if res.StatusCode >= 400 {
208 data, _ := ioutil.ReadAll(res.Body)
209 log.Errorf(ctx, "reading profile failed: %s", data)
210 return nil, fmt.Errorf("HTTP %d error", res.StatusCode)
216 OffsetFromUTCMillis int
220 if err := json.NewDecoder(res.Body).Decode(&data); err != nil {
224 loc, err := time.LoadLocation(data.User.Timezone)
226 loc = time.FixedZone("Fitbit preference", data.User.OffsetFromUTCMillis/1000)
230 Name: data.User.FullName,