zydronium/internetee-registry
1
0
Fork 0
mirror of https://github.com/internetee/registry.git synced 2025-06-11 07:04:47 +02:00
Code Issues Projects Releases Packages Wiki Activity

Improve logging for Dispute status update jbo

Browse source
This commit is contained in:
Karl Erik Õunapuu 2020-05-18 16:04:00 +03:00
parent c682155bf6
commit 36f5ec734e
1 changed files with 11 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

18
app/jobs/dispute_status_update_job.rb
View file

@ -6,7 +6,7 @@ class DisputeStatusUpdateJob < Que::Job
close_disputes close_disputes
activate_disputes activate_disputes
Rails.logger.info "DisputeStatusUpdateJob - All done. Closed #{@backlog['closed']} and " \ logger.info "DisputeStatusUpdateJob - All done. Closed #{@backlog['closed']} and " \
"activated #{@backlog['activated']} disputes." "activated #{@backlog['activated']} disputes."
show_failed_disputes unless @backlog['activate_fail'].empty? && @backlog['close_fail'].empty? show_failed_disputes unless @backlog['activate_fail'].empty? && @backlog['close_fail'].empty?
@ -14,7 +14,7 @@ class DisputeStatusUpdateJob < Que::Job
def close_disputes def close_disputes
disputes = Dispute.where(closed: nil).where('expires_at < ?', Time.zone.today).all disputes = Dispute.where(closed: nil).where('expires_at < ?', Time.zone.today).all
Rails.logger.info "DisputeStatusUpdateJob - Found #{disputes.count} closable disputes" logger.info "DisputeStatusUpdateJob - Found #{disputes.count} closable disputes"
disputes.each do |dispute| disputes.each do |dispute|
process_dispute(dispute, closing: true) process_dispute(dispute, closing: true)
end end
@ -22,7 +22,7 @@ class DisputeStatusUpdateJob < Que::Job
def activate_disputes def activate_disputes
disputes = Dispute.where(closed: nil, starts_at: Time.zone.today).all disputes = Dispute.where(closed: nil, starts_at: Time.zone.today).all
Rails.logger.info "DisputeStatusUpdateJob - Found #{disputes.count} activatable disputes" logger.info "DisputeStatusUpdateJob - Found #{disputes.count} activatable disputes"
disputes.each do |dispute| disputes.each do |dispute|
process_dispute(dispute, closing: false) process_dispute(dispute, closing: false)
@ -38,24 +38,28 @@ class DisputeStatusUpdateJob < Que::Job
def create_backlog_entry(dispute:, intent:, successful:) def create_backlog_entry(dispute:, intent:, successful:)
if successful if successful
@backlog["#{intent}d"] += 1 @backlog["#{intent}d"] += 1
Rails.logger.info "DisputeStatusUpdateJob - #{intent}d dispute " \ logger.info "DisputeStatusUpdateJob - #{intent}d dispute " \
" for '#{dispute.domain_name}'" " for '#{dispute.domain_name}'"
else else
@backlog["#{intent}_fail"] << dispute.id @backlog["#{intent}_fail"] << dispute.id
Rails.logger.info 'DisputeStatusUpdateJob - Failed to' \ logger.info 'DisputeStatusUpdateJob - Failed to' \
"#{intent} dispute for '#{dispute.domain_name}'" "#{intent} dispute for '#{dispute.domain_name}'"
end end
end end
def show_failed_disputes def show_failed_disputes
if @backlog['close_fail'].any? if @backlog['close_fail'].any?
Rails.logger.info('DisputeStatusUpdateJob - Failed to close disputes with Ids:' \ logger.info('DisputeStatusUpdateJob - Failed to close disputes with Ids:' \
"#{@backlog['close_fail']}") "#{@backlog['close_fail']}")
end end
return unless @backlog['activate_fail'].any? return unless @backlog['activate_fail'].any?
Rails.logger.info('DisputeStatusUpdateJob - Failed to activate disputes with Ids:' \ logger.info('DisputeStatusUpdateJob - Failed to activate disputes with Ids:' \
"#{@backlog['activate_fail']}") "#{@backlog['activate_fail']}")
end end
def logger
Logger.new(STDOUT)
end
end end