app/services/publish_status_service.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

# frozen_string_literal: true
class PublishStatusService < BaseService
  include Redisable

  def call(status)
    return if status.published?

    @status = status

    update_status!
    reset_status_caches
    distribute
    bump_potential_friendship!
  end

  private

  def update_status!
    @status.update!(published: true)
    ProcessMentionsService.new.call(@status)
  end

  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

  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)
  end
end