mirror of
https://github.com/funamitech/mastodon
synced 2024-12-06 02:39:04 +09:00
fe89554a54
Conflicts: - `app/lib/activitypub/activity/create.rb`: Upstream refactored how `Create` activities are handled and how values are extracted from `Create`d objects. This conflicted with how glitch-soc supported the `directMessage` flag to explicitly distinguish between limited and direct messages. Ported glitch-soc's changes to latest upstream changes. - `app/services/fan_out_on_write_service.rb`: Upstream largely refactored that file and changed some of the logic. This conflicted with glitch-soc's handling of the direct timeline and the options to allow replies and boosts in public feeds. Ported those glitch-soc changes on top of latest upstream changes. - `app/services/process_mentions_service.rb`: Upstream refactored to move mention-related ActivityPub deliveries to `ActivityPub::DeliveryWorker`, while glitch-soc contained an extra check to not send local-only toots to remote mentioned users. Took upstream's version, as the check is not needed anymore, since it is performed at the `ActivityPub::DeliveryWorker` call site already. - `app/workers/feed_insert_worker.rb`: Upstream added support for `update` toot events, while glitch-soc had support for an extra timeline support, `direct`. Ported upstream changes and extended them to the `direct` timeline. Additional changes: - `app/lib/activitypub/parser/status_parser.rb`: Added code to handle the `directMessage` flag and take it into account to compute visibility. - `app/lib/feed_manager.rb`: Extended upstream's support of `update` toot events to glitch-soc's `direct` timeline.
137 lines
4.5 KiB
Ruby
137 lines
4.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class FanOutOnWriteService < BaseService
|
|
# Push a status into home and mentions feeds
|
|
# @param [Status] status
|
|
# @param [Hash] options
|
|
# @option options [Boolean] update
|
|
# @option options [Array<Integer>] silenced_account_ids
|
|
def call(status, options = {})
|
|
@status = status
|
|
@account = status.account
|
|
@options = options
|
|
|
|
check_race_condition!
|
|
|
|
fan_out_to_local_recipients!
|
|
fan_out_to_public_streams! if broadcastable?
|
|
end
|
|
|
|
private
|
|
|
|
def check_race_condition!
|
|
# I don't know why but at some point we had an issue where
|
|
# this service was being executed with status objects
|
|
# that had a null visibility - which should not be possible
|
|
# since the column in the database is not nullable.
|
|
#
|
|
# This check re-queues the service to be run at a later time
|
|
# with the full object, if something like it occurs
|
|
|
|
raise Mastodon::RaceConditionError if @status.visibility.nil?
|
|
end
|
|
|
|
def fan_out_to_local_recipients!
|
|
deliver_to_self!
|
|
notify_mentioned_accounts!
|
|
|
|
case @status.visibility.to_sym
|
|
when :public, :unlisted, :private
|
|
deliver_to_all_followers!
|
|
deliver_to_lists!
|
|
when :limited
|
|
deliver_to_mentioned_followers!
|
|
else
|
|
deliver_to_mentioned_followers!
|
|
deliver_to_conversation!
|
|
deliver_to_direct_timelines!
|
|
end
|
|
end
|
|
|
|
def fan_out_to_public_streams!
|
|
broadcast_to_hashtag_streams!
|
|
broadcast_to_public_streams!
|
|
end
|
|
|
|
def deliver_to_self!
|
|
FeedManager.instance.push_to_home(@account, @status, update: update?) if @account.local?
|
|
FeedManager.instance.push_to_direct(@account, @status, update: update?) if @account.local? && @status.direct_visibility?
|
|
end
|
|
|
|
def notify_mentioned_accounts!
|
|
@status.active_mentions.where.not(id: @options[:silenced_account_ids] || []).joins(:account).merge(Account.local).select(:id, :account_id).reorder(nil).find_in_batches do |mentions|
|
|
LocalNotificationWorker.push_bulk(mentions) do |mention|
|
|
[mention.account_id, mention.id, 'Mention', :mention]
|
|
end
|
|
end
|
|
end
|
|
|
|
def deliver_to_all_followers!
|
|
@account.followers_for_local_distribution.select(:id).reorder(nil).find_in_batches do |followers|
|
|
FeedInsertWorker.push_bulk(followers) do |follower|
|
|
[@status.id, follower.id, :home, update: update?]
|
|
end
|
|
end
|
|
end
|
|
|
|
def deliver_to_lists!
|
|
@account.lists_for_local_distribution.select(:id).reorder(nil).find_in_batches do |lists|
|
|
FeedInsertWorker.push_bulk(lists) do |list|
|
|
[@status.id, list.id, :list, update: update?]
|
|
end
|
|
end
|
|
end
|
|
|
|
def deliver_to_mentioned_followers!
|
|
@status.mentions.joins(:account).merge(@account.followers_for_local_distribution).select(:id, :account_id).reorder(nil).find_in_batches do |mentions|
|
|
FeedInsertWorker.push_bulk(mentions) do |mention|
|
|
[@status.id, mention.account_id, :home, update: update?]
|
|
end
|
|
end
|
|
end
|
|
|
|
def deliver_to_direct_timelines!
|
|
FeedInsertWorker.push_bulk(@status.mentions.includes(:account).map(&:account).select { |mentioned_account| mentioned_account.local? }) do |account|
|
|
[@status.id, account.id, :direct, update: update?]
|
|
end
|
|
end
|
|
|
|
def broadcast_to_hashtag_streams!
|
|
@status.tags.pluck(:name).each do |hashtag|
|
|
Redis.current.publish("timeline:hashtag:#{hashtag.mb_chars.downcase}", anonymous_payload)
|
|
Redis.current.publish("timeline:hashtag:#{hashtag.mb_chars.downcase}:local", anonymous_payload) if @status.local?
|
|
end
|
|
end
|
|
|
|
def broadcast_to_public_streams!
|
|
return if @status.reply? && @status.in_reply_to_account_id != @account.id && !Setting.show_replies_in_public_timelines
|
|
|
|
Redis.current.publish('timeline:public', anonymous_payload)
|
|
Redis.current.publish(@status.local? ? 'timeline:public:local' : 'timeline:public:remote', anonymous_payload)
|
|
|
|
if @status.media_attachments.any?
|
|
Redis.current.publish('timeline:public:media', anonymous_payload)
|
|
Redis.current.publish(@status.local? ? 'timeline:public:local:media' : 'timeline:public:remote:media', anonymous_payload)
|
|
end
|
|
end
|
|
|
|
def deliver_to_conversation!
|
|
AccountConversation.add_status(@account, @status) unless update?
|
|
end
|
|
|
|
def anonymous_payload
|
|
@anonymous_payload ||= Oj.dump(
|
|
event: update? ? :'status.update' : :update,
|
|
payload: InlineRenderer.render(@status, nil, :status)
|
|
)
|
|
end
|
|
|
|
def update?
|
|
@is_update
|
|
end
|
|
|
|
def broadcastable?
|
|
@status.public_visibility? && !@account.silenced? && (!@status.reblog? || Setting.show_reblogs_in_public_timelines)
|
|
end
|
|
end
|