mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
Add the files model implementation.
This commit is contained in:
parent
64d188d732
commit
5218d9048c
1 changed files with 94 additions and 0 deletions
94
lib/fog/storage/models/hp/files.rb
Normal file
94
lib/fog/storage/models/hp/files.rb
Normal file
|
@ -0,0 +1,94 @@
|
|||
require 'fog/core/collection'
|
||||
require 'fog/storage/models/hp/file'
|
||||
|
||||
module Fog
|
||||
module HP
|
||||
class Storage
|
||||
|
||||
class Files < Fog::Collection
|
||||
|
||||
attribute :directory
|
||||
attribute :limit
|
||||
attribute :marker
|
||||
attribute :path
|
||||
attribute :prefix
|
||||
|
||||
model Fog::HP::Storage::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::HP::Storage::NotFound
|
||||
nil
|
||||
end
|
||||
|
||||
def get_url(key)
|
||||
requires :directory
|
||||
if self.directory.public_url
|
||||
"#{self.directory.public_url}/#{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::HP::Storage::NotFound
|
||||
nil
|
||||
end
|
||||
|
||||
def new(attributes = {})
|
||||
requires :directory
|
||||
super({ :directory => directory }.merge!(attributes))
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
end
|
||||
end
|
||||
end
|
Loading…
Reference in a new issue