1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70
|
module Fog
module Storage
class GoogleJSON
class Files < Fog::Collection
model Fog::Storage::GoogleJSON::File
extend Fog::Deprecation
deprecate :get_url, :get_https_url
attribute :common_prefixes, :aliases => "CommonPrefixes"
attribute :delimiter, :aliases => "Delimiter"
attribute :directory
attribute :page_token, :aliases => %w(pageToken page_token)
attribute :max_results, :aliases => ["MaxKeys", "max-keys"]
attribute :prefix, :aliases => "Prefix"
attribute :next_page_token
def all(options = {})
requires :directory
parent = service.list_objects(directory.key, attributes.merge(options))
attributes[:next_page_token] = parent.next_page_token
data = parent.to_h[:items] || []
load(data)
end
alias_method :each_file_this_page, :each
def each
if block_given?
subset = dup.all
subset.each_file_this_page { |f| yield f }
while subset.next_page_token
subset = subset.all(:page_token => subset.next_page_token)
subset.each_file_this_page { |f| yield f }
end
end
self
end
def get(key, options = {}, &block)
requires :directory
data = service.get_object(directory.key, key, **options, &block).to_h
new(data)
rescue ::Google::Apis::ClientError => e
raise e unless e.status_code == 404
nil
end
def get_https_url(key, expires, options = {})
requires :directory
service.get_object_https_url(directory.key, key, expires, **options)
end
def metadata(key, options = {})
requires :directory
data = service.get_object_metadata(directory.key, key, **options).to_h
new(data)
rescue ::Google::Apis::ClientError
nil
end
alias_method :head, :metadata
def new(opts = {})
requires :directory
super({ :directory => directory }.merge(opts))
end
end
end
end
end
|