feat:#150 extracted functions rewrote error pipe for feed routes

This commit is contained in:
Elmar Kresse
2024-01-22 15:04:50 +01:00
parent 70170054e8
commit 1582154d5f
5 changed files with 234 additions and 139 deletions

View File

@@ -10,7 +10,6 @@ import (
"htwkalender/service/fetch/sport"
v2 "htwkalender/service/fetch/v2"
"htwkalender/service/functions/time"
"log"
"log/slog"
"strconv"
)
@@ -38,27 +37,28 @@ func AddSchedules(app *pocketbase.PocketBase) {
// Every sunday at 2am fetch all sport events (5 segments - minute, hour, day, month, weekday) "0 2 * * 0"
scheduler.MustAdd("fetchSportEvents", "0 3 * * 0", func() {
slog.Info("Started fetching sport events schedule")
sport.FetchAndUpdateSportEvents(app)
sportEvents, err := sport.FetchAndUpdateSportEvents(app)
if err != nil {
slog.Error("Failed to fetch and save sport events: %v", err)
}
slog.Info("Successfully fetched " + strconv.FormatInt(int64(len(sportEvents)), 10) + " sport events")
})
//delete all events and then fetch all events from remote this should be done every sunday at 2am
scheduler.MustAdd("fetchEvents", "0 2 * * 0", func() {
err := events.DeleteAllEvents(app)
if err != nil {
log.Println(err)
slog.Error("Failed to delete all events: %v", err)
}
savedEvents, err := v2.FetchAllEventsAndSave(app, time.RealClock{})
if err != nil {
log.Println(err)
slog.Error("Failed to fetch and save events: %v", err)
} else {
log.Println("Successfully saved: " + strconv.FormatInt(int64(len(savedEvents)), 10) + " events")
slog.Info("Successfully fetched " + strconv.FormatInt(int64(len(savedEvents)), 10) + " events")
}
})
scheduler.Start()
return nil
})
}