blob: cdce28047d4e383c1f5f3e3084ec4dd1e85a74e8 (
plain) (
blame)
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
|
# frozen_string_literal: true
class PostStatusWorker
include Sidekiq::Worker
def perform(status_id, options = {})
status = Status.find(status_id)
return false if status.destroyed?
options.symbolize_keys!
status.update!(options.slice(:visibility, :local_only, :reject_replies, :hidden).compact)
status.reload
Rails.cache.delete("statuses/#{status.id}")
process_mentions_service.call(status, skip_process: (options[:process_mentions] != true)) unless options[:nomentions]
LinkCrawlWorker.perform_async(status.id) unless options[:nocrawl] || status.spoiler_text.present?
DistributionWorker.perform_async(status.id) unless options[:distribute] == false
unless status.local_only? || options[:distribute] == false || options[:federate] == false || status.hidden
ActivityPub::DistributionWorker.perform_async(status.id)
end
PollExpirationNotifyWorker.perform_at(status.poll.expires_at, status.poll.id) if status.poll
return true if !status.reply? || status.account.id == status.in_reply_to_account_id || status.hidden
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
private
def process_mentions_service
ProcessMentionsService.new
end
end
|
