System-End/hackatime
1
0
Fork 0
mirror of https://github.com/System-End/hackatime.git synced 2026-04-19 23:32:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Also save total_minutes_logged to Airtable

Browse source
This commit is contained in:
Zach Latta 2025-05-14 16:10:01 -04:00
parent 06f3f6c7e3
commit e7ce5b9312
1 changed files with 24 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
app/jobs/update_airtable_user_data_job.rb
View file

@ -6,29 +6,47 @@ class UpdateAirtableUserDataJob < ApplicationJob
def perform
users_with_heartbeats.includes(:email_addresses).find_in_batches(batch_size: 100) do |batch|
records = []
# Efficiently calculate total coding seconds for all users in this batch
user_ids_in_batch = batch.map(&:id)
total_coding_seconds_per_user = Heartbeat
.where(user_id: user_ids_in_batch)
.coding_only # Only count "coding" category
.with_valid_timestamps
.group(:user_id) # Group by user
.duration_seconds # Returns a hash { user_id => seconds }
batch.each do |user|
first_heartbeat_time = user.heartbeats.with_valid_timestamps.order(time: :asc).limit(1).pluck(:time).first
first_direct_heartbeat_time = user.heartbeats.direct_entry.with_valid_timestamps.order(time: :asc).limit(1).pluck(:time).first
first_test_heartbeat_time = user.heartbeats.test_entry.with_valid_timestamps.order(time: :asc).limit(1).pluck(:time).first
created_at = user.created_at.to_i
next if first_heartbeat_time > Time.now.to_i
next if first_heartbeat_time.nil? || first_heartbeat_time > Time.now.to_f
# Get the pre-calculated total coding seconds for this user
user_total_coding_seconds = total_coding_seconds_per_user[user.id] || 0
total_minutes_logged = (user_total_coding_seconds / 60).to_i
user.email_addresses.map do |email_address|
records << Table.new({
email: email_address.email,
signed_up_at: Time.at(created_at).iso8601,
first_direct_heartbeat_time: first_direct_heartbeat_time ? Time.at(first_direct_heartbeat_time.to_i).iso8601 : nil,
first_test_heartbeat_time: first_test_heartbeat_time ? Time.at(first_test_heartbeat_time.to_i).iso8601 : nil,
first_heartbeat_time: Time.at(first_heartbeat_time.to_i).iso8601 # airtable expects milliseconds
first_direct_heartbeat_time: first_direct_heartbeat_time ? Time.at(first_direct_heartbeat_time.to_f).iso8601 : nil,
first_test_heartbeat_time: first_test_heartbeat_time ? Time.at(first_test_heartbeat_time.to_f).iso8601 : nil,
first_heartbeat_time: Time.at(first_heartbeat_time.to_f).iso8601, # airtable expects milliseconds
total_minutes_logged: total_minutes_logged # Add the new field here
})
end
end
Table.batch_upsert(records, "email")
# Only attempt to upsert if there are records to process
Table.batch_upsert(records, "email") if records.any?
end
end
private
def users_with_heartbeats
User.where(id: Heartbeat.with_valid_timestamps.group(:user_id).pluck(:user_id))
User.where(id: Heartbeat.with_valid_timestamps.distinct.pluck(:user_id))
end
end