diff --git a/internal/torrent/manager.go b/internal/torrent/manager.go index 1ff8dbe..99682b2 100644 --- a/internal/torrent/manager.go +++ b/internal/torrent/manager.go @@ -82,9 +82,9 @@ func NewTorrentManager(cfg config.ConfigInterface, api *realdebrid.RealDebrid, p t.log.Fatalf("Cannot get downloads: %v\n", err) } t.DownloadCache = cmap.New[*realdebrid.Download]() - for _, download := range downloads { - if !t.DownloadCache.Has(download.Link) { - t.DownloadCache.Set(download.Link, &download) + for i := range downloads { + if !t.DownloadCache.Has(downloads[i].Link) { + t.DownloadCache.Set(downloads[i].Link, &downloads[i]) } } }() @@ -101,6 +101,8 @@ func NewTorrentManager(cfg config.ConfigInterface, api *realdebrid.RealDebrid, p initWait.Wait() + t.log.Infof("Fetched %d downloads", t.DownloadCache.Count()) + torrentsChan := make(chan *Torrent, len(newTorrents)) var wg sync.WaitGroup for i := range newTorrents { @@ -551,7 +553,7 @@ func (t *TorrentManager) organizeChaos(links []string, selectedFiles []*File) ([ } resp := t.Api.UnrestrictUntilOk(link, t.cfg.ShouldServeFromRclone()) resultsChan <- Result{Response: resp} - time.Sleep(1 * time.Second) + time.Sleep(time.Duration(t.cfg.GetReleaseUnrestrictAfterMs()) * time.Millisecond) }) }