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_scheduled_announcement_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_scheduled_announcement_worker.rb')
-rw-r--r-- | app/workers/publish_scheduled_announcement_worker.rb | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/app/workers/publish_scheduled_announcement_worker.rb b/app/workers/publish_scheduled_announcement_worker.rb new file mode 100644 index 000000000..4b2014e34 --- /dev/null +++ b/app/workers/publish_scheduled_announcement_worker.rb @@ -0,0 +1,18 @@ +# frozen_string_literal: true + +class PublishScheduledAnnouncementWorker + include Sidekiq::Worker + include Redisable + + def perform(announcement_id) + announcement = Announcement.find(announcement_id) + announcement.update(published: true) + + payload = InlineRenderer.render(announcement, nil, :announcement) + payload = Oj.dump(event: :announcement, 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 + end +end |