Fix delete issue

2023-11-18 21:04:48 +01:00
parent 6ef5b147c0
commit 244222032b
1 changed files with 4 additions and 1 deletions
--- a/internal/torrent/manager.go
+++ b/internal/torrent/manager.go
@@ -306,7 +306,10 @@ func (t *TorrentManager) startRefreshJob() {
 		accessKeys := allTorrents.Keys()
 		for _, oldAccessKey := range accessKeys {
 			if _, ok := retain[oldAccessKey]; !ok {
-				allTorrents.Remove(oldAccessKey)
+				t.DirectoryMap.IterCb(func(_ string, torrents cmap.ConcurrentMap[string, *Torrent]) {
+					torrents.Remove(oldAccessKey)
+				})
+				fmt.Printf("Deleted torrent: %s\n", oldAccessKey)
 			}
 		}