require "hash_keyword_args"
require "tmpdir"
require "pathname"
module Defog
class Proxy
attr_reader :proxy_root #
attr_reader :fog_wrapper # :nodoc:
# Opens a Fog
cloud storage connection to map to a corresponding proxy
# directory. Use via, e.g.,
#
# Defog::Proxy.new(:provider => :AWS, :aws_access_key_id => access_key, ...)
#
# The :provider
and its corresponding options must be
# specified as per Fog::Storage.new
. Currently, only
# :local
and :AWS
are supported. When using
# :AWS
, an additional option :bucket
must be
# specified; all files proxied by this instance must be in a single
# bucket.
#
# By default, each proxy's root directory is placed in a reasonable
# safe place, under Rails.root/tmp
if Rails is defined
# otherwise under Dir.tmpdir
. (More details: within that
# directory, the root directory is disambiguated by #provider and
# #location, so that multiple Defog::Proxy instances can be
# created without collision.)
#
# The upshot is that if you have no special constraints you don't need
# to worry about it. But if you do care, you can specify the option:
# :proxy_root => "/root/for/this/proxy/files"
#
def initialize(opts={})
opts = opts.keyword_args(:provider => :required, :proxy_root => :optional, :OTHERS => :optional)
@proxy_root = Pathname.new(opts.delete(:proxy_root)) if opts.proxy_root
@fog_wrapper = FogWrapper.connect(opts)
@proxy_root ||= case
when defined?(Rails) then Rails.root + "tmp"
else Pathname.new(Dir.tmpdir)
end + "defog" + provider.to_s + location
end
# Returns the provider for this proxy. I.e., :local
or
# :AWS
def provider
@fog_wrapper.provider
end
# Returns a 'location' handle to use in the default proxy root path,
# to disambiguate it from other proxies with the same provider. For
# :AWS it's the bucket name, for :Local it's derived from the local
# root path.
def location
@fog_wrapper.location
end
# Returns the underlying Fog::Storage object for the cloud connection
def fog_connection
@fog_wrapper.fog_connection
end
# Returns the Fog directory object for the root of the cloud files
def fog_directory
@fog_wrapper.fog_directory
end
# Proxy a remote cloud file. Returns a Defog::Handle object that
# represents the file.
#
# If a mode
is specified given opens a proxy file via
# Defog::Handle#open (passing it the mode and other options and
# optional block), returning instead the Defog::File object.
#
# Thus
# proxy.file("key", mode, options, &block)
# is shorthand for
# proxy.file("key").open(mode, options, &block)
#
def file(key, mode=nil, opts={}, &block)
handle = Handle.new(self, key)
case
when mode then handle.open(mode, opts, &block) if mode
when block then block.call(handle)
else handle
end
end
end
end