app/workers/post_status_worker.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 PostStatusWorker
  include Sidekiq::Worker

  sidekiq_options unique: :until_executed

  def perform(status_id, options = {})
    status = Status.find(status_id)
    return false if status.destroyed?

    status.visibility = options[:visibility] if options[:visibility]
    status.local_only = options[:local_only] if options[:local_only]
    status.reject_replies = options[:reject_replies] if options[:reject_replies]
    status.save!

    process_mentions_service.call(status) unless options[:nomentions]
    Rails.cache.delete("formatted_status:#{status.id}")

    LinkCrawlWorker.perform_async(status.id) unless options[:nocrawl] || status.spoiler_text?
    DistributionWorker.perform_async(status.id) unless options[:distribute] == false

    unless status.local_only? || options[:distribute] == false || options[:federate] == false
      ActivityPub::DistributionWorker.perform_async(status.id)
    end

    PollExpirationNotifyWorker.perform_at(status.poll.expires_at, status.poll.id) if status.poll

    status.delete_after = options[:delete_after] if options[:delete_after]

    return true 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)

    true
  rescue ActiveRecord::RecordNotFound, ActiveRecord::RecordInvalid
    true
  end

  def process_mentions_service
    ProcessMentionsService.new
  end
end