main.go

package main

import (
	"fmt"
	"os"

	"github.com/code-with-brian/frugal-thinker-sync/strava"
	"github.com/jinzhu/gorm"
	_ "github.com/jinzhu/gorm/dialects/sqlite"
	"github.com/joho/godotenv"
)

func init() {
	err := godotenv.Load()
	if err != nil {
		fmt.Println("Error loading .env file:", err)
		os.Exit(1)
	}
}

func main() {
	db, err := gorm.Open("sqlite3", os.Getenv("SQLITE_PATH"))
	if err != nil {
		fmt.Println("Error connecting to the database:", err)
		os.Exit(1)
	}
	defer db.Close()

	db.AutoMigrate(&strava.Activity{})

	credentials := strava.StravaCredentials{
		ClientID:     os.Getenv("STRAVA_CLIENT_ID"),
		ClientSecret: os.Getenv("STRAVA_SECRET"),
		RefreshToken: os.Getenv("STRAVA_REFRESH_TOKEN"),
		GrantType:    "refresh_token",
	}

	newToken, err := strava.RefreshToken(credentials)
	if err != nil {
		fmt.Println("Error refreshing token:", err)
		os.Exit(1)
	}

	activities, err := strava.FetchActivities(newToken.AccessToken)
	if err != nil {
		fmt.Println("Error fetching activities:", err)
		os.Exit(1)
	}

	// Debug print to check the fetched activities
	fmt.Printf("Fetched %d activities\n", len(activities))
	for _, activity := range activities {
		var existingActivity strava.Activity
		if db.Where("id = ?", activity.ID).First(&existingActivity).RecordNotFound() {
			err := db.Create(&activity).Error
			if err != nil {
				fmt.Println("Error saving activity to the database:", err)
			} else {
				fmt.Printf("Activity %d saved successfully\n", activity.ID)
			}
		} else {
			fmt.Printf("Activity %d already exists, skipping\n", activity.ID)
		}
	}
}