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

Merge pull request #2319 from internetee/2090-legacy-migration-jobs

Browse source 
Remove legacy migration jobs
This commit is contained in:
Timo Võhmar 2022-04-05 15:18:49 +03:00 • committed by GitHub
commit 5e65c10120
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 0 additions and 131 deletions
Download patch file Download diff file Expand all files Collapse all files

36
app/jobs/migrate_before_force_delete_statuses_job.rb
View file

@ -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

36
app/jobs/migrate_statuses_to_domain_history_job.rb
View file

@ -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

10
lib/tasks/migrate_domain_statuses.rake
View file

@ -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

27
test/jobs/migrate_before_force_delete_statuses_job_test.rb
View file

@ -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

22
test/jobs/migrate_statuses_to_domain_history_job_test.rb
View file

@ -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