poll_expiration_notify_worker.rb 602 Bytes
Newer Older
Rob Colbert's avatar
Rob Colbert committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
# frozen_string_literal: true

class PollExpirationNotifyWorker
  include Sidekiq::Worker

  sidekiq_options unique: :until_executed

  def perform(poll_id)
    poll = Poll.find(poll_id)

    # Notify poll owner and remote voters
    if poll.local?
      ActivityPub::DistributePollUpdateWorker.perform_async(poll.status.id)
      NotifyService.new.call(poll.account, poll)
    end

    # Notify local voters
    poll.votes.includes(:account).map(&:account).select(&:local?).each do |account|
      NotifyService.new.call(account, poll)
    end
  rescue ActiveRecord::RecordNotFound
    true
  end
end