Class: Fog::AWS::Storage::File
- Inherits:
-
Model
- Object
- Model
- Fog::AWS::Storage::File
- Defined in:
- lib/fog/aws/models/storage/file.rb
Defined Under Namespace
Classes: PartList, UploadPartData
Constant Summary collapse
- MIN_MULTIPART_CHUNK_SIZE =
5242880
- MAX_SINGLE_PUT_SIZE =
5368709120
- MULTIPART_COPY_THRESHOLD =
15728640
Instance Attribute Summary collapse
-
#body ⇒ File
Get file’s body if exists, else ”.
- #multipart_chunk_size ⇒ Object
Instance Method Summary collapse
- #acl ⇒ Object
-
#acl=(new_acl) ⇒ String
Set file’s access control list (ACL).
- #concurrency ⇒ Object
- #concurrency=(concurrency) ⇒ Object
-
#copy(target_directory_key, target_file_key, options = {}) ⇒ String
Copy object from one bucket to other bucket.
-
#destroy(options = {}) ⇒ Boolean
Destroy file via http DELETE.
-
#directory ⇒ Fog::AWS::Storage::Directory
Get the file instance’s directory.
- #metadata ⇒ Object
- #metadata=(new_metadata) ⇒ Object
- #owner=(new_owner) ⇒ Object
-
#public=(new_public) ⇒ String
Set Access-Control-List permissions.
- #public? ⇒ Boolean
-
#public_url ⇒ String
Get publicly accessible url via http GET.
-
#save(options = {}) ⇒ Boolean
Save file with body as contents to directory.key with name key via http PUT.
-
#url(expires, options = {}) ⇒ String
Get a url for file.
-
#versions ⇒ Fog::AWS::Storage::Version
File version if exists or creates new version.
Instance Attribute Details
#body ⇒ File
Get file’s body if exists, else ”.
106 107 108 109 110 111 112 113 114 115 116 |
# File 'lib/fog/aws/models/storage/file.rb', line 106 def body return attributes[:body] if attributes[:body] return '' unless last_modified file = collection.get(identity) if file attributes[:body] = file.body else attributes[:body] = '' end end |
#multipart_chunk_size ⇒ Object
Chunk size to use for multipart uploads. Use small chunk sizes to minimize memory. E.g. 5242880 = 5mb
65 66 67 |
# File 'lib/fog/aws/models/storage/file.rb', line 65 def multipart_chunk_size @multipart_chunk_size end |
Instance Method Details
#acl ⇒ Object
82 83 84 85 |
# File 'lib/fog/aws/models/storage/file.rb', line 82 def acl requires :directory, :key service.get_object_acl(directory.key, key).body['AccessControlList'] end |
#acl=(new_acl) ⇒ String
Set file’s access control list (ACL).
valid acls: private, public-read, public-read-write, authenticated-read, bucket-owner-read, bucket-owner-full-control
94 95 96 97 98 99 100 |
# File 'lib/fog/aws/models/storage/file.rb', line 94 def acl=(new_acl) valid_acls = ['private', 'public-read', 'public-read-write', 'authenticated-read', 'bucket-owner-read', 'bucket-owner-full-control'] unless valid_acls.include?(new_acl) raise ArgumentError.new("acl must be one of [#{valid_acls.join(', ')}]") end @acl = new_acl end |
#concurrency ⇒ Object
78 79 80 |
# File 'lib/fog/aws/models/storage/file.rb', line 78 def concurrency @concurrency || 1 end |
#concurrency=(concurrency) ⇒ Object
Number of threads used to copy files.
72 73 74 75 76 |
# File 'lib/fog/aws/models/storage/file.rb', line 72 def concurrency=(concurrency) raise ArgumentError.new('minimum concurrency is 1') if concurrency.to_i < 1 @concurrency = concurrency.to_i end |
#copy(target_directory_key, target_file_key, options = {}) ⇒ String
Copy object from one bucket to other bucket.
required attributes: directory, key
144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 |
# File 'lib/fog/aws/models/storage/file.rb', line 144 def copy(target_directory_key, target_file_key, = {}) requires :directory, :key # With a single PUT operation you can upload objects up to 5 GB in size. Automatically set MP for larger objects. self.multipart_chunk_size = MIN_MULTIPART_CHUNK_SIZE * 2 if !multipart_chunk_size && self.content_length.to_i > MAX_SINGLE_PUT_SIZE if multipart_chunk_size && self.content_length.to_i >= multipart_chunk_size = .select { |key, _| ALLOWED_UPLOAD_PART_OPTIONS.include?(key.to_sym) } = .merge({ 'x-amz-copy-source' => "#{directory.key}/#{key}" }) multipart_copy(, , target_directory_key, target_file_key) else service.copy_object(directory.key, key, target_directory_key, target_file_key, ) end target_directory = service.directories.new(:key => target_directory_key) target_directory.files.head(target_file_key) end |
#destroy(options = {}) ⇒ Boolean
Destroy file via http DELETE.
required attributes: directory, key
170 171 172 173 174 175 |
# File 'lib/fog/aws/models/storage/file.rb', line 170 def destroy( = {}) requires :directory, :key attributes[:body] = nil if ['versionId'] == version service.delete_object(directory.key, key, ) true end |
#directory ⇒ Fog::AWS::Storage::Directory
Get the file instance’s directory.
131 132 133 |
# File 'lib/fog/aws/models/storage/file.rb', line 131 def directory @directory end |
#metadata ⇒ Object
178 179 180 |
# File 'lib/fog/aws/models/storage/file.rb', line 178 def attributes.reject {|key, value| !(key.to_s =~ /^x-amz-/)} end |
#metadata=(new_metadata) ⇒ Object
183 184 185 |
# File 'lib/fog/aws/models/storage/file.rb', line 183 def () merge_attributes() end |
#owner=(new_owner) ⇒ Object
188 189 190 191 192 193 194 195 |
# File 'lib/fog/aws/models/storage/file.rb', line 188 def owner=(new_owner) if new_owner attributes[:owner] = { :display_name => new_owner['DisplayName'] || new_owner[:display_name], :id => new_owner['ID'] || new_owner[:id] } end end |
#public=(new_public) ⇒ String
Set Access-Control-List permissions.
valid new_publics: public_read, private
208 209 210 211 212 213 214 215 |
# File 'lib/fog/aws/models/storage/file.rb', line 208 def public=(new_public) if new_public @acl = 'public-read' else @acl = 'private' end new_public end |
#public? ⇒ Boolean
197 198 199 |
# File 'lib/fog/aws/models/storage/file.rb', line 197 def public? acl.any? {|grant| grant['Grantee']['URI'] == 'http://acs.amazonaws.com/groups/global/AllUsers' && grant['Permission'] == 'READ'} end |
#public_url ⇒ String
Get publicly accessible url via http GET. Checks permissions before creating. Defaults to s3 subdomain or compliant bucket name
required attributes: directory, key
225 226 227 228 229 230 231 232 233 234 235 |
# File 'lib/fog/aws/models/storage/file.rb', line 225 def public_url requires :directory, :key if public? service.request_url( :bucket_name => directory.key, :object_name => key ) else nil end end |
#save(options = {}) ⇒ Boolean
Save file with body as contents to directory.key with name key via http PUT
required attributes: body, directory, key
254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 |
# File 'lib/fog/aws/models/storage/file.rb', line 254 def save( = {}) requires :body, :directory, :key if != {} Fog::Logger.deprecation("options param is deprecated, use acl= instead [light_black](#{caller.first})[/]") end ['x-amz-acl'] ||= @acl if @acl ['Cache-Control'] = cache_control if cache_control ['Content-Disposition'] = content_disposition if content_disposition ['Content-Encoding'] = content_encoding if content_encoding ['Content-MD5'] = content_md5 if content_md5 ['Content-Type'] = content_type if content_type ['Expires'] = expires if expires .merge!() ['x-amz-storage-class'] = storage_class if storage_class ['x-amz-tagging'] = if .merge!(encryption_headers) # With a single PUT operation you can upload objects up to 5 GB in size. Automatically set MP for larger objects. self.multipart_chunk_size = MIN_MULTIPART_CHUNK_SIZE if !multipart_chunk_size && Fog::Storage.get_body_size(body) > MAX_SINGLE_PUT_SIZE if multipart_chunk_size && Fog::Storage.get_body_size(body) >= multipart_chunk_size && body.respond_to?(:read) data = multipart_save() merge_attributes(data.body) else data = service.put_object(directory.key, key, body, ) merge_attributes(data.headers.reject {|key, value| ['Content-Length', 'Content-Type'].include?(key)}) end self.etag = self.etag.gsub('"','') if self.etag self.content_length = Fog::Storage.get_body_size(body) self.content_type ||= Fog::Storage.get_content_type(body) true end |
#url(expires, options = {}) ⇒ String
Get a url for file.
required attributes: key
295 296 297 298 |
# File 'lib/fog/aws/models/storage/file.rb', line 295 def url(expires, = {}) requires :key collection.get_url(key, expires, ) end |