hpz937/zurg
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add cleanup job for downloaded ids

Browse Source
This commit is contained in:
Ben Adrian Sarmiento
2024-06-05 09:46:54 +02:00
parent aa11889601
commit c62cdeace8
2 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
internal/torrent/refresh.go
View File

@@ -142,6 +142,20 @@ func (t *TorrentManager) refreshTorrents() []string {
})
})
t.workerPool.Submit(func() {
// update DownloadedIDs field of torrents
allTorrents.IterCb(func(accessKey string, torrent *Torrent) {
deletedIDs := torrent.DownloadedIDs.Difference(freshIDs)
if deletedIDs.Cardinality() > 0 {
deletedIDs.Each(func(id string) bool {
torrent.DownloadedIDs.Remove(id)
return false
})
t.writeTorrentToFile(torrent)
}
})
})
return updatedPaths.ToSlice()
}

4
pkg/realdebrid/api.go
View File

@@ -174,7 +174,7 @@ func (rd *RealDebrid) GetTorrents(onlyOne bool) ([]Torrent, int, error) {
page := 1
// compute ceiling of totalCount / limit
maxPages := (totalCount + rd.cfg.GetTorrentsCount() - 1) / rd.cfg.GetTorrentsCount()
rd.log.Debugf("Torrents total count is %d, total page count is %d", totalCount, maxPages)
rd.log.Debugf("Torrents total count is %d", totalCount)
maxParallelThreads := 4
if maxPages < maxParallelThreads {
maxParallelThreads = maxPages
@@ -370,7 +370,7 @@ func (rd *RealDebrid) GetDownloads() []Download {
// compute ceiling of totalCount / limit
maxPages := (totalCount + limit - 1) / limit
rd.log.Debugf("Total downloads count is %d, total page count is %d", totalCount, maxPages)
rd.log.Debugf("Total downloads count is %d", totalCount)
maxParallelThreads := 8
if maxPages < maxParallelThreads {
maxParallelThreads = maxPages