chore(deps): bump modernc.org/sqlite from 1.38.2 to 1.39.1

Bumps [modernc.org/sqlite](https://gitlab.com/cznic/sqlite) from 1.38.2 to 1.39.1.
- [Commits](https://gitlab.com/cznic/sqlite/compare/v1.38.2...v1.39.1)

---
updated-dependencies:
- dependency-name: modernc.org/sqlite
  dependency-version: 1.39.1
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

db/db.go

@@ -31,6 +31,7 @@ import (
 	"modernc.org/sqlite"
 )
 
+
 // https://github.com/ent/ent/discussions/1667#discussioncomment-1132296
 type sqliteDriver struct {
 	*sqlite.Driver
@@ -231,15 +232,6 @@ func (c *client) GetMediaWatchlist(mediaType media.MediaType) []*ent.Media {
 	return list
 }
 
-func (c *client) GetAllEpisodes() (ent.Episodes, error) {
-	ep, err := c.ent.Episode.Query().All(context.TODO())
-	return ep, err
-}
-
-func (c *client) DeleteEpisode(ids ...int) error {
-	_, err := c.ent.Episode.Delete().Where(episode.IDIn(ids...)).Exec(context.TODO())
-	return err
-}
 func (c *client) GetEpisode(seriesId, seasonNum, episodeNum int) (*ent.Episode, error) {
 	return c.ent.Episode.Query().Where(episode.MediaID(seriesId), episode.SeasonNumber(seasonNum),
 		episode.EpisodeNumber(episodeNum)).First(context.TODO())

db/interface.go

@@ -59,6 +59,7 @@ type Settings interface {
 	GetAcceptedSubtitleFormats() ([]string, error)
 	SetAcceptedSubtitleFormats(key string, v []string) error
 	GetTmdbApiKey() string
+
 }
 
 type MediaApis interface {
@@ -74,8 +75,6 @@ type MediaApis interface {
 }
 
 type EpisodeApis interface {
-	GetAllEpisodes() (ent.Episodes, error)
-	DeleteEpisode(ids ...int) error
 	GetEpisode(seriesId, seasonNum, episodeNum int) (*ent.Episode, error)
 	GetEpisodeByID(epID int) (*ent.Episode, error)
 	UpdateEpiode(episodeId int, name, overview string) error
@@ -90,6 +89,7 @@ type EpisodeApis interface {
 	UpdateEpisodeTargetFile(id int, filename string) error
 	GetSeasonEpisodes(mediaId, seasonNum int) ([]*ent.Episode, error)
 	CleanAllDanglingEpisodes() error
+
 }
 
 type IndexerApis interface {
@@ -97,6 +97,7 @@ type IndexerApis interface {
 	DeleteIndexer(id int)
 	GetIndexer(id int) (*ent.Indexers, error)
 	GetAllIndexers() []*ent.Indexers
+
 }
 
 type HistoryApis interface {
@@ -107,5 +108,5 @@ type HistoryApis interface {
 	GetHistories() ent.Histories
 	DeleteHistory(id int) error
 	GetDownloadHistory(mediaID int) ([]*ent.History, error)
-	GetMovieDummyEpisode(movieId int) (*ent.Episode, error)
-}
+	GetMovieDummyEpisode(movieId int) (*ent.Episode, error)	
+}

engine/housekeeping.go

@@ -1,65 +1,26 @@
 package engine
 
-import (
-	"polaris/ent/media"
-	"polaris/log"
-)
+import "polaris/log"
 
-func (c *Engine) housekeeping() (err error) {
+func (c *Engine) housekeeping() error {
 	log.Infof("start housekeeping tasks...")
-	defer func() {
-		log.Infof("housekeeping tasks completed. err: %v", err)
-	}()
-
+	
 	if err := c.checkDbScraps(); err != nil {
 		return err
 	}
 	if err := c.checkImageFilesInterity(); err != nil {
 		return err
 	}
-
+	
 	return nil
 }
 
 func (c *Engine) checkDbScraps() error {
 	//TODO: remove episodes that are not associated with any series
-
-	tvs := c.db.GetMediaWatchlist(media.MediaTypeTv)
-	movies := c.db.GetMediaWatchlist(media.MediaTypeMovie)
-
-	validMediaIDs := make(map[int]bool, len(tvs)+len(movies))
-	for _, tv := range tvs {
-		validMediaIDs[tv.ID] = true
-	}
-	for _, movie := range movies {
-		validMediaIDs[movie.ID] = true
-	}
-
-	allEpisodes, err := c.db.GetAllEpisodes()
-	if err != nil {
-		log.Debugf("get all episodes error: %v", err)
-		return err
-	}
-
-	log.Infof("check db scraps, total episodes: %v, total media: %v", len(allEpisodes), len(validMediaIDs))
-	toDeleteIds := make([]int, 0)
-	for _, ep := range allEpisodes {
-		if _, ok := validMediaIDs[ep.MediaID]; !ok {
-			//log.Infof("remove scrap episode record: %v S%vE%v", ep.MediaID, ep.SeasonNumber, ep.EpisodeNumber)
-			toDeleteIds = append(toDeleteIds, ep.ID)
-		}
-	}
-
-	log.Infof("%v scrap episode records will be removed...", len(toDeleteIds))
-
-	if err := c.db.DeleteEpisode(toDeleteIds...); err != nil {
-		log.Errorf("delete scrap episode records error: %v", err)
-	}
-
 	return nil
 }
 
 func (c *Engine) checkImageFilesInterity() error {
 	//TODO: download missing image files, remove unused image files
 	return nil
-}
+}

engine/scheduler.go

@@ -42,8 +42,7 @@ func (c *Engine) addSysCron() {
 	})
 	c.registerCronJob("check_series_new_release", "0 0 */12 * * *", c.checkAllSeriesNewSeason)
 	c.registerCronJob("update_import_lists", "0 */20 * * * *", c.periodicallyUpdateImportlist)
-	c.registerCronJob("housekeeping", "0 0 2 * * *", c.housekeeping)
-	go c.housekeeping() //run once on startup
+	c.registerCronJob("housekeeping", "0 0 * * * *", c.housekeeping)
 
 	c.schedulers.Range(func(key string, value scheduler) bool {
 		log.Debugf("add cron job: %v", key)

go.mod

@@ -24,7 +24,7 @@ require (
 	github.com/pion/stun/v3 v3.0.0
 	github.com/stretchr/testify v1.11.1
 	golift.io/starr v1.2.0
-	modernc.org/sqlite v1.38.2
+	modernc.org/sqlite v1.39.1
 )
 
 require (
@@ -125,7 +125,7 @@ require (
 	gopkg.in/natefinch/lumberjack.v2 v2.2.1 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	lukechampine.com/blake3 v1.1.6 // indirect
-	modernc.org/libc v1.66.3 // indirect
+	modernc.org/libc v1.66.10 // indirect
 	modernc.org/mathutil v1.7.1 // indirect
 	modernc.org/memory v1.11.0 // indirect
 	zombiezen.com/go/sqlite v0.13.1 // indirect

go.sum

@@ -717,18 +717,18 @@ honnef.co/go/tools v0.0.0-20180728063816-88497007e858/go.mod h1:rf3lG4BRIbNafJWh
 honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 lukechampine.com/blake3 v1.1.6 h1:H3cROdztr7RCfoaTpGZFQsrqvweFLrqS73j7L7cmR5c=
 lukechampine.com/blake3 v1.1.6/go.mod h1:tkKEOtDkNtklkXtLNEOGNq5tcV90tJiA1vAA12R78LA=
-modernc.org/cc/v4 v4.26.2 h1:991HMkLjJzYBIfha6ECZdjrIYz2/1ayr+FL8GN+CNzM=
-modernc.org/cc/v4 v4.26.2/go.mod h1:uVtb5OGqUKpoLWhqwNQo/8LwvoiEBLvZXIQ/SmO6mL0=
-modernc.org/ccgo/v4 v4.28.0 h1:rjznn6WWehKq7dG4JtLRKxb52Ecv8OUGah8+Z/SfpNU=
-modernc.org/ccgo/v4 v4.28.0/go.mod h1:JygV3+9AV6SmPhDasu4JgquwU81XAKLd3OKTUDNOiKE=
-modernc.org/fileutil v1.3.8 h1:qtzNm7ED75pd1C7WgAGcK4edm4fvhtBsEiI/0NQ54YM=
-modernc.org/fileutil v1.3.8/go.mod h1:HxmghZSZVAz/LXcMNwZPA/DRrQZEVP9VX0V4LQGQFOc=
+modernc.org/cc/v4 v4.26.5 h1:xM3bX7Mve6G8K8b+T11ReenJOT+BmVqQj0FY5T4+5Y4=
+modernc.org/cc/v4 v4.26.5/go.mod h1:uVtb5OGqUKpoLWhqwNQo/8LwvoiEBLvZXIQ/SmO6mL0=
+modernc.org/ccgo/v4 v4.28.1 h1:wPKYn5EC/mYTqBO373jKjvX2n+3+aK7+sICCv4Fjy1A=
+modernc.org/ccgo/v4 v4.28.1/go.mod h1:uD+4RnfrVgE6ec9NGguUNdhqzNIeeomeXf6CL0GTE5Q=
+modernc.org/fileutil v1.3.40 h1:ZGMswMNc9JOCrcrakF1HrvmergNLAmxOPjizirpfqBA=
+modernc.org/fileutil v1.3.40/go.mod h1:HxmghZSZVAz/LXcMNwZPA/DRrQZEVP9VX0V4LQGQFOc=
 modernc.org/gc/v2 v2.6.5 h1:nyqdV8q46KvTpZlsw66kWqwXRHdjIlJOhG6kxiV/9xI=
 modernc.org/gc/v2 v2.6.5/go.mod h1:YgIahr1ypgfe7chRuJi2gD7DBQiKSLMPgBQe9oIiito=
 modernc.org/goabi0 v0.2.0 h1:HvEowk7LxcPd0eq6mVOAEMai46V+i7Jrj13t4AzuNks=
 modernc.org/goabi0 v0.2.0/go.mod h1:CEFRnnJhKvWT1c1JTI3Avm+tgOWbkOu5oPA8eH8LnMI=
-modernc.org/libc v1.66.3 h1:cfCbjTUcdsKyyZZfEUKfoHcP3S0Wkvz3jgSzByEWVCQ=
-modernc.org/libc v1.66.3/go.mod h1:XD9zO8kt59cANKvHPXpx7yS2ELPheAey0vjIuZOhOU8=
+modernc.org/libc v1.66.10 h1:yZkb3YeLx4oynyR+iUsXsybsX4Ubx7MQlSYEw4yj59A=
+modernc.org/libc v1.66.10/go.mod h1:8vGSEwvoUoltr4dlywvHqjtAqHBaw0j1jI7iFBTAr2I=
 modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=
 modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=
 modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI=
@@ -737,8 +737,8 @@ modernc.org/opt v0.1.4 h1:2kNGMRiUjrp4LcaPuLY2PzUfqM/w9N23quVwhKt5Qm8=
 modernc.org/opt v0.1.4/go.mod h1:03fq9lsNfvkYSfxrfUhZCWPk1lm4cq4N+Bh//bEtgns=
 modernc.org/sortutil v1.2.1 h1:+xyoGf15mM3NMlPDnFqrteY07klSFxLElE2PVuWIJ7w=
 modernc.org/sortutil v1.2.1/go.mod h1:7ZI3a3REbai7gzCLcotuw9AC4VZVpYMjDzETGsSMqJE=
-modernc.org/sqlite v1.38.2 h1:Aclu7+tgjgcQVShZqim41Bbw9Cho0y/7WzYptXqkEek=
-modernc.org/sqlite v1.38.2/go.mod h1:cPTJYSlgg3Sfg046yBShXENNtPrWrDX8bsbAQBzgQ5E=
+modernc.org/sqlite v1.39.1 h1:H+/wGFzuSCIEVCvXYVHX5RQglwhMOvtHSv+VtidL2r4=
+modernc.org/sqlite v1.39.1/go.mod h1:9fjQZ0mB1LLP0GYrp39oOJXx/I2sxEnZtzCmEQIKvGE=
 modernc.org/strutil v1.2.1 h1:UneZBkQA+DX2Rp35KcM69cSsNES9ly8mQWD71HKlOA0=
 modernc.org/strutil v1.2.1/go.mod h1:EHkiggD70koQxjVdSBM3JKM7k6L0FbGE5eymy9i3B9A=
 modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y=

server/server.go

@@ -26,10 +26,10 @@ import (
 func NewServer(db db.Database) *Server {
 	s := &Server{
 		db:               db,
-		srv:              &http.Server{},
+		srv: &http.Server{},
 		language:         db.GetLanguage(),
-		monitorNumCache:  cache.NewCache[int, int](30 * time.Minute),
-		downloadNumCache: cache.NewCache[int, int](30 * time.Minute),
+		monitorNumCache:  cache.NewCache[int, int](10 * time.Minute),
+		downloadNumCache: cache.NewCache[int, int](10 * time.Minute),
 	}
 	s.core = engine.NewEngine(db, s.language)
 	s.setupRoutes()
@@ -58,7 +58,7 @@ func (s *Server) setupRoutes() {
 	} else {
 		log.Warnf("serve web static files error: %v", err)
 	}
-
+	
 	//s.r.Use(ginzap.Ginzap(log.Logger().Desugar(), time.RFC3339, false))
 	r.Use(ginzap.RecoveryWithZap(log.Logger().Desugar(), true))
 
@@ -179,14 +179,6 @@ func (s *Server) Start(addr string) (int, error) {
 
 	log.Infof("----------- Polaris Server Successfully Started on Port %d------------", p)
 
-	ticker := time.NewTicker(10 * time.Minute)
-	go func() {
-		for {
-			s.cacheDownloadedStatus()
-			<-ticker.C
-		}
-	}()
-
 	return p, nil
 }
 

server/watchlist.go

@@ -89,60 +89,6 @@ type MediaWithStatus struct {
 	DownloadedNum int `json:"downloaded_num"`
 }
 
-func (s *Server) cacheDownloadedStatus() {
-	log.Info("cache watchlist downloaded/monitored status")
-	list := s.db.GetMediaWatchlist(media.MediaTypeTv)
-	for _, item := range list {
-		var ms = MediaWithStatus{
-			Media:         item,
-			MonitoredNum:  0,
-			DownloadedNum: 0,
-		}
-		mon, ok1 := s.monitorNumCache.Get(item.ID)
-		dow, ok2 := s.downloadNumCache.Get(item.ID)
-		if ok1 && ok2 {
-			ms.MonitoredNum = mon
-			ms.DownloadedNum = dow
-		} else {
-			details, err := s.db.GetMediaDetails(item.ID)
-			if err != nil {
-				log.Warnf("get media details: %v", err)
-				continue
-			}
-			for _, ep := range details.Episodes {
-				if ep.Monitored {
-					ms.MonitoredNum++
-					if ep.Status == episode.StatusDownloaded {
-						ms.DownloadedNum++
-					}
-				}
-			}
-			s.monitorNumCache.Set(item.ID, ms.MonitoredNum)
-			s.downloadNumCache.Set(item.ID, ms.DownloadedNum)
-		}
-	}
-
-	list = s.db.GetMediaWatchlist(media.MediaTypeMovie)
-	for _, item := range list {
-		_, ok2 := s.downloadNumCache.Get(item.ID)
-		if ok2 {
-			continue
-		}
-
-		dummyEp, err := s.db.GetMovieDummyEpisode(item.ID)
-		if err != nil {
-			log.Errorf("get dummy episode: %v", err)
-		} else {
-
-			if dummyEp.Status == episode.StatusDownloaded {
-				s.downloadNumCache.Set(item.ID, 1)
-			}
-
-		}
-	}
-
-}
-
 //missing: episode aired missing
 //downloaded: all monitored episode downloaded
 //monitoring: episode aired downloaded, but still has not aired episode
@@ -163,7 +109,20 @@ func (s *Server) GetTvWatchlist(c *gin.Context) (interface{}, error) {
 			ms.MonitoredNum = mon
 			ms.DownloadedNum = dow
 		} else {
-			continue
+			details, err := s.db.GetMediaDetails(item.ID)
+			if err != nil {
+				return nil, errors.Wrap(err, "get details")
+			}
+			for _, ep := range details.Episodes {
+				if ep.Monitored {
+					ms.MonitoredNum++
+					if ep.Status == episode.StatusDownloaded {
+						ms.DownloadedNum++
+					}
+				}
+			}
+			s.monitorNumCache.Set(item.ID, ms.MonitoredNum)
+			s.downloadNumCache.Set(item.ID, ms.DownloadedNum)
 		}
 
 		res[i] = ms
@@ -180,10 +139,14 @@ func (s *Server) GetMovieWatchlist(c *gin.Context) (interface{}, error) {
 			MonitoredNum:  1,
 			DownloadedNum: 0,
 		}
-		dow, ok2 := s.downloadNumCache.Get(item.ID)
-		if ok2 {
-			ms.DownloadedNum = dow
-		} 
+		dummyEp, err := s.db.GetMovieDummyEpisode(item.ID)
+		if err != nil {
+			log.Errorf("get dummy episode: %v", err)
+		} else {
+			if dummyEp.Status == episode.StatusDownloaded {
+				ms.DownloadedNum++
+			}
+		}
 		res[i] = ms
 	}
 	return res, nil