BigW Consortium Gitlab

update_user_activity_worker.rb 592 Bytes
Newer Older
1 2 3 4 5 6 7 8 9
class UpdateUserActivityWorker
  include Sidekiq::Worker
  include DedicatedSidekiqQueue

  def perform(pairs)
    pairs = cast_data(pairs)
    ids = pairs.keys
    conditions = 'WHEN id = ? THEN ? ' * ids.length

10 11
    User.where(id: ids)
      .update_all([
12 13 14 15 16 17 18 19 20 21 22 23 24 25 26
        "last_activity_on = CASE #{conditions} ELSE last_activity_on END",
        *pairs.to_a.flatten
      ])

    Gitlab::UserActivities.new.delete(*ids)
  end

  private

  def cast_data(pairs)
    pairs.each_with_object({}) do |(key, value), new_pairs|
      new_pairs[key.to_i] = Time.at(value.to_i).to_s(:db)
    end
  end
end