Adding support for User Stats import to the generic importer

script/bulk_import/generic_bulk.rb

@@ -23,14 +23,15 @@ class BulkImport::Generic < BulkImport::Base
   end
 
   def execute
-    import_categories
-    import_users
-    import_user_emails
+    # import_categories
+    # import_users
+    # import_user_emails
     #import_single_sign_on_records
-    import_topics
-    import_posts
-    import_topic_allowed_users
-    import_likes
+    # import_topics
+    # import_posts
+    # import_topic_allowed_users
+    # import_likes
+    import_user_stats
   end
 
   def import_categories
@@ -229,6 +230,50 @@ class BulkImport::Generic < BulkImport::Base
     end
   end
 
+  def import_user_stats
+    puts "Importing user stats..."
+
+    users = @db.execute(<<~SQL)
+        WITH posts_counts AS (SELECT COUNT(p.id) as count, p.user_id FROM posts p GROUP BY p.user_id),
+        topic_counts AS (SELECT COUNT(t.id) as count, t.user_id FROM topics t GROUP BY t.user_id),
+        first_post AS (SELECT MIN(p.created_at) as created_at, p.user_id FROM posts p GROUP BY p.user_id ORDER BY p.created_at ASC)
+        SELECT u.id as user_id, u.created_at, pc.count as posts, tc.count as topics, fp.created_at as first_post
+        FROM users u
+        JOIN posts_counts pc ON u.id = pc.user_id
+        JOIN topic_counts tc ON u.id = tc.user_id
+        JOIN first_post fp on u.id = fp.user_id
+    SQL
+
+    create_user_stats(users) do |row|
+      user = {
+        imported_id: row["user_id"],
+        imported_user_id: row["user_id"],
+        new_since: to_datetime(row["created_at"]),
+        post_count: row["posts"],
+        topic_count: row["topics"],
+        first_post_created_at: to_datetime(row["first_post"])
+      }
+
+      likes_received = @db.execute(<<~SQL)
+        SELECT COUNT(l.id) as likes_received FROM likes l join posts p on l.post_id = p.id WHERE p.user_id = #{row["user_id"]}
+      SQL
+
+      if likes_received
+        user[:likes_received] = row["likes_received"]
+      end
+
+      likes_given = @db.execute(<<~SQL)
+        SELECT COUNT(l.id) as likes_given FROM likes l WHERE l.user_id = #{row["user_id"]}
+      SQL
+
+      if likes_given
+        user[:likes_given] = row["likes_given"]
+      end
+
+      user
+    end
+  end
+
   def create_connection(path)
     sqlite = SQLite3::Database.new(path, results_as_hash: true)
     sqlite.busy_timeout = 60000 # 60 seconds