mirror of
https://github.com/internetee/registry.git
synced 2025-07-31 06:56:23 +02:00
Remove legacy migration jobs
This commit is contained in:
parent
8babae9a0e
commit
cee5f34bd8
5 changed files with 0 additions and 131 deletions
|
@ -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
|
|
|
@ -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
|
|
|
@ -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
|
|
|
@ -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
|
|
|
@ -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
|
|
Loading…
Add table
Add a link
Reference in a new issue