RUBYCRITIC
RUBYCRITIC
class ArchiveSignaturesJob < ApplicationJob - ArchiveSignaturesJob has no descriptive comment
queue_as :low_priority
def perform(petition, archived_petition, limit: 1000) - ArchiveSignaturesJob#perform has a flog score of 105
- ArchiveSignaturesJob#perform has approx 39 statements
terminating = false
worker = trap("TERM") do
terminating = true
worker.call
end
Appsignal.without_instrumentation do
if petition.signatures.unarchived.exists? -
-
-
signatures = petition.signatures.unarchived.batch(limit: limit) -
-
signatures.each do |signature|
signature.with_lock do -
unless signature.archived_at? -
archived_signature = Archived::Signature.new do |s| - ArchiveSignaturesJob#perform contains iterators nested 2 deep
- ArchiveSignaturesJob#perform has the variable name 's'
s.petition_id = signature.petition_id -
s.uuid = signature.uuid -
s.state = signature.state -
s.number = signature.number -
s.name = signature.name -
s.email = signature.email -
s.postcode = signature.postcode -
s.location_code = signature.location_code -
s.constituency_id = signature.constituency_id -
s.ip_address = signature.ip_address -
s.perishable_token = signature.perishable_token -
s.unsubscribe_token = signature.unsubscribe_token -
s.notify_by_email = signature.notify_by_email -
s.validated_at = signature.validated_at -
s.invalidation_id = signature.invalidation_id -
s.invalidated_at = signature.invalidated_at -
s.government_response_email_at = signature.government_response_email_at -
s.debate_scheduled_email_at = signature.debate_scheduled_email_at -
s.debate_outcome_email_at = signature.debate_outcome_email_at -
s.petition_email_at = signature.petition_email_at -
s.creator = signature.creator? -
s.sponsor = signature.sponsor? -
s.created_at = signature.created_at -
s.updated_at = signature.updated_at -
end
archived_signature.save!(validate: false)
signature.update_column(:archived_at, Time.current) -
-
end
end
if terminating
reschedule_job(petition, archived_petition, limit: limit)
return true
end
end
end
end
if petition.signatures.unarchived.exists? -
-
-
self.class.perform_later(petition, archived_petition, limit: limit)
else
petition.update_column(:archived_at, Time.current) -
end
ensure
trap "TERM", worker
end
private
def reschedule_job(petition, archived_petition, limit: 1000, wait_until: 5.minutes.from_now) - ArchiveSignaturesJob#reschedule_job has 4 parameters
- ArchiveSignaturesJob#reschedule_job has unused parameter 'limit'
self.class.set(wait_until: wait_until).perform_later(petition, archived_petition)
end
end