class PgExport
  class FtpAdapter
    extend Forwardable

    CHUNK_SIZE = (2**16).freeze

    def_delegators :connection, :ftp, :host

    def initialize(connection)
      @connection = connection
      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 upload_file(path, name)
      ftp.putbinaryfile(path.to_s, name, CHUNK_SIZE)
    end

    def download_file(path, name)
      ftp.getbinaryfile(name, path.to_s, CHUNK_SIZE)
    end

    def to_s
      host
    end

    private

    attr_reader :connection
  end
end