coderwall
diff --git a/‎app/clock.rb
Lines changed: 16 additions & 6 deletions b/‎app/clock.rb
Lines changed: 16 additions & 6 deletions
diff --git a/‎app/jobs/protips_recalculate_scores_job.rb
Lines changed: 11 additions & 0 deletions b/‎app/jobs/protips_recalculate_scores_job.rb
Lines changed: 11 additions & 0 deletions
diff --git a/‎app/jobs/search_sync_job.rb
Lines changed: 33 additions & 0 deletions b/‎app/jobs/search_sync_job.rb
Lines changed: 33 additions & 0 deletions
diff --git a/‎lib/tasks/protips.rake
Lines changed: 0 additions & 72 deletions b/‎lib/tasks/protips.rake
Lines changed: 0 additions & 72 deletions
diff --git a/‎lib/tasks/search.rake
Lines changed: 0 additions & 108 deletions b/‎lib/tasks/search.rake
Lines changed: 0 additions & 108 deletions
@@ -5,7 +5,6 @@
 
 include Clockwork
 
-
 # Runs as 1:01 AM Pacific
 every(1.day, 'award:activate:active', at: '01:01') do
   ActivatePendingUsersWorker.perform_async
@@ -25,12 +24,23 @@
   end
 end
 
-every(1.day, 'cleanup:protips:associate_zombie_upvotes', at: '03:30') { CleanupProtipsAssociateZombieUpvotesJob.perform_async }
-every(1.day, 'clear_expired_sessions', at: '06:00') {  ClearExpiredSessionsJob.perform_async }
-every(1.day, 'protips:recalculate_scores', at: '00:00') {}
-every(1.day, 'search:sync', at: '00:00') {}
-every(1.day, 'teams:refresh', at: '00:00') {}
+every(1.day, 'cleanup:protips:associate_zombie_upvotes', at: '03:30') do
+  CleanupProtipsAssociateZombieUpvotesJob.perform_async
+end
+
+every(1.day, 'clear_expired_sessions', at: '06:00') do
+  ClearExpiredSessionsJob.perform_async
+end
 
+every(1.day, 'protips:recalculate_scores', at: '03:00') do
+  ProtipsRecalculateScoresJob.perform_async
+end
+
+every(1.day, 'search:sync', at: '04:00') do
+  SearchSyncJob.perform_async
+end
+
+every(1.day, 'teams:refresh', at: '00:00') {}
 
 # This is tied with broken code. Probably should delete
 every(1.day, 'facts:system', at: '00:00') {}
@@ -0,0 +1,11 @@
+class ProtipsRecalculateScoresJob
+  include Sidekiq::Worker
+
+  sidekiq_options queue: :low
+
+  def perform
+    Protip.where('created_at > ?', 25.hours.ago).where(upvotes_value_cache: nil).each do |protip|
+      ProcessProtipJob.perform_async(:recalculate_score, protip.id)
+    end
+  end
+end
@@ -0,0 +1,33 @@
+class SearchSyncJob
+  include Sidekiq::Worker
+
+  sidekiq_options queue: :medium
+
+  def perform
+    number_of_protips_in_index = Protip.tire.search { query { all } }.total
+    number_of_protips_in_database = Protip.count
+
+    if number_of_protips_in_index != number_of_protips_in_database
+      protips_in_index = Protip.tire.search do
+        size number_of_protips_in_index
+        query { all }
+      end.map { |protip| protip.id.to_i }
+
+      protips_in_database = Protip.select(:id).map(&:id)
+
+      #now that we know the sets in db and index, calculate the missing records
+      nonexistent_protips = (protips_in_index - protips_in_database)
+      unindexed_protips = (protips_in_database - protips_in_index)
+
+      nonexistent_protips.each do |nonexistent_protip_id|
+        Protip.index.remove({'_id' => nonexistent_protip_id, '_type' => 'protip'})
+      end
+
+      unindexed_protips.each do |unindexed_protip_id|
+        IndexProtip.perform_async(unindexed_protip_id)
+      end
+
+      puts "removed #{nonexistent_protips.count} protips and added #{unindexed_protips.count} protips"
+    end
+  end
+end