1
0
Fork 0
mirror of https://github.com/fog/fog.git synced 2022-11-09 13:51:43 -05:00
fog--fog/lib/fog/hp/models/storage/files.rb

103 lines
2.6 KiB
Ruby

require 'fog/core/collection'
require 'fog/hp/models/storage/file'
module Fog
module Storage
class HP
class Files < Fog::Collection
attribute :directory
attribute :limit
attribute :marker
attribute :path
attribute :prefix
model Fog::Storage::HP::File
def all(options = {})
requires :directory
options = {
'limit' => limit,
'marker' => marker,
'path' => path,
'prefix' => prefix
}.merge!(options)
merge_attributes(options)
parent = directory.collection.get(
directory.key,
options
)
if parent
load(parent.files.map {|file| file.attributes})
else
nil
end
end
alias :each_file_this_page :each
def each
if !block_given?
self
else
subset = dup.all
subset.each_file_this_page {|f| yield f}
until subset.empty? || subset.length == (subset.limit || 10000)
subset = subset.all(:marker => subset.last.key)
subset.each_file_this_page {|f| yield f}
end
self
end
end
def get(key, &block)
requires :directory
data = connection.get_object(directory.key, key, &block)
file_data = data.headers.merge({
:body => data.body,
:key => key
})
new(file_data)
rescue Fog::Storage::HP::NotFound
nil
end
def get_url(key)
requires :directory
if self.directory.public_url
# escape the key to cover for special char. in object names
"#{self.directory.public_url}/#{Fog::HP.escape(key)}"
end
end
def get_cdn_url(key)
requires :directory
if self.directory.cdn_public_url
# escape the key to cover for special char. in object names
"#{self.directory.cdn_public_url}/#{Fog::HP.escape(key)}"
end
end
def head(key, options = {})
requires :directory
data = connection.head_object(directory.key, key)
file_data = data.headers.merge({
:key => key
})
new(file_data)
rescue Fog::Storage::HP::NotFound
nil
end
def new(attributes = {})
requires :directory
super({ :directory => directory }.merge!(attributes))
end
end
end
end
end