X-Git-Url: https://git.octo.it/?p=kraftakt.git;a=blobdiff_plain;f=gfitsync.go;h=22f4c5668e63eac577830aca0fbc94bd04aed89c;hp=2bc3b738ed92408c94c573c0dea09aa9768ea53b;hb=43223a02eecd68642404b09c3085f435722cb144;hpb=a1803b210e15430a724d10e7370fd0a0e3256f8b

diff --git a/gfitsync.go b/gfitsync.go
index 2bc3b73..22f4c56 100644
--- a/gfitsync.go
+++ b/gfitsync.go
@@ -218,21 +218,31 @@ func handleNotification(ctx context.Context, s *fitbit.Subscription) error {
 	if err != nil {
 		return err
 	}
-	c, err := fitbit.NewClient(ctx, s.OwnerID, u)
+
+	tm, err := time.Parse("2006-01-02", s.Date)
 	if err != nil {
 		return err
 	}
 
-	tm, err := time.Parse("2006-01-02", s.Date)
+	fitbitClient, err := fitbit.NewClient(ctx, s.OwnerID, u)
 	if err != nil {
 		return err
 	}
 
-	summary, err := c.ActivitySummary(tm)
+	summary, err := fitbitClient.ActivitySummary(tm)
 	if err != nil {
 		return err
 	}
-
 	log.Debugf(ctx, "ActivitySummary for %s = %+v", u.Email, summary)
+
+	gfitClient, err := gfit.NewClient(ctx, u)
+	if err != nil {
+		return err
+	}
+
+	if err := gfitClient.SetSteps(ctx, summary.Summary.Steps, tm); err != nil {
+		return fmt.Errorf("gfitClient.SetSteps(%d) = %v", summary.Summary.Steps, err)
+	}
+
 	return nil
 }