sync.go

package main

import (
	"encoding/json"
	"errors"
	"fmt"
	"log"
	"strings"
	"time"

	"github.com/anyappinc/fitbit"
	"github.com/jovandeginste/workout-tracker/v2/pkg/app"
	"resty.dev/v3"
)

func (fs *fitbitSync) initRESTClient() {
	client := resty.New()
	client.SetBaseURL(fs.WorkoutConfig.URL + "/api/v1/")
	client.SetAuthToken(fs.WorkoutConfig.APIKey)

	fs.restClient = client
}

func (fs *fitbitSync) syncActivities(days int) {
	fs.initRESTClient()

	units := fs.fitbitClient.GetUnit()
	end := time.Now()
	endDate := end.Format("2006-01-02")
	start := end.AddDate(0, 0, -days)

	for d := start; !d.After(end); d = d.AddDate(0, 0, 1) {
		date := d.Format("2006-01-02")
		log.Printf("Syncing: %s\n", date)

		act, err := fs.getDailyActivitySummary(d)
		if err != nil {
			log.Printf("could not get daily activity summary: %v", err)
			continue
		}

		if act == nil {
			continue
		}

		if fs.WorkoutConfig.syncActivities {
			for _, a := range act.Activities {
				if !a.HasStartTime {
					continue
				}

				if err := fs.uploadActivity(a); err != nil {
					log.Printf("could not sync activity TCX: %v", err)
					continue
				}
			}
		}

		final := date == endDate

		mw := fs.buildMeasurement(date, final, units, act)
		if err := fs.postMeasurement(mw); err != nil {
			log.Printf("could not post measurement: %v", err)
		}
	}
}

func (fs *fitbitSync) buildMeasurement(date string, final bool, units *fitbit.Unit, act *fitbit.DailyActivitySummary) *app.Measurement {
	mw := &app.Measurement{
		Date: date,
	}

	if fs.WorkoutConfig.syncSteps {
		if act.Summary != nil {
			mw.Steps = float64(act.Summary.Steps)
		}
	}

	if !final {
		return mw
	}

	if fs.WorkoutConfig.syncHeight {
		mw.Height = fs.profile.Height
		mw.HeightUnit = units.Height
	}

	if fs.WorkoutConfig.syncWeight {
		mw.Weight = fs.profile.Weight
		mw.WeightUnit = units.Weight
	}

	return mw
}

func (fs *fitbitSync) postMeasurement(m *app.Measurement) error {
	res, err := fs.restClient.R().
		SetBody(m).
		Post("/daily")
	if err != nil {
		return err
	}

	if !res.IsSuccess() {
		return errors.New(res.Status())
	}

	return nil
}

func (fs *fitbitSync) uploadActivity(a fitbit.Activity) error {
	tcx, err := fs.getActivityTCX(a)
	if err != nil {
		return err
	}

	name := fmt.Sprintf("%d.tcx", a.LogID)

	res, err := fs.restClient.R().
		SetBody(tcx).
		SetQueryParam("name", name).
		Post("/import/generic")
	if err != nil {
		return err
	}

	var response app.APIResponse

	if err := json.Unmarshal(res.Bytes(), &response); err != nil {
		return err
	}

	if !res.IsSuccess() {
		return errors.New(res.Status() + ": " + strings.Join(response.Errors, ","))
	}

	return nil
}