Merge pull request #357 from hackclub/fix-ahoy-backfill-job-model-naming

fix(ahoy): fix incorrect insert of backfilled ahoy...

Author: maxwofford

app/jobs/ahoy_backfill_project_created_job.rb

@@ -4,17 +4,25 @@ class AhoyBackfillProjectCreatedJob < ApplicationJob
   queue_as :default
 
   def perform
-    result = ActiveRecord::Base.connection.execute(<<~SQL)
-      INSERT INTO ahoy_events (name, user_id, time, properties)
-      SELECT 'project_created', pm.user_id, MIN(pm.created_at), '{"source":"backfill"}'::jsonb
-      FROM project_memberships pm
-      WHERE NOT EXISTS (
-        SELECT 1 FROM ahoy_events ae
-        WHERE ae.user_id = pm.user_id AND ae.name = 'project_created'
-      )
-      GROUP BY pm.user_id
-    SQL
+    already_tracked = Ahoy::Event
+      .where(name: "project_created")
+      .where.not(user_id: nil)
+      .distinct
+      .pluck(:user_id)
 
-    Rails.logger.info("[AhoyBackfillProjectCreated] backfilled #{result.cmd_tuples} events")
+    missing = Project::Membership
+      .where.not(user_id: already_tracked)
+      .group(:user_id)
+      .minimum(:created_at)
+
+    return if missing.empty?
+
+    rows = missing.map do |user_id, first_project_at|
+      { name: "project_created", user_id: user_id, time: first_project_at, properties: { source: "backfill" } }
+    end
+
+    Ahoy::Event.insert_all(rows)
+
+    Rails.logger.info("[AhoyBackfillProjectCreated] backfilled #{rows.size} events")
   end
 end