diff options
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/player/main.go | 18 |
1 files changed, 17 insertions, 1 deletions
diff --git a/cmd/player/main.go b/cmd/player/main.go index b0fec6c..0a7bacb 100644 --- a/cmd/player/main.go +++ b/cmd/player/main.go @@ -95,11 +95,27 @@ func wireDeps(cfg *internal.Config, store repository.Store, logger *slog.Logger, authSvc := service.NewAuthService(store, clk, hasher, sm) helper := service.NewAccessHelper(store) - podcastSvc := service.NewPodcastService(store, clk, cfg.MediaRoot, helper, prober, thumbGen) + podcastSvc := service.NewPodcastService(store, clk, cfg.MediaRoot, helper, prober, thumbGen, cfg.PodcastCheckMinutes) gcWorker := service.NewGCWorker(store, clk, cfg.MediaRoot, time.Duration(cfg.GCIntervalMinutes)*time.Minute, logger) gcWorker.Start() + // Start podcast feed background checker. + go func() { + ticker := time.NewTicker(time.Duration(cfg.PodcastCheckMinutes) * time.Minute) + defer ticker.Stop() + for { + select { + case <-ticker.C: + if err := podcastSvc.CheckFeeds(context.Background()); err != nil { + logger.Error("podcast feed check failed", "err", err) + } + case <-appCtx.Done(): + return + } + } + }() + return &appDeps{ store: store, hasher: hasher, |