10 "github.com/octo/gfitsync/app"
12 oauth2google "golang.org/x/oauth2/google"
13 fitness "google.golang.org/api/fitness/v1"
14 "google.golang.org/api/googleapi"
15 "google.golang.org/appengine"
16 "google.golang.org/appengine/log"
20 csrfToken = "@CSRFTOKEN@"
24 var oauthConfig = &oauth2.Config{
25 ClientID: "@GOOGLE_CLIENT_ID@",
26 ClientSecret: "@GOOGLE_CLIENT_SECRET@",
27 Endpoint: oauth2google.Endpoint,
28 RedirectURL: "https://fitbit-gfit-sync.appspot.com/google/grant",
30 fitness.FitnessActivityWriteScope,
31 fitness.FitnessBodyWriteScope,
35 func Application(ctx context.Context) *fitness.Application {
36 return &fitness.Application{
37 Name: "Fitbit to Google Fit sync",
38 Version: appengine.VersionID(ctx),
39 DetailsUrl: "", // optional
43 func AuthURL() string {
44 return oauthConfig.AuthCodeURL(csrfToken, oauth2.AccessTypeOffline)
47 func ParseToken(ctx context.Context, r *http.Request, u *app.User) error {
48 if state := r.FormValue("state"); state != csrfToken {
49 return fmt.Errorf("invalid state parameter: %q", state)
52 tok, err := oauthConfig.Exchange(ctx, r.FormValue("code"))
57 return u.SetToken(ctx, "Google", tok)
64 func NewClient(ctx context.Context, u *app.User) (*Client, error) {
65 c, err := u.OAuthClient(ctx, "Google", oauthConfig)
70 service, err := fitness.New(c)
80 func DataStreamID(dataSource *fitness.DataSource) string {
83 dataSource.DataType.Name,
84 "@PROJECT_NUMBER@", // FIXME
87 if dev := dataSource.Device; dev != nil {
88 if dev.Manufacturer != "" {
89 fields = append(fields, dev.Manufacturer)
92 fields = append(fields, dev.Model)
95 fields = append(fields, dev.Uid)
99 return strings.Join(fields, ":")
102 func (c *Client) DataSourceCreate(ctx context.Context, dataSource *fitness.DataSource) (string, error) {
103 res, err := c.Service.Users.DataSources.Create(userID, dataSource).Context(ctx).Do()
105 if gerr, ok := err.(*googleapi.Error); ok && gerr.Code == http.StatusConflict {
106 if dataSource.DataStreamId != "" {
107 return dataSource.DataStreamId, nil
109 return DataStreamID(dataSource), nil
111 log.Errorf(ctx, "c.Service.Users.DataSources.Create() = (%+v, %v)", res, err)
114 return res.DataStreamId, nil
117 func (c *Client) DataSetPatch(ctx context.Context, dataSourceID string, points []*fitness.DataPoint) error {
118 startTimeNanos, endTimeNanos := int64(-1), int64(-1)
119 for _, p := range points {
120 if startTimeNanos == -1 || startTimeNanos > p.StartTimeNanos {
121 startTimeNanos = p.StartTimeNanos
123 if endTimeNanos == -1 || endTimeNanos < p.EndTimeNanos {
124 endTimeNanos = p.EndTimeNanos
127 datasetID := fmt.Sprintf("%d-%d", startTimeNanos, endTimeNanos)
129 dataset := &fitness.Dataset{
130 DataSourceId: dataSourceID,
131 MinStartTimeNs: startTimeNanos,
132 MaxEndTimeNs: endTimeNanos,
136 _, err := c.Service.Users.DataSources.Datasets.Patch(userID, dataSourceID, datasetID, dataset).Context(ctx).Do()
138 log.Errorf(ctx, "c.Service.Users.DataSources.Datasets.Patch() = %v", err)
144 func (c *Client) SetSteps(ctx context.Context, steps int, date time.Time) error {
145 const dataTypeName = "com.google.step_count.delta"
147 dataSourceID, err := c.DataSourceCreate(ctx, &fitness.DataSource{
148 Application: Application(ctx),
149 DataStreamId: "", // COMPUTED
150 DataStreamName: "", // "daily summary"?
151 DataType: &fitness.DataType{
152 Field: []*fitness.DataTypeField{
153 &fitness.DataTypeField{
167 return c.DataSetPatch(ctx, dataSourceID, []*fitness.DataPoint{
169 ComputationTimeMillis: time.Now().UnixNano() / 1000000,
170 DataTypeName: dataTypeName,
171 StartTimeNanos: date.UnixNano(),
172 EndTimeNanos: date.Add(24 * time.Hour).Add(-1 * time.Nanosecond).UnixNano(),
173 Value: []*fitness.Value{
175 IntVal: int64(steps),