Sha256: d953d21a43f65588592b285d200356bb31ccfaf6f024d9d6678593d8849f80ea
Contents?: true
Size: 1.82 KB
Versions: 3
Compression:
Stored size: 1.82 KB
Contents
# frozen_string_literal: true
# auto_register: false
require 'dry/transaction'
require 'pg_export/import'
require 'pg_export/container'
class PgExport
module Transactions
class ImportDumpInteractively
include Dry::Transaction(container: PgExport::Container)
include Import[
'adapters.bash_adapter',
'repositories.gateway_dump_repository',
'repositories.gateway_dump_file_repository',
'ui_input'
]
step :open_connection, with: 'operations.open_connection'
step :fetch_dumps_from_ftp
step :select_dump
step :download_dump_from_ftp
step :close_connection
step :decrypt_dump, with: 'operations.decrypt_dump'
step :select_database
step :restore
private
def fetch_dumps_from_ftp(database_name:, gateway:)
dumps = gateway_dump_repository.all(database_name: database_name, gateway: gateway)
return Failure(message: 'No dumps') if dumps.none?
Success(gateway: gateway, dumps: dumps)
end
def select_dump(dumps:, gateway:)
dump = ui_input.select_dump(dumps)
Success(dump: dump, gateway: gateway)
end
def download_dump_from_ftp(dump:, gateway:)
dump.file = gateway_dump_file_repository.by_name(name: dump.name, gateway: gateway)
Success(dump: dump, gateway: gateway)
end
def close_connection(dump:, gateway:)
Thread.new { gateway.close }
Success(dump: dump)
end
def select_database(dump:)
name = ui_input.enter_database_name(dump.database)
Success(dump: dump, database: name)
end
def restore(dump:, database:)
bash_adapter.pg_restore(dump.file, database)
Success({})
rescue bash_adapter.class::PgRestoreError => e
Failure(message: e.to_s)
end
end
end
end
Version data entries
3 entries across 3 versions & 1 rubygems