aboutsummaryrefslogtreecommitdiff
path: root/web/climb-backfill.go
diff options
context:
space:
mode:
Diffstat (limited to 'web/climb-backfill.go')
-rw-r--r--web/climb-backfill.go81
1 files changed, 0 insertions, 81 deletions
diff --git a/web/climb-backfill.go b/web/climb-backfill.go
deleted file mode 100644
index 13a8c02..0000000
--- a/web/climb-backfill.go
+++ /dev/null
@@ -1,81 +0,0 @@
-package web
-
-import (
- "database/sql"
- "log/slog"
-
- "github.com/martinlehoux/biking_home/config"
- "github.com/martinlehoux/biking_home/mountain_pass"
- "github.com/martinlehoux/biking_home/official_climb"
- "github.com/martinlehoux/biking_home/ride"
- "github.com/martinlehoux/biking_home/rideanalysis"
- "github.com/martinlehoux/kagamigo/kcore"
- "github.com/schollz/progressbar/v3"
-)
-
-// BackfillOfficialClimbAttempts parses every route-bearing ride, matches its
-// official climbs, and persists the resulting attempts. An optional reporter
-// is invoked with progress for CLI rendering.
-func BackfillOfficialClimbAttempts(db *sql.DB, configPath string, reporters ...func(current, total int)) (int, error) {
- appConfig, err := config.Load(configPath)
- if err != nil {
- return 0, err
- }
- matchPolicy := official_climb.DefaultMatchPolicy()
- matchPolicy.EndpointRadiusM = appConfig.OfficialClimb.MatchRadiusM
- items, err := ride.List(db)
- if err != nil {
- return 0, err
- }
- officialClimbs, err := official_climb.List(db)
- if err != nil {
- return 0, err
- }
- var bar *progressbar.ProgressBar
- report := func(int, int) {}
- if len(reporters) > 0 {
- report = reporters[0]
- }
- backfilled := 0
- for i, item := range items {
- report(i+1, len(items))
- if item.FitPath == "" && item.GPXPath == "" {
- continue
- }
- parsed, err := ride.ParseStoredRide(item)
- if err != nil {
- slog.Warn("Failed to parse ride for climb backfill", "ride_id", item.ID, "error", err)
- continue
- }
- passes, err := mountain_pass.LoadMountainPassesAroundRide(db, parsed.Coords, rideDetailMountainPassMarginM)
- if err != nil {
- slog.Warn("Failed to load passes for climb backfill", "ride_id", item.ID, "error", err)
- }
- analysis := rideanalysis.Analyze(parsed, passes, officialClimbs, matchPolicy)
- attempts := attemptsFromAnalysis(item.ID, analysis, parsed)
- if err := official_climb.ReplaceRideAttempts(db, item.ID, attempts); err != nil {
- slog.Warn("Failed to record climb attempts", "ride_id", item.ID, "error", err)
- continue
- }
- backfilled++
- }
- if bar != nil {
- bar.Finish()
- }
- return backfilled, nil
-}
-
-// BackfillOfficialClimbAttemptsCmd runs the climb attempt backfill from the CLI.
-func BackfillOfficialClimbAttemptsCmd(db *sql.DB, configPath string) {
- var bar *progressbar.ProgressBar
- count, err := BackfillOfficialClimbAttempts(db, configPath, func(current, total int) {
- if bar == nil && mountain_pass.ProgressBarEnabled() {
- bar = progressbar.Default(int64(total), "Backfilling climb attempts")
- }
- if bar != nil {
- bar.Set(current)
- }
- })
- kcore.Expect(err, "failed to backfill climb attempts")
- slog.Info("Backfilled climb attempts", "rides", count)
-}