Add logging to remaining jobs

Author: ArtOfCode-

app/jobs/clean_up_new_thread_followers_job.rb

@@ -16,9 +16,14 @@ def perform
       result = duplicate.destroy
 
       unless result
-        puts "failed to destroy new thread follower duplicate \"#{duplicate.id}\""
+        logger.warn "Failed to destroy new thread follower duplicate \"#{duplicate.id}\. Validations follow."
+        duplicate.errors.full_messages.each do |msg|
+          logger.warn msg
+        end
         duplicate.errors.each { |e| puts e.full_message }
       end
     end
+
+    logger.info "Processed #{posts.size} posts."
   end
 end

app/jobs/clean_up_spammy_users_job.rb

@@ -9,6 +9,8 @@ def perform(created_after: 1.month.ago)
                             .where(users: { deleted: false }).group('users.id').having('count(posts.id) > 0')
                             .having('count(distinct if(posts.deleted = true, null, posts.id)) = 0')
 
+    blocked = 0
+
     possible_spammers.each do |spammer|
       all_posts_spam = spammer.posts.all? do |post|
         # A post is considered spam if there are any helpful spam flags on it.
@@ -17,9 +19,12 @@ def perform(created_after: 1.month.ago)
         end
       end
       if all_posts_spam
+        blocked += 1
         spammer.block('automatic block from spam cleanup job', length: 2.years)
         spammer.soft_delete(User.system)
       end
     end
+
+    logger.info "Considered #{possible_spammers.count} potential spammers, blocked #{blocked}."
   end
 end

app/jobs/clean_up_thread_followers_job.rb

@@ -16,9 +16,14 @@ def perform
       result = duplicate.destroy
 
       unless result
-        puts "failed to destroy thread follower duplicate \"#{duplicate.id}\""
+        logger.warn "Failed to destroy thread follower duplicate \"#{duplicate.id}\. Validations follow."
+        duplicate.errors.full_messages.each do |msg|
+          logger.warn msg
+        end
         duplicate.errors.each { |e| puts e.full_message }
       end
     end
+
+    logger.info "Processed #{threads.size} threads."
   end
 end

app/jobs/cleanup_votes_job.rb

@@ -3,28 +3,33 @@ class CleanupVotesJob < ApplicationJob
 
   def perform
     Community.all.each do |c|
-      RequestContext.community = c
-      orphan_votes = Vote.all.reject { |v| v.post.present? }
+      logger.tagged(c.name) do
+        RequestContext.community = c
+        orphan_votes = Vote.all.reject { |v| v.post.present? }
 
-      puts "[#{c.name}] destroying #{orphan_votes.length} #{'orphan vote'.pluralize(orphan_votes.length)}"
+        logger.info "Removing #{orphan_votes.length} #{'orphan vote'.pluralize(orphan_votes.length)}"
 
-      system_user = User.find(-1)
+        system_user = User.find(-1)
 
-      orphan_votes.each do |v|
-        result = v.destroy
+        orphan_votes.each do |v|
+          result = v.destroy
 
-        if result
-          AuditLog.admin_audit(
-            comment: "Deleted orphaned vote for user ##{v.recv_user_id} " \
-                     "on post ##{v.post_id} " \
-                     "in community ##{c.id} (#{c.name})",
-            event_type: 'vote_delete',
-            related: v,
-            user: system_user
-          )
-        else
-          puts "[#{c.name}] failed to destroy vote \"#{v.id}\""
-          v.errors.each { |e| puts e.full_message }
+          if result
+            AuditLog.admin_audit(
+              comment: "Deleted orphaned vote for user ##{v.recv_user_id} " \
+                       "on post ##{v.post_id} " \
+                       "in community ##{c.id} (#{c.name})",
+              event_type: 'vote_delete',
+              related: v,
+              user: system_user
+            )
+          else
+            logger.warn "Failed to remove vote #{v.id}. Validations follow."
+            v.errors.full_messages.each do |msg|
+              logger.warn msg
+            end
+            v.errors.each { |e| puts e.full_message }
+          end
         end
       end
     end

app/jobs/potential_spam_profiles_job.rb

@@ -14,5 +14,7 @@ def perform
       UserAbility.where(community_user_id: cu_ids, ability_id: ability_ids)
                  .update_all(is_suspended: true, suspension_message: 'This ability has been automatically suspended.')
     end
+
+    logger.info "Found #{users.size} likely spam profiles & suspended abilities."
   end
 end

app/jobs/send_summary_emails_job.rb

@@ -15,5 +15,7 @@ def perform
                    .content_summary
                    .deliver_later
     end
+
+    logger.info "Scheduled send of #{staff.size} emails."
   end
 end

config/initializers/job_logger.rb

@@ -6,6 +6,7 @@ def job_logger
       if @job_logger.nil?
         logger = ActiveSupport::Logger.new(Rails.root.join('log/jobs.log'))
         logger.level = ActiveSupport::Logger::INFO
+        logger.formatter = ::Logger::Formatter.new
         @job_logger = ActiveSupport::TaggedLogging.new(logger)
       else
         @job_logger