app/workers/update_user_activity_worker.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

# frozen_string_literal: true

class UpdateUserActivityWorker
  include ApplicationWorker

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

    User.where(id: ids)
      .update_all([
        "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