X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=fitbit%2Ffitbit.go;h=36a6e87b386f49c60eb789f81172953a5617b0bb;hb=92093b34c3443824b0ce6de91acc86469636ce2f;hp=394cfd8c94496e2a6dc641ee929123deacb3c451;hpb=e0dd0f79fe96f749e19fac2401f751d841fc19b5;p=kraftakt.git

diff --git a/fitbit/fitbit.go b/fitbit/fitbit.go
index 394cfd8..36a6e87 100644
--- a/fitbit/fitbit.go
+++ b/fitbit/fitbit.go
@@ -17,7 +17,6 @@ import (
 	"google.golang.org/appengine/log"
 )
 
-
 func oauthConfig() *oauth2.Config {
 	return &oauth2.Config{
 		ClientID:     app.Config.FitbitClientID,
@@ -193,13 +192,45 @@ func (c *Client) Subscribe(ctx context.Context, collection string) error {
 
 	if res.StatusCode >= 400 && res.StatusCode != http.StatusConflict {
 		data, _ := ioutil.ReadAll(res.Body)
-		log.Errorf(ctx, "creating subscription failed: status %d %q", res.StatusCode, data)
-		return fmt.Errorf("creating subscription failed")
+		log.Errorf(ctx, "creating %q subscription failed: status %d %q", collection, res.StatusCode, data)
+		return fmt.Errorf("creating %q subscription failed", collection)
 	}
 
 	return nil
 }
 
+func (c *Client) Unsubscribe(ctx context.Context, collection string) error {
+	subscriberID, err := c.appUser.ID(ctx)
+	if err != nil {
+		return err
+	}
+
+	url := fmt.Sprintf("https://api.fitbit.com/1/user/%s/%s/apiSubscriptions/%s.json",
+		c.fitbitUserID, collection, subscriberID)
+	req, err := http.NewRequest(http.MethodDelete, url, nil)
+	if err != nil {
+		return err
+	}
+
+	res, err := c.client.Do(req.WithContext(ctx))
+	if err != nil {
+		return err
+	}
+	defer res.Body.Close()
+
+	if res.StatusCode >= 400 && res.StatusCode != http.StatusNotFound {
+		data, _ := ioutil.ReadAll(res.Body)
+		log.Errorf(ctx, "deleting %q subscription failed: status %d %q", collection, res.StatusCode, data)
+		return fmt.Errorf("deleting %q subscription failed", collection)
+	}
+
+	return nil
+}
+
+func (c *Client) DeleteToken(ctx context.Context) error {
+	return c.appUser.DeleteToken(ctx, "Fitbit")
+}
+
 type Profile struct {
 	Name     string
 	Timezone *time.Location