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

Do not print log to STDOUT while running testsuite

Browse source
This commit is contained in:
Karl Erik Õunapuu 2020-05-22 16:19:36 +03:00
parent 13e31af133
commit 01c20edaf8
2 changed files with 16 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

22
app/jobs/dispute_status_update_job.rb
View file

@ -1,12 +1,14 @@
class DisputeStatusUpdateJob < Que::Job class DisputeStatusUpdateJob < Que::Job
def run def run(logger: Logger.new(STDOUT))
@logger = logger
@backlog = { 'activated': 0, 'closed': 0, 'activate_fail': [], 'close_fail': [] } @backlog = { 'activated': 0, 'closed': 0, 'activate_fail': [], 'close_fail': [] }
.with_indifferent_access .with_indifferent_access
close_disputes close_disputes
activate_disputes activate_disputes
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 +16,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
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 +24,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
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,28 +40,24 @@ 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
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
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?
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?
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

11
test/jobs/dispute_status_update_job_test.rb
View file

@ -3,17 +3,18 @@ require "test_helper"
class DisputeStatusUpdateJobTest < ActiveSupport::TestCase class DisputeStatusUpdateJobTest < ActiveSupport::TestCase
setup do setup do
travel_to Time.zone.parse('2010-10-05') travel_to Time.zone.parse('2010-10-05')
@logger = Rails.logger
end end
def test_nothing_is_raised def test_nothing_is_raised
assert_nothing_raised do assert_nothing_raised do
DisputeStatusUpdateJob.run DisputeStatusUpdateJob.run(logger: @logger)
end end
end end
def test_whois_data_added_when_dispute_activated def test_whois_data_added_when_dispute_activated
dispute = disputes(:future) dispute = disputes(:future)
DisputeStatusUpdateJob.run DisputeStatusUpdateJob.run(logger: @logger)
whois_record = Whois::Record.find_by(name: dispute.domain_name) whois_record = Whois::Record.find_by(name: dispute.domain_name)
assert whois_record.present? assert whois_record.present?
@ -24,7 +25,7 @@ class DisputeStatusUpdateJobTest < ActiveSupport::TestCase
dispute = disputes(:active) dispute = disputes(:active)
dispute.update!(starts_at: Time.zone.today - 3.years - 1.day) dispute.update!(starts_at: Time.zone.today - 3.years - 1.day)
DisputeStatusUpdateJob.run DisputeStatusUpdateJob.run(logger: @logger)
dispute.reload dispute.reload
assert dispute.closed assert dispute.closed
@ -36,7 +37,7 @@ class DisputeStatusUpdateJobTest < ActiveSupport::TestCase
def test_registered_domain_whois_data_is_added def test_registered_domain_whois_data_is_added
Dispute.create(domain_name: 'shop.test', starts_at: '2010-07-05') Dispute.create(domain_name: 'shop.test', starts_at: '2010-07-05')
travel_to Time.zone.parse('2010-07-05') travel_to Time.zone.parse('2010-07-05')
DisputeStatusUpdateJob.run DisputeStatusUpdateJob.run(logger: @logger)
whois_record = Whois::Record.find_by(name: 'shop.test') whois_record = Whois::Record.find_by(name: 'shop.test')
assert_includes whois_record.json['status'], 'disputed' assert_includes whois_record.json['status'], 'disputed'
@ -61,7 +62,7 @@ class DisputeStatusUpdateJobTest < ActiveSupport::TestCase
# Dispute status is removed night time day after it's ended # Dispute status is removed night time day after it's ended
travel_to Time.zone.parse('2010-07-05') + 3.years + 1.day travel_to Time.zone.parse('2010-07-05') + 3.years + 1.day
DisputeStatusUpdateJob.run DisputeStatusUpdateJob.run(logger: @logger)
whois_record.reload whois_record.reload
assert_not whois_record.json['status'].include? 'disputed' assert_not whois_record.json['status'].include? 'disputed'