Merge pull request #2001 from codidact/art/jobs-again

Fix scheduled jobs

Author: Oaphi

.github/workflows/ci-cd.yml

@@ -87,6 +87,7 @@ jobs:
           bundler-cache: true
       - name: Prepare for testing
         run: |
+          echo "${{ secrets.MASTER_KEY }}" > config/master.key
           cp config/database.sample.yml config/database.yml
           cp config/storage.sample.yml config/storage.yml
           bundle exec rails db:create

app/jobs/application_job.rb

@@ -5,7 +5,7 @@ class ApplicationJob < ActiveJob::Base
   # Most jobs are safe to ignore if the underlying records are no longer available
   discard_on ActiveJob::DeserializationError
 
-  def initialize
+  def initialize(*args, **opts)
     @job_id = SecureRandom.uuid
     super
   end

app/jobs/mail_uncaptured_donations_job.rb

@@ -0,0 +1,29 @@
+class MailUncapturedDonationsJob < ApplicationJob
+  queue_as :default
+
+  def perform(*_args)
+    intents = Stripe::PaymentIntent.list
+    mailed = 0
+    errors = 0
+    intents.auto_paging_each do |pi|
+      break unless Time.at(pi.created) >= 24.hours.ago
+      next unless pi.status == 'requires_payment_method'
+      next unless pi.metadata['user_id'].present?
+      next if pi.metadata['emailed'].present?
+
+      user = User.find(pi.metadata['user_id'])
+      symbol = { 'GBP' => '£', 'USD' => '$', 'EUR' => '€' }[pi.currency.upcase]
+      amount = pi.amount / 100
+      DonationMailer.with(currency: symbol, amount: amount, email: user.email, name: user.username, intent: pi)
+                    .donation_uncaptured.deliver_now
+      Stripe::PaymentIntent.update(pi.id, { metadata: { emailed: true } })
+      logger.debug "Mailed ##{user.id} for PaymentIntent #{pi.id}"
+      mailed += 1
+    rescue => e
+      Stripe::PaymentIntent.update(pi.id, { metadata: { email_error: e.message.to_s } })
+      logger.error "Error sending email for user #{user.id}, PaymentIntent #{pi.id}: #{e.message}"
+      errors += 1
+    end
+    logger.info "Mailed #{mailed} donations, #{errors} errors"
+  end
+end

app/jobs/recalc_abilities_job.rb

@@ -0,0 +1,55 @@
+class RecalcAbilitiesJob < ApplicationJob
+  queue_as :default
+
+  ##
+  # Perform ability recalculations.
+  # @param options [Hash] additional options for the job. Currently supports +verbose+ and +quiet+.
+  def perform(**options)
+    resolved = []
+    destroy = []
+    all = AbilityQueue.pending.to_a
+
+    all.each do |q|
+      cu = q.community_user
+      u = cu&.user
+
+      if cu.nil? || u.nil?
+        destroy << q.id
+        next
+      end
+
+      RequestContext.community = cu.community
+
+      if options[:verbose] && !options[:quiet]
+        logger.debug "Scope: Community     : #{cu.community.name} (#{cu.community.host})"
+        logger.debug "       User          : #{u.username} (#{cu.user_id})"
+        logger.debug "       CommunityUser : #{cu.id}"
+      elsif !options[:verbose] && !options[:quiet]
+        logger.debug "Scope: CommunityUser : #{cu.id}"
+      end
+
+      cu.recalc_abilities!
+
+      # Grant mod ability if mod status is given
+      if cu.at_least_moderator? && !cu.ability?('mod')
+        cu.grant_ability!('mod')
+      end
+
+      resolved << q.id
+    rescue => e
+      logger.error "  Failed: #{e.class.name}: #{e.message}"
+      logger.error e.backtrace
+
+      if Rails.env.test?
+        raise e
+      end
+    end
+
+    AbilityQueue.where(id: resolved).update(completed: true)
+    AbilityQueue.where(id: destroy).delete_all
+
+    unless options[:quiet]
+      logger.info "Completed, #{resolved.size}/#{all.size} tasks successful, #{destroy.size} tasks invalid"
+    end
+  end
+end

