Sha256: 1e5375d93d826c113c83698af4554e88284be4035583d90fd9b30d408d98e4f5
Contents?: true
Size: 1.19 KB
Versions: 1
Compression:
Stored size: 1.19 KB
Contents
# frozen_string_literal: true require 'open3' require 'pg_export/import' require 'pg_export/lib/pg_export/entities/dump' require 'pg_export/lib/pg_export/value_objects/dump_file' class PgExport module Repositories class GatewayDumpRepository def all(database_name:, gateway:) gateway.list([database_name, '*'].compact.join('_')).map do |item| begin dump(item[:name], database_name, item[:size]) rescue Dry::Types::ConstraintError nil end end.compact end def by_database_name(database_name:, gateway:, offset:) gateway.list(database_name + '_*').drop(offset).map do |item| begin dump(item[:name], database_name, item[:size]) rescue Dry::Types::ConstraintError nil end end.compact end private FilePlaceholder = Struct.new(:size) private_constant :FilePlaceholder def dump(name, database_name, size) Entities::Dump.new( name: name, database: database_name, file: ValueObjects::DumpFile.new(FilePlaceholder.new(size.to_i)), type: :encrypted ) end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
pg_export-1.0.0.rc1 | lib/pg_export/lib/pg_export/repositories/gateway_dump_repository.rb |