diff options
author | Thibaut Girka <thib@sitedethib.com> | 2020-01-24 14:37:06 +0100 |
---|---|---|
committer | Thibaut Girka <thib@sitedethib.com> | 2020-01-24 14:37:06 +0100 |
commit | 9adeaf2bfc1c16ca70e611b5288886b21414217b (patch) | |
tree | 53372bc9bd6f38d158aad50c768e18773b7d3f3b /app/workers/publish_announcement_reaction_worker.rb | |
parent | a8c109baca4d02cc8aed454e231518c1f8ec1844 (diff) | |
parent | 4bae4e972d43f71bffb888ac82c180b2fa3f1ada (diff) |
Merge branch 'master' into glitch-soc/merge-upstream
Conflicts: - `app/controllers/statuses_controller.rb`: Minor conflict due to theming system
Diffstat (limited to 'app/workers/publish_announcement_reaction_worker.rb')
-rw-r--r-- | app/workers/publish_announcement_reaction_worker.rb | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/app/workers/publish_announcement_reaction_worker.rb b/app/workers/publish_announcement_reaction_worker.rb new file mode 100644 index 000000000..6f3b6dc5b --- /dev/null +++ b/app/workers/publish_announcement_reaction_worker.rb @@ -0,0 +1,22 @@ +# frozen_string_literal: true + +class PublishAnnouncementReactionWorker + include Sidekiq::Worker + include Redisable + + def perform(announcement_id, name) + announcement = Announcement.find(announcement_id) + + reaction, = announcement.announcement_reactions.where(name: name).group(:announcement_id, :name, :custom_emoji_id).select('name, custom_emoji_id, count(*) as count, false as me') + reaction ||= announcement.announcement_reactions.new(name: name) + + payload = InlineRenderer.render(reaction, nil, :reaction).tap { |h| h[:announcement_id] = announcement_id } + payload = Oj.dump(event: :'announcement.reaction', payload: payload) + + Account.joins(:user).where('users.current_sign_in_at > ?', User::ACTIVE_DURATION.ago).find_each do |account| + redis.publish("timeline:#{account.id}", payload) if redis.exists("subscribed:timeline:#{account.id}") + end + rescue ActiveRecord::RecordNotFound + true + end +end |