diff options
author | Thibaut Girka <thib@sitedethib.com> | 2019-06-25 22:56:32 +0200 |
---|---|---|
committer | ThibG <thib@sitedethib.com> | 2019-06-27 16:44:12 +0200 |
commit | ca17bae904783dfb1f4899a533d28a79da0c6fe9 (patch) | |
tree | c38565923e7b92c2125452daf35fecf76588f81d /app/services/fan_out_on_write_service.rb | |
parent | 2f95adc06fbfae22e8f9b4df212938108f5e295c (diff) |
Use a redis-cached feed for the DM timeline
Diffstat (limited to 'app/services/fan_out_on_write_service.rb')
-rw-r--r-- | app/services/fan_out_on_write_service.rb | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/app/services/fan_out_on_write_service.rb b/app/services/fan_out_on_write_service.rb index b66dc342e..cf433d8a6 100644 --- a/app/services/fan_out_on_write_service.rb +++ b/app/services/fan_out_on_write_service.rb @@ -37,6 +37,7 @@ class FanOutOnWriteService < BaseService def deliver_to_self(status) Rails.logger.debug "Delivering status #{status.id} to author" FeedManager.instance.push_to_home(status.account, status) + FeedManager.instance.push_to_direct(status.account, status) if status.direct_visibility? end def deliver_to_followers(status) @@ -98,11 +99,9 @@ class FanOutOnWriteService < BaseService def deliver_to_direct_timelines(status) Rails.logger.debug "Delivering status #{status.id} to direct timelines" - status.mentions.includes(:account).each do |mention| - Redis.current.publish("timeline:direct:#{mention.account.id}", @payload) if mention.account.local? + FeedInsertWorker.push_bulk(status.mentions.includes(:account).map(&:account).select { |mentioned_account| mentioned_account.local? }) do |account| + [status.id, account.id, :direct] end - - Redis.current.publish("timeline:direct:#{status.account.id}", @payload) if status.account.local? end def deliver_to_own_conversation(status) |