invidious-experimenting/src/invidious/jobs/pull_popular_videos_job.cr

class Invidious::Jobs::PullPopularVideosJob < Invidious::Jobs::BaseJob
  POPULAR_VIDEOS = Atomic.new([] of ChannelVideo)
  private getter db : DB::Database

  def initialize(@db)
  end

  def begin
    loop do
      videos = Invidious::Database::ChannelVideos.select_popular_videos
        .sort_by!(&.published)
        .reverse!

      POPULAR_VIDEOS.set(videos)

      sleep 1.minute
      Fiber.yield
    end
  end
end