app/workers/distribution_worker.rb

   1 # frozen_string_literal: true
   2
   3 class DistributionWorker
   4   include Sidekiq::Worker
   5
   6   def perform(status_id)
   7     RedisLock.acquire(redis: Redis.current, key: "distribute:#{status_id}") do |lock|
   8       if lock.acquired?
   9         FanOutOnWriteService.new.call(Status.find(status_id))
  10       else
  11         raise Mastodon::RaceConditionError
  12       end
  13     end
  14   rescue ActiveRecord::RecordNotFound
  15     true
  16   end
  17 end