Sha256: d367a9f9ade35a6bb86683afd8ec173ba78b4c77ef3675c45ec9f0f7fbdaf15c
Contents?: true
Size: 2 KB
Versions: 8
Compression:
Stored size: 2 KB
Contents
require 'dandelion/utils'
module Dandelion
module Adapter
class FTP < Adapter::Base
include ::Dandelion::Utils
adapter 'ftp'
def initialize(config)
require 'net/ftp'
@config = config
@config.defaults(port: Net::FTP::FTP_PORT)
@config[:passive] = to_b(@config[:passive])
@ftp = ftp_client
end
def read(file)
begin
@ftp.getbinaryfile(file, nil)
rescue Net::FTPPermError => e
nil
end
end
def write(file, data)
temp(file, data) do |temp|
begin
@ftp.putbinaryfile(temp, file)
rescue Net::FTPPermError => e
mkdir_p(File.dirname(file))
@ftp.putbinaryfile(temp, file)
end
end
end
def delete(file)
begin
@ftp.delete(file)
cleanup(File.dirname(file))
rescue Net::FTPPermError => e
end
end
def to_s
"ftp://#{@config['username']}@#{@config['host']}/#{@config['path']}"
end
private
def ftp_client
ftp = Net::FTP.new
ftp.connect(@config['host'], @config['port'])
ftp.login(@config['username'], @config['password'])
ftp.passive = @config['passive']
ftp.chdir(@config['path']) if @config['path']
ftp
end
def cleanup(dir)
unless dir == File.dirname(dir)
if empty?(dir)
@ftp.rmdir(dir)
cleanup(File.dirname(dir))
end
end
end
def empty?(dir)
return @ftp.nlst(dir).empty?
end
def mkdir_p(dir)
unless dir == File.dirname(dir)
begin
@ftp.mkdir(dir)
rescue Net::FTPPermError => e
mkdir_p(File.dirname(dir))
@ftp.mkdir(dir)
end
end
end
def to_b(value)
return [true, 'true', 1, '1', 'T', 't'].include?(value.class == String ? value.downcase : value)
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems