From d112634947eec432cbb072410b9e3bc118331201 Mon Sep 17 00:00:00 2001 From: ghostserverd <42226464+ghostserverd@users.noreply.github.com> Date: Mon, 9 May 2022 08:48:56 -0700 Subject: [PATCH] feat(actions): wait for delay (#263) --- internal/release/service.go | 8 ++++++++ 1 file changed, 8 insertions(+) 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.)