Contents

# frozen_string_literal: true

# auto_register: false

require 'dry/transaction'

require 'pg_export/import'
require 'pg_export/container'
require 'pg_export/lib/pg_export/value_objects/dump_file'

class PgExport
  module Transactions
    class ExportDump
      include Dry::Transaction(container: PgExport::Container)
      include Import['factories.dump_factory', 'adapters.bash_adapter']

      step :prepare_params
      step :build_dump
      step :encrypt_dump, with: 'operations.encrypt_dump'
      step :open_connection, with: 'operations.open_connection'
      step :upload_dump_to_ftp
      step :remove_old_dumps_from_ftp, with: 'operations.remove_old_dumps_from_ftp'
      step :close_connection

      private

      def prepare_params(database_name:)
        database_name = database_name.to_s

        return Failure(message: 'Invalid database name') if database_name.empty?

        Success(database_name: database_name)
      end

      def build_dump(database_name:)
        dump = dump_factory.plain(
          database: database_name,
          file: bash_adapter.pg_dump(ValueObjects::DumpFile.new, database_name)
        )
        Success(dump: dump)
      rescue bash_adapter.class::PgDumpError => e
        Failure(message: 'Unable to dump database: ' + e.to_s)
      end

      def upload_dump_to_ftp(dump:, gateway:)
        gateway.persist(dump.file, dump.name)
        Success(dump: dump, gateway: gateway)
      end

      def close_connection(removed_dumps:, gateway:)
        gateway.close
        Success(gateway: gateway)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
pg_export-1.0.0.rc3	lib/pg_export/lib/pg_export/transactions/export_dump.rb
pg_export-1.0.0.rc2	lib/pg_export/lib/pg_export/transactions/export_dump.rb
pg_export-1.0.0.rc1	lib/pg_export/lib/pg_export/transactions/export_dump.rb