From cee5f34bd8cd7ac46ec42ab690a7244c65afe579 Mon Sep 17 00:00:00 2001 From: Thiago Youssef Date: Wed, 23 Mar 2022 14:48:41 +0200 Subject: [PATCH] Remove legacy migration jobs --- ...igrate_before_force_delete_statuses_job.rb | 36 ------------------- .../migrate_statuses_to_domain_history_job.rb | 36 ------------------- lib/tasks/migrate_domain_statuses.rake | 10 ------ ...e_before_force_delete_statuses_job_test.rb | 27 -------------- ...ate_statuses_to_domain_history_job_test.rb | 22 ------------ 5 files changed, 131 deletions(-) delete mode 100644 app/jobs/migrate_before_force_delete_statuses_job.rb delete mode 100644 app/jobs/migrate_statuses_to_domain_history_job.rb delete mode 100644 lib/tasks/migrate_domain_statuses.rake delete mode 100644 test/jobs/migrate_before_force_delete_statuses_job_test.rb delete mode 100644 test/jobs/migrate_statuses_to_domain_history_job_test.rb diff --git a/app/jobs/migrate_before_force_delete_statuses_job.rb b/app/jobs/migrate_before_force_delete_statuses_job.rb deleted file mode 100644 index 7e6a1e1c0..000000000 --- a/app/jobs/migrate_before_force_delete_statuses_job.rb +++ /dev/null @@ -1,36 +0,0 @@ -class MigrateBeforeForceDeleteStatusesJob < ApplicationJob - def perform - logger.info 'Ran MigrateBeforeForceDeleteStatusesJob!' - - domains = Domain.where.not(statuses_before_force_delete: nil) - logger.info "Total domains are #{domains.count}" - - interate_domain_in_batches(domains) - end - - private - - def interate_domain_in_batches(domains) - count = 0 - - domains.find_in_batches do |domain_batches| - count += domain_batches.count - logger.info "Proccesing #{count} domains of #{domains.count}" - domain_batches.each do |domain| - migrate_data_to_statuses_history(domain) - end - end - end - - def migrate_data_to_statuses_history(domain) - domain.update(force_delete_domain_statuses_history: domain.statuses_before_force_delete) - rescue StandardError => e - logger.warn "#{domain.name} crashed!" - logger.warn e.to_s - raise e - end - - def logger - @logger ||= Logger.new(Rails.root.join('log/migrate_before_force_delete_statuses.log')) - end -end diff --git a/app/jobs/migrate_statuses_to_domain_history_job.rb b/app/jobs/migrate_statuses_to_domain_history_job.rb deleted file mode 100644 index f35c986b6..000000000 --- a/app/jobs/migrate_statuses_to_domain_history_job.rb +++ /dev/null @@ -1,36 +0,0 @@ -class MigrateStatusesToDomainHistoryJob < ApplicationJob - def perform - logger.info 'Ran MigrateStatusesToDomainHistoryJob!' - - domains = Domain.where(locked_by_registrant_at: nil) - logger.info "Total domains are #{domains.count}" - - interate_domain_in_batches(domains) - end - - private - - def interate_domain_in_batches(domains) - count = 0 - - domains.find_in_batches do |domain_batches| - count += domain_batches.count - logger.info "Proccesing #{count} domains of #{domains.count}" - domain_batches.each do |domain| - migrate_data_to_admin_store_field(domain) - end - end - end - - def migrate_data_to_admin_store_field(domain) - domain.update(admin_store_statuses_history: domain.statuses) - rescue StandardError => e - logger.warn "#{domain.name} crashed!" - logger.warn e.to_s - raise e - end - - def logger - @logger ||= Logger.new(Rails.root.join('log/migrate_statuses_to_domain_history.log')) - end -end diff --git a/lib/tasks/migrate_domain_statuses.rake b/lib/tasks/migrate_domain_statuses.rake deleted file mode 100644 index 8c68f9e70..000000000 --- a/lib/tasks/migrate_domain_statuses.rake +++ /dev/null @@ -1,10 +0,0 @@ -namespace :migrate_domain_statuses do - desc 'Starts collect invalid validation contacts' - task fd_domains: :environment do - MigrateBeforeForceDeleteStatusesJob.perform_later - end - - task admin_status_history: :environment do - MigrateStatusesToDomainHistoryJob.perform_later - end -end diff --git a/test/jobs/migrate_before_force_delete_statuses_job_test.rb b/test/jobs/migrate_before_force_delete_statuses_job_test.rb deleted file mode 100644 index 0288a686c..000000000 --- a/test/jobs/migrate_before_force_delete_statuses_job_test.rb +++ /dev/null @@ -1,27 +0,0 @@ -require 'test_helper' - -class MigrateBeforeForceDeleteStatusesJobTest < ActiveJob::TestCase - setup do - travel_to Time.zone.parse('2010-07-05') - @domain = domains(:shop) - end - - def test_migrate_data_before_force_delete - @domain.update(statuses: [DomainStatus::SERVER_UPDATE_PROHIBITED]) - @domain.reload - assert @domain.statuses.include? DomainStatus::SERVER_UPDATE_PROHIBITED - - @domain.schedule_force_delete(type: :soft) - @domain.reload - - assert @domain.force_delete_scheduled? - - perform_enqueued_jobs do - MigrateBeforeForceDeleteStatusesJob.perform_later - end - - @domain.reload - - assert @domain.force_delete_domain_statuses_history.include? DomainStatus::SERVER_UPDATE_PROHIBITED - end -end diff --git a/test/jobs/migrate_statuses_to_domain_history_job_test.rb b/test/jobs/migrate_statuses_to_domain_history_job_test.rb deleted file mode 100644 index dcacc327a..000000000 --- a/test/jobs/migrate_statuses_to_domain_history_job_test.rb +++ /dev/null @@ -1,22 +0,0 @@ -require 'test_helper' - -class MigrateBeforeForceDeleteStatusesJobTest < ActiveJob::TestCase - setup do - travel_to Time.zone.parse('2010-07-05') - @domain = domains(:shop) - end - - def test_migrate_statuses_to_domain_history_job - @domain.update(statuses: [DomainStatus::SERVER_UPDATE_PROHIBITED]) - @domain.reload - assert @domain.statuses.include? DomainStatus::SERVER_UPDATE_PROHIBITED - - perform_enqueued_jobs do - MigrateStatusesToDomainHistoryJob.perform_later - end - - @domain.reload - - assert @domain.admin_store_statuses_history.include? DomainStatus::SERVER_UPDATE_PROHIBITED - end -end