can_read?(user)
click to toggle source
def can_read?(user)
return false if @read_acl.nil?
list_users_with_read.include?(user)
end
can_read_write?(user)
click to toggle source
def can_read_write?(user)
can_read?(user) && can_write?(user)
end
can_write?(user)
click to toggle source
def can_write?(user)
return false if @write_acl.nil?
list_users_with_write.include?(user)
end
cdn_enable=(new_cdn_enable)
click to toggle source
def cdn_enable=(new_cdn_enable)
@cdn_enable ||= false
if (!service.cdn.nil? && service.cdn.enabled?)
@cdn_enable = new_cdn_enable
else
@cdn_enable = false
end
end
cdn_enabled?()
click to toggle source
def cdn_enabled?
if (!service.cdn.nil? && service.cdn.enabled?)
begin response = service.cdn.head_container(key)
cdn_header = response.headers.fetch('X-Cdn-Enabled', nil)
if (!cdn_header.nil? && cdn_header == 'True')
@cdn_enable = true
else
@cdn_enable = false
end
rescue Fog::CDN::HP::NotFound, Excon::Errors::SocketError
@cdn_enable = false
end
else
@cdn_enable = false
end
end
cdn_public_ssl_url()
click to toggle source
def cdn_public_ssl_url
requires :key
@cdn_public_ssl_url ||= begin
begin response = service.cdn.head_container(key)
if response.headers['X-Cdn-Enabled'] == 'True'
response.headers.fetch('X-Cdn-Ssl-Uri', nil)
end
rescue Fog::CDN::HP::NotFound
nil
end
end
end
cdn_public_url()
click to toggle source
def cdn_public_url
requires :key
@cdn_public_url ||= begin
begin response = service.cdn.head_container(key)
if response.headers['X-Cdn-Enabled'] == 'True'
response.headers.fetch('X-Cdn-Uri', nil)
end
rescue Fog::CDN::HP::NotFound
nil
end
end
end
destroy()
click to toggle source
def destroy
requires :key
service.delete_container(key)
if cdn_enabled?
begin
service.cdn.delete_container(key)
rescue Fog::CDN::HP::NotFound
end
end
true
rescue Excon::Errors::NotFound, Fog::Storage::HP::NotFound
false
end
files()
click to toggle source
def files
@files ||= begin
Fog::Storage::HP::Files.new(
:directory => self,
:service => service
)
end
end
grant(perm, users=nil)
click to toggle source
def grant(perm, users=nil)
if users.is_a?(String)
user_list = users.split(',')
else
user_list = users
end
r_acl, w_acl = service.perm_to_acl(perm, user_list)
unless r_acl.nil? || r_acl.empty?
@read_acl = [] if @read_acl.nil?
@read_acl = @read_acl + r_acl
@read_acl.uniq!
end
unless w_acl.nil? || w_acl.empty?
@write_acl = [] if @write_acl.nil?
@write_acl = @write_acl + w_acl
@write_acl.uniq!
end
true
end
list_users_with_read()
click to toggle source
def list_users_with_read
users = []
users = @read_acl.map {|acl| acl.split(':')[1]} unless @read_acl.nil?
return users
end
list_users_with_write()
click to toggle source
def list_users_with_write
users = []
users = @write_acl.map {|acl| acl.split(':')[1]} unless @write_acl.nil?
return users
end
public=(new_public)
click to toggle source
def public=(new_public)
if new_public
self.grant("pr")
else
self.revoke("pr")
end
@public = new_public
end
public?()
click to toggle source
def public?
@read_acl = [] if @read_acl.nil?
if @read_acl.include?(".r:*")
true
else
false
end
end
public_url()
click to toggle source
def public_url
requires :key
@public_url ||= begin
begin response = service.head_container(key)
url = service.public_url(key)
rescue Fog::Storage::HP::NotFound => err
nil
end
end
end
read_acl()
click to toggle source
def read_acl
@read_acl || []
end
revoke(perm, users=nil)
click to toggle source
def revoke(perm, users=nil)
if users.is_a?(String)
user_list = users.split(',')
else
user_list = users
end
r_acl, w_acl = service.perm_to_acl(perm, user_list)
unless r_acl.nil? || r_acl.empty?
@read_acl = [] if @read_acl.nil?
@read_acl = @read_acl - r_acl
@read_acl.uniq!
end
unless w_acl.nil? || w_acl.empty?
@write_acl = [] if @write_acl.nil?
@write_acl = @write_acl - w_acl
@write_acl.uniq!
end
true
end
save(new_options = {})
click to toggle source
def save(new_options = {})
requires :key
options = {}
meta_hash = {}
metadata.each { |meta| meta_hash.store(meta.key, meta.value) }
if meta_hash
options.merge!(meta_hash)
end
options.merge!(service.perm_acl_to_header(@read_acl, @write_acl))
options.merge!({'X-Container-Sync-To' => self.sync_to}) unless self.sync_to.nil?
options.merge!({'X-Container-Sync-Key' => self.sync_key}) unless self.sync_key.nil?
options.merge!({'X-Container-Meta-Web-Index' => self.web_index}) unless self.web_index.nil?
options.merge!({'X-Container-Meta-Web-Listings' => self.web_listings})
options.merge!({'X-Container-Meta-Web-Listings-Css' => self.web_listings_css}) unless self.web_listings_css.nil?
options.merge!({'X-Container-Meta-Web-Error' => self.web_error}) unless self.web_error.nil?
options.merge!(new_options)
service.put_container(key, options)
if (!service.cdn.nil? && service.cdn.enabled?)
if @cdn_enable
begin response = service.cdn.head_container(key)
if response.headers['X-Cdn-Enabled'] == 'False'
service.cdn.post_container(key, {'X-Cdn-Enabled' => 'True'})
end
rescue Fog::CDN::HP::NotFound
service.cdn.put_container(key)
rescue Excon::Errors::SocketError
end
else
begin response = service.cdn.head_container(key)
if response.headers['X-Cdn-Enabled'] == 'True'
service.cdn.post_container(key, {'X-Cdn-Enabled' => 'False'})
end
rescue Fog::CDN::HP::NotFound
rescue Excon::Errors::SocketError
end
end
end
true
end
sync(target_dir, secret)
click to toggle source
def sync(target_dir, secret)
requires :key
return false if target_dir.key == key
begin service.head_container(key)
if !target_dir.nil? && target_dir.is_a?(Fog::Storage::HP::Directory) && target_dir.respond_to?(:public_url) && !target_dir.public_url.nil?
self.sync_to = target_dir.public_url
self.sync_key = secret
target_dir.sync_key = secret
target_dir.save
true
else
false
end
rescue Fog::Storage::HP::NotFound
false
end
end
write_acl()
click to toggle source
def write_acl
@write_acl || []
end