New rewrite with svelte and pocketbase

backend/crons.go

@@ -0,0 +1,70 @@
+package main
+
+import (
+	"log"
+	"fmt"
+)
+
+func (app *application) SetupCrons() {
+	app.pb.Cron().MustAdd("update_sets_and_cards", "0 3 * * *", func() {
+		log.Println("Started updating sets and cards...")
+		
+		scryfallSets := fetchApiSets()
+
+		insertQuery := CreateBulkSetsInsertQuery(scryfallSets)
+		_, err := app.pb.DB().
+						NewQuery(insertQuery).
+						Execute()
+		if err != nil {
+			log.Println(fmt.Sprintf("[ERROR] %v",err))
+		}
+		log.Println(fmt.Sprintf("Updated %d sets", len(scryfallSets)))
+
+		setsCodesQuery := []MtgSet{}
+		err = app.pb.DB().
+				NewQuery("SELECT id, code FROM mtg_set").
+				All(&setsCodesQuery)
+		if err != nil {
+			log.Println(fmt.Sprintf("[ERROR] %v",err))
+		}
+
+		setsCodes := map[string]string{}
+		for _,v := range setsCodesQuery {
+			setsCodes[v.ID] = v.Code
+		}
+
+		selectedSets := []Brawlset{}
+		selectedSetsCodes := []string{}
+		err = app.pb.DB().
+				NewQuery("SELECT sets FROM brawlset").
+				All(&selectedSets)
+		if err != nil {
+			log.Println(fmt.Sprintf("[ERROR] %v",err))
+		}
+		for _, v := range selectedSets {
+			for _, set := range v.Sets {
+				selectedSetsCodes = append(selectedSetsCodes, setsCodes[set])
+			}
+		}
+
+		log.Println(fmt.Sprintf("Fetching %d sets...", len(selectedSetsCodes)))
+		allCards := []ScryfallCard{}
+		for _, v := range selectedSetsCodes {
+			url := "https://api.scryfall.com/cards/search?q=(game%3Apaper)+set%3A" + v
+			allCards = fetchApiCards(url, allCards)
+		}
+
+		upsertQuery := CreateBulkCardsUpsertQuery(allCards)
+		_, err = app.pb.DB().
+						NewQuery(upsertQuery).
+						Execute()
+		if err != nil {
+			log.Println(fmt.Sprintf("[ERROR] %v",err))
+		}
+		log.Println(fmt.Sprintf("Updated %d cards", len(allCards)))
+	})
+
+	app.pb.Cron().MustAdd("regenerate_cache_json", "30 3 * * *", func() {
+		GenerateCache(app.pb.App)
+	})
+}