From 9057c865c31ad2eedbc7db4ba76319303e05e3db Mon Sep 17 00:00:00 2001
From: Vishnu Narayanan <iamwishnu@gmail.com>
Date: Wed, 1 May 2024 01:03:40 +1000
Subject: [PATCH] feat: Add rake task to clear ActionCable jobs (#9307)

---
 lib/tasks/sidekiq_tasks.rake | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)
 create mode 100644 lib/tasks/sidekiq_tasks.rake

diff --git a/lib/tasks/sidekiq_tasks.rake b/lib/tasks/sidekiq_tasks.rake
new file mode 100644
index 000000000..a984b6d68
--- /dev/null
+++ b/lib/tasks/sidekiq_tasks.rake
@@ -0,0 +1,17 @@
+namespace :sidekiq do
+  desc "Clear ActionCableJobs from sidekiq's critical queue"
+  task clear_action_cable_broadcast_jobs: :environment do
+    queue_name = 'critical'
+    queue = Sidekiq::Queue.new(queue_name)
+    jobs_cleared = 0
+
+    queue.each do |job|
+      if job['wrapped'] == 'ActionCableBroadcastJob'
+        job.delete
+        jobs_cleared += 1
+      end
+    end
+
+    puts "Cleared #{jobs_cleared} ActionCableBroadcastJob(s) from the #{queue_name} queue."
+  end
+end