3a92885a86
* Process incoming poll tallies update * Send Update on poll vote * Do not send Updates for a poll more often than once every 3 minutes * Include voters in people to notify of results update * Schedule closing poll worker on poll creation * Add new notification type for ending polls * Add front-end support for ended poll notifications * Fix UpdatePollSerializer * Fix Updates not being triggered by local votes * Fix tests failure * Fix web push notifications for closing polls * Minor cleanup * Notify voters of both remote and local polls when those close * Fix delivery of poll updates to mentioned accounts and voters
24 lines
602 B
Ruby
24 lines
602 B
Ruby
# 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).filter(&:local?).each do |account|
|
|
NotifyService.new.call(account, poll)
|
|
end
|
|
rescue ActiveRecord::RecordNotFound
|
|
true
|
|
end
|
|
end
|