Sha256: b742b27dd35962942a2490528c8cc3da207a5c9a527b8f8777cda99dd54d2a9c
Contents?: true
Size: 502 Bytes
Versions: 25
Compression:
Stored size: 502 Bytes
Contents
module Nuntius
class PurgeMessageJob < ApplicationJob
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
end
end
Version data entries
25 entries across 25 versions & 1 rubygems