config/credentials.yml.enc

@@ -1 +1 @@
-SA7h7Xm7xF3AEvje/xZiPMzem0wh2CysuvvB+iM6R0Epkg+z+vZG2oxI/9tVzDGELWtwoNDPeqNa0bUbGjo6gt7xyEpmQbivEVKnwcbVK+1bxPHKke+hveVEUhmY/axFIIpty+VTnZVnrJkZ35/rW9egcRr5O2HikuAuBz8KrYLvB2w3h8EdmcIbbfjMvKWlUVvc8D9t3v+k56B1CbTghTmGeG0NLijWAA+U+pDmErPOR9JUAVY/nbF2/T8aQ5Szameuoj88Pk5P6alFDHwlWUSHhuEY5Z7A5LKM1NtzlTGc+CAcTVzKvx6DCg8WUJugy3uS7Bpp6uNj9TvJoZzrb0i5G1nDmIl7tK2GCNclp3JFEklrUJIrF4asRuDQUzdvuPeTEXNyi2cc5d6hSBG+MwEvG90P6n0td5+gv+rr1FCKuzP5ftyxqPsnvZuBKRxNSw0+VTTXhTO73jcwttHYrD9Jwc9tVbCVqegwsEO0dB0sNL6M89rudDMbpPnz7rJXr6lXD4Az3qJ/0N3ubYDwiuGOk7UHDntm4Id4BFDm5qeLeOUg1n2PDhsQUWh2Lfnk7ADvjQMinfXhdAQkYVim9sDtNO/Grn9xSXfCn3vs1xOdTtKLb23+EIxO2STtkHTsJG5XvxC2jmzL5/zQx/vO/zepHom7POdso4Ygoqw9oEttm/KPG85lcX0edXv/l1i5JBMMbzaQgd1PL4uWwrv+3LoSq+vQORijR50OiLdlMZ5IFn+QagJEdeVtUiCbYA3AhUK/FcH3L5QtSGNObEUrUJ4fVuWP6X8E34vd+DoY++D6PtG89SFIGBRmQ23cT111uIw3p2A9HP4N9B/uNKwxAnr4S1he6EkoA5CtDE0NZufy25s0IVf//FDWXS8FDg3ZhtOUeMWB0dew9VeCCWwr8RrLu4jP46IvVqfFeiVWf7gJcenEJ0QuqPlBeukSpgNxckDjwijRz5obzeS9ZAWYgCZg2kg/6CmuIM2VjkWMJ13uKYkFgpheoNsk1jZwH4+0fdm+Zc+fE4KQFcSkkazea/qEanN2/tDo6pRowSlRpi/nWJqHxcu87QMm7cBq5/E9DNjwyKOPmgr7c2NzDrlPYMRgzdcauPz6Y4qfcg9C6lKwJIo18VQhrqwh7wW+nNTov3Shw/yclkVrxnHTQbyH3mOstJsVPpYeYewxOQj/gikvvkx/lUeUnyo2/Ebff2nJCbnLmJ8/7Vwz9c/yvg==--d1HPd+AnhFU1woqD--z2ikkRr6d5WTzC7X5xOVPA==
+ukMy8KvWRehfYquyl3GRlaSkFk/8OAjIw3HK2LIH4u1HhtiY2XrkXbwg3rKeCofCW1K5lxNf7r+w+v0IMfVnOkmOPI0eB/TNotrq0ieomzMnhYOXzBBQb/31vFFMFCGOZIRbk9vyduQGg/wifWMjoEk9ooL++YP2q+fXm/80d2gDF/G4hMNgdAq0SFPjn3cVM2Qty1ru1BuOJwgqo4yKDBjvuL7ZOxudDuPnKujY2IpgykCkKCk7TE80v9B4ZKdIi27P1ciWmP5Kc50jk7SWlhHVbo3FdJy1a/n5RadGq/vdlwOXFdyNUvlRF7xRvjlgiqoyqDHcyOuOyIP86v2qgeDl5Y7yYwIhe8FwqPy/oW/jMDP8OvDZuWtNwpxIFJYT7sKdvIvEvjrPR+0pyTVsVMZomTiUIcFC/IA9KV+DVjtj+Tfy2UZH4W8AU6i8hObiSs4CbT081L2AHc0ZcLKMI/bh8+vBay4J2UB6vcBbpNbAaNPyj7bXsrM0+YxpPJidgrEMyoVt+fIiA5H/kXhp8WV3Jkr2eEriq5z9+m6IZFSFs58i06hN0ZH5WHUdhJcVIgMBiLOex4SVd9zL6NW2y+ZK9Fs27z8u22zn+51oQHcpz2wbmVV3sGBYaFLFinqm3/HoW60eAcvM4SfXErz0fwIzq7yN7XIY9q5/6E0hhAdHZQqVlEJWOhUAIH9ik+Ga90gWLfkkoym/G1PIUYnmeJtLUKYyj94b+YdxQNkgzGtJA7FCGVmNUuy8wCw0OIG1hg3z9TSg5mbN7ZNhBRVDvKQENJqg9tFXM0MgXn+lQ0v+io4ds6Ist2BGr4gJIz5R7bRFOIG6G60/+ZEfPBjNcj5rrGYDBATmqKo9myaSLQ68WyJB37Fs3CchM4lAdoVbXnEyJwP8HGRaips+ZhjBVvSs/8w7yQteBswFrc00+gts5TpqCz3AjNNMsHTP5cr5IhqoNWdpxvFgHHLBAPtn0HWJ5C3OP3X/4GhxG3G9Z99pxbH1ZjWn1vnKadKUfY4vzPYCZsMaokTr2/XuL8wROLohCD53SVATsGsbiL947u+X6WYEZVuOH2IY5xMhTO9JW8DYb0Rm31Te8oOpzoIrz9Ck70YDQcADiNg4SEeLTQlpve40C5+YI5Xr+60GbOHRHSGv31ENnubVTCTv3q6otE0iqCOAQ62RdqhzT23aaz0NuH5DtLIlWn/3ev9Js6mm1rnF7AzVKey01IsS--p3woHV6iIC4KuPxP--fRXQKncEML1whOWmVm2Z8w==

scripts/change_to_wilson_scores.rb

@@ -1 +1 @@
-CleanupVotesJob.perform_later
+CleanupVotesJob.perform_now

scripts/cleanup_votes.rb

@@ -1,18 +1 @@
-intents = Stripe::PaymentIntent.list
-intents.auto_paging_each do |pi|
-  begin
-    break unless Time.at(pi.created) >= 24.hours.ago
-    next unless pi.status == 'requires_payment_method'
-    next unless pi.metadata['user_id'].present?
-    next if pi.metadata['emailed'].present?
-    user = User.find(pi.metadata['user_id'])
-    symbol = { 'GBP' => '£', 'USD' => '$', 'EUR' => '€' }[pi.currency.upcase]
-    amount = pi.amount / 100
-    DonationMailer.with(currency: symbol, amount: amount, email: user.email, name: user.username, intent: pi)
-                  .donation_uncaptured.deliver_now
-    Stripe::PaymentIntent.update(pi.id, { metadata: { emailed: true } })
-    puts "Mailed ##{user.id} for PaymentIntent #{pi.id}"
-  rescue => ex
-    Stripe::PaymentIntent.update(pi.id, { metadata: { email_error: "#{ex.message}" } })
-  end
-end
+MailUncapturedDonations.perform_now