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