Found that team members that weren't migrated were due STRIPE keys missing

just3ws · just3ws · commit 25e1116a52a3 · 2014-11-06T15:17:05.000-06:00
diff --git a/Rakefile b/Rakefile
@@ -125,8 +125,13 @@ namespace :team do
         #puts 'MEMBERS'
         #puts '----------------------------------------------------------------------------------------------------'
 
-        if pg_team.members.count != mongo_team.team_members.count
-          puts "members | pg:#{pg_team.id} | mongo:#{mongo_team.id}| #{mongo_team.team_members.count} != #{pg_team.members.count}"
+        if pg_team.members.count < mongo_team.team_members.count
+          puts "members | pg:#{pg_team.id} | mongo:#{mongo_team.id}| #{pg_team.members.count} < #{mongo_team.team_members.count}"
+
+          ap pg_team.members.count
+          ap mongo_team.team_members.count
+
+          #require 'pry'; binding.pry
         end
 
 
diff --git a/app/jobs/team_migrator_job.rb b/app/jobs/team_migrator_job.rb
@@ -161,13 +161,37 @@ def extract_links(pgteam, team)
   end
 
   def add_members(pgteam)
-    Rails.logger.info("add_members(#{pgteam.id})")
+    puts "add_members(#{pgteam.id})"
+
+    mongo_user_ids = Team.find(pgteam.mongo_id).team_members.map(&:id).uniq
+    pg_user_ids = User.where(team_document_id: pgteam.mongo_id).map(&:id).uniq
+    user_ids = mongo_user_ids.dup.concat(pg_user_ids).uniq
+
+    puts "-"*80
+    ap mongo_user_ids
+    ap pg_user_ids
+    ap user_ids
+
+    return nil if user_ids.empty?
+
+    users = User.where('id in (?)', user_ids)
 
-    users = User.where(team_document_id: pgteam.mongo_id)
     users.each do |user|
-      pgteam.members.create! user: user, state: 'active'
+      pgteam.members.create!(user: user, state: 'active')
     end
+
     users.update_all(team_id: pgteam.id)
+
+    puts "#{pgteam.members.count} #{mongo_user_ids.count}"
+
+    if pgteam.members.count != mongo_user_ids.count
+      puts "INCORRECT NUMBER OF MEMBERS MIGRATED"
+      ap pgteam.members.map(&:id) - user_ids
+      ap user_ids - pgteam.members.map(&:id)
+    end
+  rescue => ex
+    puts "THERE WAS AN ERROR ADDING MEMBERS"
+    ap ex
   end
 
   def add_jobs(pgteam)
