diff options
author | ThibG <thib@sitedethib.com> | 2020-04-05 12:51:22 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-04-05 12:51:22 +0200 |
commit | 89e28c76744dc888e7c5f85aef305452681fd6be (patch) | |
tree | a8912717fa31375c5898786e370ed022e3c43c5c /app/workers | |
parent | a889756dd5f72a1423a613d8ce141f5347da48bc (diff) |
Fix PostgreSQL load when linking in announcements (#13250)
* Fix PostgreSQL load when linking in announcements Fixes #13245 by caching status lookups Since statuses are supposed to be known already and we only need their URLs and a few other things, caching them should be fine. Since it's only used by announcements so far, there won't be much statuses to cache. * Perform status lookup when saving announcements, not when rendering them * Change EntityCache#status to fetch URLs instead of looking into the database * Move announcement link lookup to publishing worker * Address issues pointed out during review
Diffstat (limited to 'app/workers')
-rw-r--r-- | app/workers/publish_scheduled_announcement_worker.rb | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/app/workers/publish_scheduled_announcement_worker.rb b/app/workers/publish_scheduled_announcement_worker.rb index efca39d3d..1392efed0 100644 --- a/app/workers/publish_scheduled_announcement_worker.rb +++ b/app/workers/publish_scheduled_announcement_worker.rb @@ -5,15 +5,24 @@ class PublishScheduledAnnouncementWorker include Redisable def perform(announcement_id) - announcement = Announcement.find(announcement_id) + @announcement = Announcement.find(announcement_id) - announcement.publish! unless announcement.published? + refresh_status_ids! - payload = InlineRenderer.render(announcement, nil, :announcement) + @announcement.publish! unless @announcement.published? + + payload = InlineRenderer.render(@announcement, nil, :announcement) payload = Oj.dump(event: :announcement, payload: payload) FeedManager.instance.with_active_accounts do |account| redis.publish("timeline:#{account.id}", payload) if redis.exists("subscribed:timeline:#{account.id}") end end + + private + + def refresh_status_ids! + @announcement.status_ids = Status.from_text(@announcement.text).map(&:id) + @announcement.save + end end |