diff options
Diffstat (limited to 'app/services')
-rw-r--r-- | app/services/publish_status_service.rb | 40 |
1 files changed, 31 insertions, 9 deletions
diff --git a/app/services/publish_status_service.rb b/app/services/publish_status_service.rb index 737186a17..f81b43a97 100644 --- a/app/services/publish_status_service.rb +++ b/app/services/publish_status_service.rb @@ -1,22 +1,44 @@ # frozen_string_literal: true class PublishStatusService < BaseService + include Redisable + def call(status) return if status.published? - status.update!(published: true) + @status = status - ProcessMentionsService.new.call(status) + update_status! + reset_status_caches + distribute + bump_potential_friendship! + end - LinkCrawlWorker.perform_in(rand(1..30).seconds, status.id) unless status.spoiler_text? - DistributionWorker.perform_async(status.id) - ActivityPub::DistributionWorker.perform_async(status.id) if status.local? && !status.local_only? + private - return if !status.reply? || status.account.id == status.in_reply_to_account_id + def update_status! + @status.update!(published: true) + ProcessMentionsService.new.call(@status) + end - ActivityTracker.increment('activity:interactions') + def reset_status_caches + Rails.cache.delete_matched("statuses/#{@status.id}-*") + Rails.cache.delete("statuses/#{@status.id}") + Rails.cache.delete(@status) + redis.zremrangebyscore("spam_check:#{@status.account.id}", @status.id, @status.id) + end - return if status.account.following?(status.in_reply_to_account_id) + def distribute + LinkCrawlWorker.perform_in(rand(1..30).seconds, @status.id) unless @status.spoiler_text? + DistributionWorker.perform_async(@status.id) + ActivityPub::DistributionWorker.perform_async(@status.id) if @status.local? && !@status.local_only? + end + + def bump_potential_friendship! + return if !@status.reply? || @status.account.id == @status.in_reply_to_account_id + + ActivityTracker.increment('activity:interactions') + return if @status.account.following?(@status.in_reply_to_account_id) - PotentialFriendshipTracker.record(status.account.id, status.in_reply_to_account_id, :reply) + PotentialFriendshipTracker.record(@status.account.id, @status.in_reply_to_account_id, :reply) end end |