diff options
author | beatrix <beatrix.bitrot@gmail.com> | 2017-10-25 17:37:06 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-10-25 17:37:06 -0400 |
commit | 31814ddda009939d5d2ebe3e0ac061c26387529a (patch) | |
tree | 19e002405d30a50aca740a979efeb6b3a9d1e186 /app/services/batched_remove_status_service.rb | |
parent | 5f0268ab842990740d79d44e77159bb52f1a08ce (diff) | |
parent | 42f2045c217df4b482e6ce70615a1d3252e0e972 (diff) |
Merge pull request #198 from glitch-soc/gs-direct-timeline
Direct messages timeline from tootsuite/mastodon#4514
Diffstat (limited to 'app/services/batched_remove_status_service.rb')
-rw-r--r-- | app/services/batched_remove_status_service.rb | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/app/services/batched_remove_status_service.rb b/app/services/batched_remove_status_service.rb index 5d83771c9..aa2229f13 100644 --- a/app/services/batched_remove_status_service.rb +++ b/app/services/batched_remove_status_service.rb @@ -40,6 +40,7 @@ class BatchedRemoveStatusService < BaseService # Cannot be batched statuses.each do |status| unpush_from_public_timelines(status) + unpush_from_direct_timelines(status) if status.direct_visibility? batch_salmon_slaps(status) if status.local? end @@ -100,6 +101,16 @@ class BatchedRemoveStatusService < BaseService end end + def unpush_from_direct_timelines(status) + payload = @json_payloads[status.id] + redis.pipelined do + @mentions[status.id].each do |mention| + redis.publish("timeline:direct:#{mention.account.id}", payload) if mention.account.local? + end + redis.publish("timeline:direct:#{status.account.id}", payload) if status.account.local? + end + end + def batch_salmon_slaps(status) return if @mentions[status.id].empty? |