unpublish_announcement_worker.rb 414 B

1234567891011121314
  1. # frozen_string_literal: true
  2. class UnpublishAnnouncementWorker
  3. include Sidekiq::Worker
  4. include Redisable
  5. def perform(announcement_id)
  6. payload = Oj.dump(event: :'announcement.delete', payload: announcement_id.to_s)
  7. FeedManager.instance.with_active_accounts do |account|
  8. redis.publish("timeline:#{account.id}", payload) if redis.exists?("subscribed:timeline:#{account.id}")
  9. end
  10. end
  11. end