Class: ApiKeys::Jobs::UpdateStatsJob

Inherits:
ActiveJob::Base
  • Object
show all
Includes:
Logging
Defined in:
lib/api_keys/jobs/update_stats_job.rb

Overview

Background job to update API key usage statistics (last_used_at, requests_count). Enqueued by the Authentication concern after a successful request.

Instance Method Summary collapse

Instance Method Details

#perform(api_key_id, timestamp) ⇒ Object

Perform the database updates for the given ApiKey.

Parameters:

  • api_key_id (Integer, String) —

    The ID of the ApiKey to update.

  • timestamp (Time) —

    The timestamp of the request (when it was authenticated).



21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/api_keys/jobs/update_stats_job.rb', line 21

def perform(api_key_id, timestamp)
  api_key = ApiKey.find_by(id: api_key_id)

  unless api_key
    log_warn "[ApiKeys::Jobs::UpdateStatsJob] ApiKey not found with ID: #{api_key_id}. Skipping stats update."
    return
  end

  log_debug "[ApiKeys::Jobs::UpdateStatsJob] Updating stats for ApiKey ID: #{api_key_id} at #{timestamp}"

  # Use provided timestamp for consistency
  # Use update_column to skip validations/callbacks for performance
  api_key.update_column(:last_used_at, timestamp)

  # Conditionally increment requests_count if configured
  if ApiKeys.configuration.track_requests_count
    # Use increment_counter for atomic updates
    ApiKey.increment_counter(:requests_count, api_key.id)
    log_debug "[ApiKeys::Jobs::UpdateStatsJob] Incremented requests_count for ApiKey ID: #{api_key_id}"
  end

  log_debug "[ApiKeys::Jobs::UpdateStatsJob] Finished updating stats for ApiKey ID: #{api_key_id}"

rescue ActiveRecord::ActiveRecordError => e
  # Log error but don't automatically retry unless configured to do so.
  # Frequent stats updates might tolerate occasional failures better than endless retries.
  log_error "[ApiKeys::Jobs::UpdateStatsJob] Failed to update stats for ApiKey ID: #{api_key_id}. Error: #{e.message}"
  # Depending on ActiveJob adapter, specific retry logic might be needed here
  # or configured globally. For now, just log.
rescue StandardError => e
  log_error "[ApiKeys::Jobs::UpdateStatsJob] Unexpected error processing ApiKey ID: #{api_key_id}. Error: #{e.class}: #{e.message}
#{e.backtrace.join("
")}"
  # Consider re-raising or using a dead-letter queue strategy depending on job system
end