4 Commits
0.0.1 ... main

Author SHA1 Message Date
Fran Jurmanović
51b669b058 version increase 2024-10-17 23:48:54 +02:00
Fran Jurmanović
32d1192a3e fix concerts deleting when nothing is scraped 2024-10-17 23:48:35 +02:00
Fran Jurmanović
549541c44f add cron timezone 2024-09-30 23:32:46 +02:00
Fran Jurmanović
c2af7905cf fix godotenv 2024-09-30 23:29:35 +02:00
5 changed files with 17 additions and 10 deletions

View File

@@ -1,7 +1,6 @@
package main
import (
"log"
"rockhu-bot/local/api"
cronhu "rockhu-bot/local/utl/cron"
"rockhu-bot/local/utl/db"
@@ -14,10 +13,7 @@ import (
)
func main() {
err := godotenv.Load()
if err != nil {
log.Fatal("error loading .env file")
}
godotenv.Load()
di := dig.New()
cronhu.Init(di)

View File

@@ -27,7 +27,7 @@ func NewConcertRepository(db *gorm.DB) *ConcertRepository {
func (as ConcertRepository) GetAll(ctx context.Context) *[]model.ConcertModel {
db := as.db.WithContext(ctx)
ConcertModel := new([]model.ConcertModel)
db.Find(&ConcertModel)
db.Unscoped().Find(&ConcertModel)
return ConcertModel
}

View File

@@ -38,7 +38,11 @@ func (as ConcertService) CheckAndUpdateConcerts(ctx context.Context) []model.Con
cm := as.GetAll(ctx)
fmt.Printf("Currently there are %d concerts\n", len(*cm))
NewConcerts := scrapeData(ctx)
fmt.Printf("There are %d new concerts\n", len(*NewConcerts))
concertCount := len(*NewConcerts)
fmt.Printf("There are %d new concerts\n", concertCount)
if concertCount == 0 {
return *NewConcerts
}
forInsert, forDelete, _ := partitionConcerts(*cm, *NewConcerts)
tx := as.repository.CreateTransaction()

View File

@@ -1,7 +1,7 @@
package configs
const (
Version = "0.0.1"
Version = "0.0.4"
Prefix = "v1"
Secret = "Donde4sta"
SecretCode = "brasno"

View File

@@ -2,6 +2,8 @@ package cronhu
import (
"log"
"os"
"time"
"github.com/robfig/cron/v3"
"go.uber.org/dig"
@@ -9,8 +11,13 @@ import (
func Init(di *dig.Container) *cron.Cron {
c := cron.New()
err := di.Provide(func() *cron.Cron {
location, err := time.LoadLocation(os.Getenv("TIMEZONE"))
if err != nil {
log.Panic("unable to load timezone!")
}
c := cron.New(cron.WithLocation(location))
err = di.Provide(func() *cron.Cron {
return c
})