richthegeek
diff --git a/‎Gemfile.lock
Lines changed: 21 additions & 11 deletions b/‎Gemfile.lock
Lines changed: 21 additions & 11 deletions
diff --git a/‎Rakefile
Lines changed: 69 additions & 0 deletions b/‎Rakefile
Lines changed: 69 additions & 0 deletions
diff --git a/‎Vagrantfile
Lines changed: 9 additions & 3 deletions b/‎Vagrantfile
Lines changed: 9 additions & 3 deletions
diff --git a/‎app/jobs/team_migrator_batch_job.rb
Lines changed: 6 additions & 2 deletions b/‎app/jobs/team_migrator_batch_job.rb
Lines changed: 6 additions & 2 deletions
@@ -1,16 +1,12 @@
 GIT
-  remote: git://github.com/emberjs/ember-rails.git
-  revision: 5e5a398f3c67c3a3b84b7513b93b22bf81055cc9
+  remote: https://github.com/rebelidealist/stripe-ruby-mock
+  revision: f4229cbe762bc2a5a302cdd83088c283881e9c5a
+  branch: live-tests
   specs:
-    ember-rails (0.15.0)
-      active_model_serializers
-      barber (>= 0.4.1)
-      ember-data-source (>= 1.0.0.beta.5)
-      ember-source (>= 1.1.0)
-      execjs (>= 1.2)
-      handlebars-source (> 1.0.0)
-      jquery-rails (>= 1.0.17)
-      railties (>= 3.1)
+    stripe-ruby-mock (1.10.1.7)
+      dante (>= 0.2.0)
+      jimson-temp
+      stripe (>= 1.15.0)
 
 GIT
   remote: git://github.com/nixme/jazz_hands.git
@@ -38,6 +34,20 @@ GIT
       mime-types (>= 1.25, < 3.0)
       rest-client (~> 1.4)
 
+GIT
+  remote: git://github.com/emberjs/ember-rails.git
+  revision: 5e5a398f3c67c3a3b84b7513b93b22bf81055cc9
+  specs:
+    ember-rails (0.15.0)
+      active_model_serializers
+      barber (>= 0.4.1)
+      ember-data-source (>= 1.0.0.beta.5)
+      ember-source (>= 1.1.0)
+      execjs (>= 1.2)
+      handlebars-source (> 1.0.0)
+      jquery-rails (>= 1.0.17)
+      railties (>= 3.1)
+
 GEM
   remote: https://rubygems.org/
   remote: https://rails-assets.org/
 
@@ -4,3 +4,72 @@ require 'rake'
 Coderwall::Application.load_tasks
 
 task default: :spec
+
+
+namespace :team do
+  task migrate: :environment do
+    TeamMigratorBatchJob.new.perform
+  end
+
+  #
+  # IMPORTANT: pending_join_requests is a STRING array in Postgres but an INTEGER array in MongoDB.
+  # IMPORTANT: pending_join_requests is an array of User#id values
+  #
+
+  def neq(attr, pg, mongo, fail_if_neq=true)
+    left =  pg.send(attr)
+    right = mongo.send(attr)
+
+    if left != right
+      puts "#{attr}   #{left} != #{right}  (#{pg.id}|#{mongo.id})"
+
+      if fail_if_neq
+        require 'pry'; binding.pry
+      end
+    end
+  end
+
+  task verify: :environment do
+    PgTeam.find_each(batch_size: 100) do |pg_team|
+      begin
+        mongo_id = pg_team.mongo_id
+        mongo_team = Team.find(mongo_id)
+
+
+        %i(updated_at median score total slug mean pending_join_requests).each do |attr|
+          neq(attr, pg_team, mongo_team, false)
+        end
+
+
+        %i(about achievement_count analytics benefit_description_1 benefit_description_2 benefit_description_3 benefit_name_1 benefit_name_2 benefit_name_3 big_image big_quote blog_feed branding country_id created_at endorsement_count facebook featured_banner_image featured_links_title github github_organization_name headline hide_from_featured highlight_tags hiring_tagline interview_steps invited_emails link_to_careers_page location monthly_subscription name number_of_jobs_to_show office_photos organization_way organization_way_name organization_way_photo our_challenge paid_job_posts premium preview_code reason_description_1 reason_description_2 reason_description_3 reason_name_1 reason_name_2 reason_name_3 size stack_list twitter upcoming_events upgraded_at valid_jobs website why_work_image your_impact youtube_url).each do |attr|
+          neq(attr, pg_team, mongo_team)
+        end
+      rescue => ex
+
+        ap ex
+
+        require 'pry'; binding.pry
+      end
+    end
+  end
+
+  task counts: :environment do
+    pg_team_count = PgTeam.count
+    puts "PgTeam.count=#{pg_team_count}"
+    team_count = Team.count
+    puts "Team.count=#{team_count}"
+    puts "Unmigrated teams count=#{(team_count - pg_team_count)}"
+  end
+
+
+  task unmigrated: :environment do
+    unmigrated_teams = []
+
+    Team.all.each do |team|
+      unmigrated_teams << team.id.to_s unless PgTeam.where(mongo_id: team.id.to_s).exists?
+    end
+
+    puts "Unmigrated teams count=#{unmigrated_teams.count}"
+    puts "Unmigrated Teams=%w(#{unmigrated_teams.join(' ')})"
+  end
+end
@@ -26,10 +26,10 @@ $provision = 'vagrant/bootstrap.sh'
 
 Vagrant.configure(VAGRANTFILE_API_VERSION) do |config|
 
-  config.vm.box = $box
-  config.vm.box_url = $box_url
+  config.vm.box = box
+  #config.vm.box_url = box_url
   config.vm.provision :shell do |s|
-    s.path = $provision
+    s.path = provision
   end
 
   config.ssh.keep_alive = true
@@ -70,6 +70,12 @@ Vagrant.configure(VAGRANTFILE_API_VERSION) do |config|
   else
     puts "Please install the 'vagrant-vbguest' plugin"
   end
+
+  #if Vagrant.has_plugin?('vagrant-cachier')
+    #config.cache.scope = :box
+  #else
+    #puts "Please install the 'vagrant-cachier' plugin"
+  #end
 end
 
 def set_port_mapping_for(config, service, guest_port, settings, force = false)
 
@@ -3,8 +3,12 @@ class TeamMigratorBatchJob
   include Sidekiq::Worker
 
   def perform
-    Team.each  do |team|
-      TeamMigratorJob.perform_async(team.id.to_s)
+    Team.each do |team|
+      begin
+        TeamMigratorJob.perform_async(team.id.to_s)
+      rescue => ex
+        Rails.logger.error("[#{team.id.to_s}] #{ex} >>\n#{ex.backtrace.join("\n  ")}")
+      end
     end
   end
 end