hummingbird-me/kitsu-server

# frozen_string_literal: true

module Sidekiq
  module Middleware
    module Server
      class CurrentUser
        def call(_, job, _)
          # Extract the User ID from job metadata
          user = User.find_by(id: job['current_user'])
          # Save it onto the thread
          Thread.current[:current_user] = user
          # Send it to Sentry
          Sentry.set_user(id: user.id, name: user.name, email: user.email) if user
          # Run Sidekiq job
          yield
        ensure
          Thread.current[:current_user] = nil
        end
      end
    end
  end
end