houdini/lib/scheduled_jobs.rb

# frozen_string_literal: true

# License: AGPL-3.0-or-later WITH WTO-AP-3.0-or-later
# Full license explanation at https://github.com/houdiniproject/houdini/blob/master/LICENSE
require 'qx'
module ScheduledJobs
  # Each of these functions should return an Enumerator
  # Each value in the enumerator should be a lambda
  # That way the heroku_scheduled_job task can iterate over each lambda
  # and wrap each call in begin/rescue/end blocks
  # and it can continue to execute all the parts of the job without bailing early, even if one part of the job fails
  # And it will aggregate success/failure messages from all the lambdas in the enum

  # Clear out all junk tables. Warning, some of this is dangerous yo!
  def self.delete_junk_data
    # Delete all custom fields with emptly/nil vals
    del_cfjs_noval = Qx.delete_from(:custom_field_joins)
                       .where("value IS NULL OR value=''")
    # Delete orphaned custom field joins (those should also all have supporters)
    del_cfjs_orphaned = Qx.delete_from(:custom_field_joins).where('id IN ($ids)',
                                                                  ids: Qx.select('custom_field_joins.id')
                                                                    .from(:custom_field_joins)
                                                                    .left_join('supporters', 'custom_field_joins.supporter_id=supporters.id')
                                                                    .where('supporters.id IS NULL'))
    # Delete orphaned tag joins
    del_tags_orphaned = Qx.delete_from(:tag_joins).where('id IN ($ids)',
                                                         ids: Qx.select('tag_joins.id')
                                                            .from(:tag_joins)
                                                            .left_join(:supporters, 'tag_joins.supporter_id=supporters.id')
                                                            .where('supporters.id IS NULL'))

    Enumerator.new do |yielder|
      yielder << lambda do
        del_cfjs_noval.execute
        'Successfully cleaned up custom field joins with no values'
      end
      yielder << lambda do
        del_cfjs_orphaned.execute
        'Successfully cleaned up custom field joins that have been orphaned from supporters'
      end
      yielder << lambda do
        del_tags_orphaned.execute
        'Successfully cleaned up tags that have been orphaned from supporters'
      end
    end
  end

  def self.pay_recurring_donations
    Enumerator.new do |yielder|
      yielder << lambda do
        ids = PayRecurringDonation.pay_all_due_with_stripe
        "Queued jobs to pay #{ids.count} total recurring donations\n Recurring Donation Ids to run are: \n#{ids.join('\n')}"
      end
    end
  end

  def self.update_verification_statuses
    Enumerator.new do |yielder|
      Nonprofit.where(verification_status: 'pending').each do |np|
        yielder << lambda do
          acct = Stripe::Account.retrieve(np.stripe_account_id)
          verified = acct.transfers_enabled && acct.verification.fields_needed.count == 0
          np.verification_status = verified ? 'verified' : np.verification_status
          VerificationFailedJob.perform_later(np) if np.verification_status != 'verified'
          VerificationCompletedJob.perform_later(np) if np.verification_status == 'verified'
          np.save
          "Status updated for NP #{np.id} as '#{np.verification_status}'"
        end
      end
    end
  end

  def self.update_np_balances
    Enumerator.new do |yielder|
      nps = Nonprofit.where('id IN (?)', Charge.pending.uniq.pluck(:nonprofit_id))
      nps.each do |np|
        yielder << lambda do
          UpdateNonprofit.mark_available_charges(np.id)
          "Updated charge statuses for NP #{np.id}"
        end
      end
    end
  end

  def self.update_pending_payouts
    Enumerator.new do |yielder|
      Payout.pending.includes(:nonprofit).each do |p|
        yielder << lambda do
          err = false
          p.status = Stripe::Transfer.retrieve(p.stripe_transfer_id,
                                               stripe_account: p.nonprofit.stripe_account_id).status
          p.save
          "Updated status for NP #{p.nonprofit.id}, payout # #{p.id}"
        end
      end
    end
  end

  def self.delete_expired_source_tokens
    Enumerator.new do |yielder|
      yielder << lambda do
        tokens_deleted = SourceToken.where('expiration > ?', DateTime.now - 1.day).delete_all
        "Deleted #{tokens_deleted} source tokens"
      end
    end
  end
end