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

Merge even if in progress

Browse Source
This commit is contained in:
Ben Sarmiento
2024-02-07 11:23:53 +01:00
parent f42aad3c33
commit d1b4158c96
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
internal/torrent/refresh.go
View File

@@ -45,13 +45,18 @@ func (t *TorrentManager) refreshTorrents(isInitialRun bool) []string {
continue
}
accessKey := t.GetKey(info)
if !info.AnyInProgress() {
if !info.AnyInProgress() { // since it's single instance info, Any == All
newlyFetchedKeys.Add(accessKey)
}
if torrent, exists := allTorrents.Get(accessKey); !exists {
torrent, exists := allTorrents.Get(accessKey)
if !exists {
allTorrents.Set(accessKey, info)
} else if !info.DownloadedIDs.Difference(torrent.DownloadedIDs).IsEmpty() {
continue
}
newIDs := info.DownloadedIDs.Union(info.InProgressIDs)
oldIDs := torrent.DownloadedIDs.Union(torrent.InProgressIDs)
if !newIDs.Difference(oldIDs).IsEmpty() {
mainTorrent := t.mergeToMain(torrent, info)
allTorrents.Set(accessKey, &mainTorrent)
}