johno/decypharr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added CET timezone

Browse Source
This commit is contained in:
Mukhtar Akere
2025-06-16 22:54:11 +01:00
parent b7226b21ec
commit 5661b05ec1
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/debrid/store/repair.go
View File

@@ -257,8 +257,11 @@ func (c *Cache) reInsertTorrent(ct *CachedTorrent) (*CachedTorrent, error) {
return ct, nil return ct, nil
} }
func (c *Cache) resetInvalidLinks() { func (c *Cache) resetInvalidLinks(ctx context.Context) {
c.logger.Debug().Msgf("Resetting accounts") c.logger.Debug().Msgf("Resetting accounts")
c.invalidDownloadLinks = sync.Map{} c.invalidDownloadLinks = sync.Map{}
c.client.Accounts().Reset() // Reset the active download keys c.client.Accounts().Reset() // Reset the active download keys
// Refresh the download links
c.refreshDownloadLinks(ctx)
} }

2
pkg/debrid/store/worker.go
View File

@@ -45,7 +45,7 @@ func (c *Cache) StartSchedule(ctx context.Context) error {
} else { } else {
// Schedule the job // Schedule the job
if _, err := c.cetScheduler.NewJob(jd, gocron.NewTask(func() { if _, err := c.cetScheduler.NewJob(jd, gocron.NewTask(func() {
c.resetInvalidLinks() c.resetInvalidLinks(ctx)
}), gocron.WithContext(ctx)); err != nil { }), gocron.WithContext(ctx)); err != nil {
c.logger.Error().Err(err).Msg("Failed to create link reset job") c.logger.Error().Err(err).Msg("Failed to create link reset job")
} else { } else {