HTWK/htwkalender
1
1
Fork 0
mirror of https://gitlab.dit.htwk-leipzig.de/htwk-software/htwkalender.git synced 2025-08-02 17:59:14 +02:00
Code Issues Packages Projects Releases Wiki Activity

feat:#6 added attribute and schedule for feed clean

Browse Source
This commit is contained in:
masterElmar
2023-11-20 22:31:30 +01:00
parent ecb43abd6a
commit cf23ed8ab3
5 changed files with 546 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
backend/service/addSchedule.go
View File

@@ -4,8 +4,10 @@ import (
"github.com/pocketbase/pocketbase"
"github.com/pocketbase/pocketbase/core"
"github.com/pocketbase/pocketbase/tools/cron"
"htwkalender/service/db"
"htwkalender/service/events"
"log"
"time"
)
func AddSchedules(app *pocketbase.PocketBase) {
@@ -17,9 +19,7 @@ func AddSchedules(app *pocketbase.PocketBase) {
// Every three hours update all courses (5 segments - minute, hour, day, month, weekday) "0 */3 * * *"
// Every 10 minutes update all courses (5 segments - minute, hour, day, month, weekday) "*/10 * * * *"
scheduler.MustAdd("updateCourse", "0 */3 * * *", func() {
courses := events.GetAllCourses(app)
for _, course := range courses {
err := events.UpdateModulesForCourse(app, course)
if err != nil {
@@ -29,11 +29,29 @@ func AddSchedules(app *pocketbase.PocketBase) {
log.Println("Update Course: " + course + " successful")
}
}
})
// Every sunday at 3am clean all courses (5 segments - minute, hour, day, month, weekday) "0 3 * * 0"
scheduler.MustAdd("cleanFeeds", "0 3 * * 0", func() {
feeds, err := db.GetAllFeeds(app)
if err != nil {
log.Println("CleanFeeds: get all feeds failed")
return
}
for _, feed := range feeds {
// if retrieved time is older than a half year delete feed
if feed.GetTime("retrieved").Before(time.Now().AddDate(0, -6, 0)) {
err = app.Dao().DeleteRecord(feed)
if err != nil {
log.Println("CleanFeeds: delete feed " + feed.GetId() + " failed")
log.Println(err)
} else {
log.Println("CleanFeeds: delete feed " + feed.GetId() + " successful")
}
}
}
})
scheduler.Start()
return nil
})

25
backend/service/db/dbFeeds.go
View File

@@ -1,10 +1,10 @@
package db
import (
"github.com/pocketbase/dbx"
"github.com/pocketbase/pocketbase"
"github.com/pocketbase/pocketbase/models"
"htwkalender/model"
"time"
)
func SaveFeed(feed model.Feed, collection *models.Collection, app *pocketbase.PocketBase) (*models.Record, error) {
@@ -19,10 +19,29 @@ func SaveFeed(feed model.Feed, collection *models.Collection, app *pocketbase.Po
}
func FindFeedByToken(token string, app *pocketbase.PocketBase) (*model.Feed, error) {
var feed model.Feed
err := app.Dao().DB().Select("*").From("feeds").Where(dbx.NewExp("id = {:id}", dbx.Params{"id": token})).One(&feed)
record, err := app.Dao().FindRecordById("feeds", token)
if err != nil {
return nil, err
}
var feed model.Feed
feed.Modules = record.GetString("modules")
feed.Retrieved = record.GetTime("retrieved")
//update retrieved time
record.Set("retrieved", time.Now())
err = app.Dao().SaveRecord(record)
return &feed, err
}
func GetAllFeeds(app *pocketbase.PocketBase) ([]*models.Record, error) {
feeds, err := app.Dao().FindRecordsByFilter("feeds", "", "", 0, 0)
if err != nil {
return nil, err
}
return feeds, nil
}