Added recurring scheduled worker that will activate pending users

just3ws · just3ws · commit 75e13ed9ca5a · 2014-08-11T12:22:38.000-05:00
diff --git a/app/clock.rb b/app/clock.rb
@@ -6,7 +6,11 @@
 include Clockwork
 
 
-every(1.day, 'award:activate:active', at: '00:00') {   }
+# Runs as 1:01 AM Pacific
+every(1.day, 'award:activate:active', at: '01:01') do
+  ActivatePendingUsersWorker.perform_async
+end
+
 every(1.day, 'award:fresh:stale', at: '00:00') {}
 every(1.day, 'cleanup:protips:associate_zombie_upvotes', at: '00:00') {}
 every(1.day, 'clear_expired_sessions', at: '00:00') {}
diff --git a/app/models/user.rb b/app/models/user.rb
@@ -139,7 +139,7 @@ def banned?
   def activate
     UserActivateWorker.perform_async(id)
   end
-  
+
   def activate!
     # TODO: Switch to update, failing validations?
     update_attributes!(state: ACTIVE, activated_on: DateTime.now)
@@ -166,8 +166,6 @@ def oldest_achievement_since_last_visit
     badges.where("badges.created_at > ?", last_request_at).order('badges.created_at ASC').last
   end
 
-
-
   def company_name
     team.try(:name) || company
   end
@@ -177,7 +175,6 @@ def profile_url
     avatar_url
   end
 
-
   def can_be_refreshed?
     (achievements_checked_at.nil? || achievements_checked_at < 1.hour.ago)
   end
diff --git a/app/workers/activate_pending_users_worker.rb b/app/workers/activate_pending_users_worker.rb
@@ -0,0 +1,18 @@
+class ActivatePendingUsersWorker
+  include Sidekiq::Worker
+  sidekiq_options queue: :critical
+
+
+  def perform
+    # Spawning possibly many thousands
+    # of workers the order doesn't really matter
+    # but would like to spread their execution
+    # over the next hour to avoid overloading
+    # the database.
+    delay = 0
+    User.pending.find_each(batch_size: 100) do |user|
+      UserActivateWorker.perform_in(delay.minutes, user.id)
+      delay = delay + Random.rand(0..59)
+    end
+  end
+end
diff --git a/app/workers/user_activate_worker.rb b/app/workers/user_activate_worker.rb
@@ -1,4 +1,3 @@
-# UserActivateWorker
 class UserActivateWorker
   include Sidekiq::Worker
   sidekiq_options queue: :high
diff --git a/lib/tasks/award.rake b/lib/tasks/award.rake

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,3 @@`
`1`		`-# UserActivateWorker`
`2`	`1`	`class UserActivateWorker`
`3`	`2`	`include Sidekiq::Worker`
`4`	`3`	`sidekiq_options queue: :high`