|
|
|
@ -40,7 +40,6 @@ class FanOutOnWriteService < BaseService
|
|
|
|
deliver_to_self!
|
|
|
|
deliver_to_self!
|
|
|
|
|
|
|
|
|
|
|
|
unless @options[:skip_notifications]
|
|
|
|
unless @options[:skip_notifications]
|
|
|
|
notify_quoted_account!
|
|
|
|
|
|
|
|
notify_mentioned_accounts!
|
|
|
|
notify_mentioned_accounts!
|
|
|
|
notify_about_update! if update?
|
|
|
|
notify_about_update! if update?
|
|
|
|
end
|
|
|
|
end
|
|
|
|
@ -70,12 +69,6 @@ class FanOutOnWriteService < BaseService
|
|
|
|
FeedManager.instance.push_to_home(@account, @status, update: update?) if @account.local?
|
|
|
|
FeedManager.instance.push_to_home(@account, @status, update: update?) if @account.local?
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
|
|
def notify_quoted_account!
|
|
|
|
|
|
|
|
return unless @status.quote&.quoted_account&.local? && @status.quote&.accepted?
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
LocalNotificationWorker.perform_async(@status.quote.quoted_account_id, @status.quote.id, 'Quote', 'quote')
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def notify_mentioned_accounts!
|
|
|
|
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|
|
|
|
|
@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|
|
|
|
|
LocalNotificationWorker.push_bulk(mentions) do |mention|
|
|
|
|
|