feat: Add a job to clear notifications that were created before 1 month (#8732)

app/jobs/notification/remove_old_notification_job.rb

@@ -0,0 +1,8 @@
+class Notification::RemoveOldNotificationJob < ApplicationJob
+  queue_as :low
+
+  def perform
+    Notification.where('created_at < ?', 1.month.ago)
+                .find_each(batch_size: 1000, &:delete)
+  end
+end

app/jobs/trigger_scheduled_items_job.rb

@@ -19,5 +19,8 @@ class TriggerScheduledItemsJob < ApplicationJob
 
     # Job to sync whatsapp templates
     Channels::Whatsapp::TemplatesSyncSchedulerJob.perform_later
+
+    # Job to clear notifications which are older than 1 month
+    Notification::RemoveOldNotificationJob.perform_later
   end
 end

spec/jobs/notification/remove_old_notification_job_spec.rb

@@ -0,0 +1,24 @@
+require 'rails_helper'
+
+RSpec.describe Notification::RemoveOldNotificationJob do
+  let(:user) { create(:user) }
+  let(:conversation) { create(:conversation) }
+
+  it 'enqueues the job' do
+    notification = create(:notification, user: user, notification_type: 'conversation_creation', primary_actor: conversation)
+    expect do
+      described_class.perform_later(notification)
+    end.to have_enqueued_job(described_class)
+      .on_queue('low')
+  end
+
+  it 'removes old notifications which are older than 1 month' do
+    create(:notification, user: user, notification_type: 'conversation_creation', primary_actor: conversation, created_at: 2.months.ago)
+    create(:notification, user: user, notification_type: 'conversation_creation', primary_actor: conversation, created_at: 1.month.ago)
+    create(:notification, user: user, notification_type: 'conversation_creation', primary_actor: conversation, created_at: 1.day.ago)
+    create(:notification, user: user, notification_type: 'conversation_creation', primary_actor: conversation, created_at: 1.hour.ago)
+
+    described_class.perform_now
+    expect(Notification.count).to eq(2)
+  end
+end

spec/jobs/trigger_scheduled_items_job_spec.rb

@@ -40,5 +40,10 @@ RSpec.describe TriggerScheduledItemsJob do
       expect(Channels::Whatsapp::TemplatesSyncSchedulerJob).to receive(:perform_later).once
       described_class.perform_now
     end
+
+    it 'triggers Notification::RemoveOldNotificationJob' do
+      expect(Notification::RemoveOldNotificationJob).to receive(:perform_later).once
+      described_class.perform_now
+    end
   end
 end