Passing current_user to Sidekiq

sidekiq_mediator.rb

module SidekiqMediator
  def perform_async(klass, *args)
    args.push(current_user.login)
    klass.send(:perform_async, *args)
  end
 end
 
 # EXAMPLE
 
class DeliveryController < ApplicationController
  include SidekiqMediator

  def update
    # update attributes
    perform_async(DeliveryUpdateWorker, params[:delivery])
    # render delivery
  end
end

class DeliveryDeleteWorker
  include Sidekiq::Worker

  def perform(delivery, user_login)
    user = User.find_by(login: user_login)
    ActivityGenerationService.new(delivery, user) if user
  end
end

including SidekiqMediator whenever we need to use current_user

reference: https://blog.bigbinary.com/2018/12/05/passing-current-user-by-default-in-sidekiq.html