Contents

class PgExport
  module Ftp
    class Adapter
      CHUNK_SIZE = (2**16).freeze

      def initialize(connection:)
        @connection = connection
        @host = connection.host
        ObjectSpace.define_finalizer(self, proc { connection.close })
      end

      def list(regex_string)
        ftp.list(regex_string).map { |item| item.split(' ').last }.sort.reverse
      end

      def delete(filename)
        ftp.delete(filename)
      end

      def persist(path, timestamped_name)
        ftp.putbinaryfile(path, timestamped_name, CHUNK_SIZE)
      end

      def get(path, timestamped_name)
        ftp.getbinaryfile(timestamped_name, path, CHUNK_SIZE)
      end

      def ftp
        connection.ftp
      end

      def to_s
        host
      end

      private

      attr_reader :connection, :host
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
pg_export-0.6.1	lib/pg_export/ftp/adapter.rb
pg_export-0.6.0	lib/pg_export/ftp/adapter.rb