Refactor Podcasts Bust Cache job (#5421)

app/models/podcast.rb

@@ -53,6 +53,6 @@ def unique_slug_including_users_and_orgs
   def bust_cache
     return unless path
 
-    Podcasts::BustCacheJob.perform_later(path)
+    Podcasts::BustCacheWorker.perform_async(path)
   end
 end

app/workers/podcasts/bust_cache_worker.rb

@@ -0,0 +1,11 @@
+module Podcasts
+  class BustCacheWorker
+    include Sidekiq::Worker
+
+    sidekiq_options queue: :high_priority, retry: 10
+
+    def perform(path)
+      CacheBuster.bust_podcast(path)
+    end
+  end
+end

spec/models/page_spec.rb

@@ -49,15 +49,12 @@
   end
 
   context "when callbacks are triggered after save" do
-    let(:page) { build(:page) }
-
-    before do
-      allow(Pages::BustCacheWorker).to receive(:perform_async)
-    end
+    let(:page) { create(:page) }
 
     it "triggers cache busting on save" do
-      page.save
-      expect(Pages::BustCacheWorker).to have_received(:perform_async).with(page.slug)
+      sidekiq_assert_enqueued_with(job: Pages::BustCacheWorker, args: [page.slug]) do
+        page.save
+      end
     end
   end
 end

spec/models/podcast_spec.rb

@@ -17,7 +17,9 @@
 
   context "when callbacks are triggered after save" do
     it "triggers cache busting on save" do
-      expect { build(:podcast).save }.to have_enqueued_job.on_queue("podcasts_bust_cache").once
+      sidekiq_assert_enqueued_with(job: Podcasts::BustCacheWorker, args: [podcast.path]) do
+        podcast.save
+      end
     end
   end
 

spec/workers/podcasts/bust_cache_worker.rb

@@ -0,0 +1,16 @@
+require "rails_helper"
+
+RSpec.describe Podcasts::BustCacheWorker, type: :worker do
+  let(:worker) { subject }
+
+  before do
+    allow(CacheBuster).to receive(:bust_podcast)
+  end
+
+  describe "#perform" do
+    it "busts cache" do
+      worker.perform("path")
+      expect(CacheBuster).to have_received(:bust_podcast).with("path")
+    end
+  end
+end