diff --git a/internal/release/service.go b/internal/release/service.go index 4b80491..08b7d85 100644 --- a/internal/release/service.go +++ b/internal/release/service.go @@ -3,6 +3,7 @@ package release import ( "context" "strings" + "time" "github.com/autobrr/autobrr/internal/action" "github.com/autobrr/autobrr/internal/domain" @@ -129,6 +130,13 @@ func (s *service) Process(release *domain.Release) { } } + // sleep for the delay period specified in the filter before running actions + delay := release.Filter.Delay + if delay > 0 { + log.Debug().Msgf("Delaying processing of '%v' (%v) for %v by %d seconds as specified in the filter", release.TorrentName, release.Filter.Name, release.Indexer, delay) + time.Sleep(time.Duration(delay) * time.Second) + } + var rejections []string // run actions (watchFolder, test, exec, qBittorrent, Deluge, arr etc.)