Class: Nuntius::PurgeMessageJob

Inherits:

ApplicationJob

• Object
• ActiveJob::Base
• ApplicationJob
• Nuntius::PurgeMessageJob

Defined in:

app/jobs/nuntius/purge_message_job.rb

Instance Method Summary

• #perform(account_id, months) ⇒ Object

Instance Method Details

#perform(account_id, months) ⇒ Object

# File 'app/jobs/nuntius/purge_message_job.rb', line 3

def perform(account_id, months)
  messages = Nuntius::Message.distinct.select(:id).where("metadata ->> 'account_id' = :account", account: account_id)
    .where(created_at: ..months.months.ago.beginning_of_day)
    .where.not(status: %w[complaint bounced])

  Nuntius::Message.where(parent_message_id: messages.pluck(:id)).in_batches.update_all(parent_message_id: nil)

  messages.in_batches.destroy_all
end