diff options
author | Eugen Rochko <eugen@zeonfederated.com> | 2016-11-05 15:20:05 +0100 |
---|---|---|
committer | Eugen Rochko <eugen@zeonfederated.com> | 2016-11-05 17:13:14 +0100 |
commit | 48b9619439818ecb344ae33c9c31a55ecb1aa27a (patch) | |
tree | ef350e3ebf2563adbe4d57778a08f561d912415f /app/services/fan_out_on_write_service.rb | |
parent | 62292797eccc5bcf47abae9f4daaa2c186660644 (diff) |
Adding hashtags
Diffstat (limited to 'app/services/fan_out_on_write_service.rb')
-rw-r--r-- | app/services/fan_out_on_write_service.rb | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/app/services/fan_out_on_write_service.rb b/app/services/fan_out_on_write_service.rb index 707f74c35..a36f80150 100644 --- a/app/services/fan_out_on_write_service.rb +++ b/app/services/fan_out_on_write_service.rb @@ -5,6 +5,10 @@ class FanOutOnWriteService < BaseService deliver_to_self(status) if status.account.local? deliver_to_followers(status) deliver_to_mentioned(status) + + return if status.account.silenced? + + deliver_to_hashtags(status) deliver_to_public(status) end @@ -15,22 +19,27 @@ class FanOutOnWriteService < BaseService end def deliver_to_followers(status) - status.account.followers.each do |follower| + status.account.followers.find_each do |follower| next if !follower.local? || FeedManager.instance.filter?(:home, status, follower) FeedManager.instance.push(:home, follower, status) end end def deliver_to_mentioned(status) - status.mentions.each do |mention| + status.mentions.find_each do |mention| mentioned_account = mention.account next if !mentioned_account.local? || mentioned_account.id == status.account_id || FeedManager.instance.filter?(:mentions, status, mentioned_account) FeedManager.instance.push(:mentions, mentioned_account, status) end end + def deliver_to_hashtags(status) + status.tags.find_each do |tag| + FeedManager.instance.broadcast("hashtag:#{tag.name}", id: status.id) + end + end + def deliver_to_public(status) - return if status.account.silenced? FeedManager.instance.broadcast(:public, id: status.id) end end |