app/services/remove_status_for_account_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

# frozen_string_literal: true

class RemoveStatusForAccountService < BaseService
  include Redisable

  def call(account, status)
    @account      = account
    @status       = status
    @payload      = Oj.dump(event: :delete, payload: status.id.to_s)

    RedisLock.acquire(lock_options) do |lock|
      if lock.acquired?
        remove_from_feeds
        remove_from_lists
      else
        raise Mastodon::RaceConditionError
      end
    end
  end

  private

  def remove_from_feeds
    FeedManager.instance.unpush_from_home(@account, @status)
    Redis.current.publish("timeline:direct:#{@account.id}", @payload)
    redis.publish("timeline:#{@account.id}", @payload)
  end

  def remove_from_lists
    @account.lists_for_local_distribution.select(:id, :account_id).reorder(nil).find_each do |list|
      FeedManager.instance.unpush_from_list(list, @status)
    end
  end

  def lock_options
    { redis: Redis.current, key: "distribute:#{@status.id}" }
  end
end