|
|
- class FanOutOnWriteService < BaseService
- # Push a status into home and mentions feeds
- # @param [Status] status
- def call(status)
- deliver_to_self(status) if status.account.local?
- deliver_to_followers(status)
- deliver_to_mentioned(status)
- deliver_to_public(status)
- end
-
- private
-
- def deliver_to_self(status)
- FeedManager.instance.push(:home, status.account, status)
- end
-
- def deliver_to_followers(status)
- status.account.followers.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|
- 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_public(status)
- FeedManager.instance.broadcast(:public, id: status.id)
- end
- end
|