Class: Fog::AWS::Storage::Mock
- Inherits:
-
Object
- Object
- Fog::AWS::Storage::Mock
- Includes:
- Utils
- Defined in:
- lib/fog/aws/requests/storage/get_bucket.rb,
lib/fog/aws/storage.rb,
lib/fog/aws/requests/storage/get_object.rb,
lib/fog/aws/requests/storage/put_bucket.rb,
lib/fog/aws/requests/storage/put_object.rb,
lib/fog/aws/requests/storage/copy_object.rb,
lib/fog/aws/requests/storage/get_service.rb,
lib/fog/aws/requests/storage/head_object.rb,
lib/fog/aws/requests/storage/delete_bucket.rb,
lib/fog/aws/requests/storage/delete_object.rb,
lib/fog/aws/requests/storage/get_bucket_acl.rb,
lib/fog/aws/requests/storage/get_object_acl.rb,
lib/fog/aws/requests/storage/get_object_url.rb,
lib/fog/aws/requests/storage/put_bucket_acl.rb,
lib/fog/aws/requests/storage/put_object_url.rb,
lib/fog/aws/requests/storage/get_bucket_logging.rb,
lib/fog/aws/requests/storage/get_object_torrent.rb,
lib/fog/aws/requests/storage/put_bucket_logging.rb,
lib/fog/aws/requests/storage/get_bucket_location.rb,
lib/fog/aws/requests/storage/get_request_payment.rb,
lib/fog/aws/requests/storage/put_request_payment.rb,
lib/fog/aws/requests/storage/get_bucket_versioning.rb,
lib/fog/aws/requests/storage/put_bucket_versioning.rb,
lib/fog/aws/requests/storage/post_object_hidden_fields.rb,
lib/fog/aws/requests/storage/get_bucket_object_versions.rb
Overview
:nodoc:all
Class Method Summary collapse
Instance Method Summary collapse
- #copy_object(source_bucket_name, source_object_name, target_bucket_name, target_object_name, options = {}) ⇒ Object
- #delete_bucket(bucket_name) ⇒ Object
- #delete_object(bucket_name, object_name) ⇒ Object
- #get_bucket(bucket_name, options = {}) ⇒ Object
- #get_bucket_acl(bucket_name) ⇒ Object
- #get_bucket_location(bucket_name) ⇒ Object
- #get_bucket_logging(bucket_name) ⇒ Object
- #get_bucket_object_versions(bucket_name, options = {}) ⇒ Object
- #get_bucket_versioning(bucket_name) ⇒ Object
- #get_object(bucket_name, object_name, options = {}, &block) ⇒ Object
- #get_object_acl(bucket_name, object_name) ⇒ Object
- #get_object_object(bucket_name, object_name) ⇒ Object
- #get_object_url(bucket_name, object_name, expires) ⇒ Object
- #get_request_payment(bucket_name) ⇒ Object
- #get_service ⇒ Object
- #head_object(bucket_name, object_name, options = {}) ⇒ Object
-
#initialize(options = {}) ⇒ Mock
constructor
A new instance of Mock.
- #post_object_hidden_fields(options = {}) ⇒ Object
- #put_bucket(bucket_name, options = {}) ⇒ Object
- #put_bucket_acl(bucket_name, acl) ⇒ Object
- #put_bucket_logging(bucket_name, logging_status) ⇒ Object
- #put_bucket_versioning(bucket_name, status) ⇒ Object
- #put_object(bucket_name, object_name, data, options = {}) ⇒ Object
- #put_object_url(bucket_name, object_name, expires) ⇒ Object
- #put_request_payment(bucket_name, payer) ⇒ Object
- #signature(params) ⇒ Object
Methods included from Utils
Constructor Details
#initialize(options = {}) ⇒ Mock
Returns a new instance of Mock.
93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 |
# File 'lib/fog/aws/storage.rb', line 93 def initialize(={}) require 'mime/types' @aws_access_key_id = [:aws_access_key_id] [:region] ||= 'us-east-1' @host = [:host] || case [:region] when 'eu-west-1' 's3-eu-west-1.amazonaws.com' when 'us-east-1' 's3.amazonaws.com' when 'ap-southeast-1' 's3-ap-southeast-1.amazonaws.com' when 'us-west-1' 's3-us-west-1.amazonaws.com' else raise ArgumentError, "Unknown region: #{[:region].inspect}" end @data = self.class.data[[:region]][@aws_access_key_id] end |
Class Method Details
.data ⇒ Object
77 78 79 80 81 82 83 84 85 |
# File 'lib/fog/aws/storage.rb', line 77 def self.data @data ||= Hash.new do |hash, region| hash[region] = Hash.new do |region_hash, key| region_hash[key] = { :buckets => {} } end end end |
.reset_data(keys = data.keys) ⇒ Object
87 88 89 90 91 |
# File 'lib/fog/aws/storage.rb', line 87 def self.reset_data(keys=data.keys) for key in [*keys] data.delete(key) end end |
Instance Method Details
#copy_object(source_bucket_name, source_object_name, target_bucket_name, target_object_name, options = {}) ⇒ Object
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 |
# File 'lib/fog/aws/requests/storage/copy_object.rb', line 47 def copy_object(source_bucket_name, source_object_name, target_bucket_name, target_object_name, = {}) response = Excon::Response.new source_bucket = @data[:buckets][source_bucket_name] source_object = source_bucket && source_bucket[:objects][source_object_name] target_bucket = @data[:buckets][target_bucket_name] if source_object && target_bucket response.status = 200 target_object = source_object.dup target_object.merge!({ 'Name' => target_object_name }) target_bucket[:objects][target_object_name] = target_object response.body = { 'ETag' => target_object['ETag'], 'LastModified' => Time.parse(target_object['LastModified']) } else response.status = 404 raise(Excon::Errors.status_error({:expects => 200}, response)) end response end |
#delete_bucket(bucket_name) ⇒ Object
31 32 33 34 35 36 37 38 39 40 41 42 43 44 |
# File 'lib/fog/aws/requests/storage/delete_bucket.rb', line 31 def delete_bucket(bucket_name) response = Excon::Response.new if @data[:buckets][bucket_name].nil? response.status = 404 raise(Excon::Errors.status_error({:expects => 204}, response)) elsif @data[:buckets][bucket_name] && !@data[:buckets][bucket_name][:objects].empty? response.status = 409 raise(Excon::Errors.status_error({:expects => 204}, response)) else @data[:buckets].delete(bucket_name) response.status = 204 end response end |
#delete_object(bucket_name, object_name) ⇒ Object
34 35 36 37 38 39 40 41 42 43 44 |
# File 'lib/fog/aws/requests/storage/delete_object.rb', line 34 def delete_object(bucket_name, object_name) response = Excon::Response.new if bucket = @data[:buckets][bucket_name] response.status = 204 bucket[:objects].delete(object_name) else response.status = 404 raise(Excon::Errors.status_error({:expects => 204}, response)) end response end |
#get_bucket(bucket_name, options = {}) ⇒ Object
61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 |
# File 'lib/fog/aws/requests/storage/get_bucket.rb', line 61 def get_bucket(bucket_name, = {}) unless bucket_name raise ArgumentError.new('bucket_name is required') end if ['delimiter'] Fog::Mock.not_implemented end response = Excon::Response.new if bucket = @data[:buckets][bucket_name] contents = bucket[:objects].values.sort {|x,y| x['Key'] <=> y['Key']}.reject do |object| (['prefix'] && object['Key'][0...['prefix'].length] != ['prefix']) || (['marker'] && object['Key'] <= ['marker']) end.map do |object| data = object.reject {|key, value| !['ETag', 'Key', 'LastModified', 'Size', 'StorageClass'].include?(key)} data.merge!({ 'LastModified' => Time.parse(data['LastModified']), 'Owner' => bucket['Owner'], 'Size' => data['Size'].to_i }) data end max_keys = ['max-keys'] || 1000 size = [max_keys, 1000].min truncated_contents = contents[0...size] response.status = 200 response.body = { 'Contents' => truncated_contents, 'IsTruncated' => truncated_contents.size != contents.size, 'Marker' => ['marker'], 'MaxKeys' => max_keys, 'Name' => bucket['Name'], 'Prefix' => ['prefix'] } if ['max-keys'] && ['max-keys'] < response.body['Contents'].length response.body['IsTruncated'] = true response.body['Contents'] = response.body['Contents'][0...['max-keys']] end else response.status = 404 raise(Excon::Errors.status_error({:expects => 200}, response)) end response end |
#get_bucket_acl(bucket_name) ⇒ Object
51 52 53 |
# File 'lib/fog/aws/requests/storage/get_bucket_acl.rb', line 51 def get_bucket_acl(bucket_name) Fog::Mock.not_implemented end |
#get_bucket_location(bucket_name) ⇒ Object
37 38 39 40 41 42 43 44 45 46 47 |
# File 'lib/fog/aws/requests/storage/get_bucket_location.rb', line 37 def get_bucket_location(bucket_name) response = Excon::Response.new if bucket = @data[:buckets][bucket_name] response.status = 200 response.body = {'LocationConstraint' => bucket['LocationConstraint'] } else response.status = 404 raise(Excon::Errors.status_error({:expects => 200}, response)) end response end |
#get_bucket_logging(bucket_name) ⇒ Object
51 52 53 |
# File 'lib/fog/aws/requests/storage/get_bucket_logging.rb', line 51 def get_bucket_logging(bucket_name) Fog::Mock.not_implemented end |
#get_bucket_object_versions(bucket_name, options = {}) ⇒ Object
76 77 78 |
# File 'lib/fog/aws/requests/storage/get_bucket_object_versions.rb', line 76 def get_bucket_object_versions(bucket_name, = {}) Fog::Mock.not_implemented end |
#get_bucket_versioning(bucket_name) ⇒ Object
41 42 43 |
# File 'lib/fog/aws/requests/storage/get_bucket_versioning.rb', line 41 def get_bucket_versioning(bucket_name) Fog::Mock.not_implemented end |
#get_object(bucket_name, object_name, options = {}, &block) ⇒ Object
60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 |
# File 'lib/fog/aws/requests/storage/get_object.rb', line 60 def get_object(bucket_name, object_name, = {}, &block) unless bucket_name raise ArgumentError.new('bucket_name is required') end unless object_name raise ArgumentError.new('object_name is required') end response = Excon::Response.new if (bucket = @data[:buckets][bucket_name]) && (object = bucket[:objects][object_name]) if ['If-Match'] && ['If-Match'] != object['ETag'] response.status = 412 elsif ['If-Modified-Since'] && ['If-Modified-Since'] > Time.parse(object['LastModified']) response.status = 304 elsif ['If-None-Match'] && ['If-None-Match'] == object['ETag'] response.status = 304 elsif ['If-Unmodified-Since'] && ['If-Unmodified-Since'] < Time.parse(object['LastModified']) response.status = 412 else response.status = 200 response.headers = { 'Content-Length' => object['Size'], 'Content-Type' => object['Content-Type'], 'ETag' => object['ETag'], 'Last-Modified' => object['LastModified'] } unless block_given? response.body = object[:body] else data = StringIO.new(object[:body]) remaining = data.length while remaining > 0 chunk = data.read([remaining, Excon::CHUNK_SIZE].min) block.call(chunk) remaining -= Excon::CHUNK_SIZE end end end else response.status = 404 raise(Excon::Errors.status_error({:expects => 200}, response)) end response end |
#get_object_acl(bucket_name, object_name) ⇒ Object
62 63 64 |
# File 'lib/fog/aws/requests/storage/get_object_acl.rb', line 62 def get_object_acl(bucket_name, object_name) Fog::Mock.not_implemented end |
#get_object_object(bucket_name, object_name) ⇒ Object
51 52 53 |
# File 'lib/fog/aws/requests/storage/get_object_torrent.rb', line 51 def get_object_object(bucket_name, object_name) Fog::Mock.not_implemented end |
#get_object_url(bucket_name, object_name, expires) ⇒ Object
39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/fog/aws/requests/storage/get_object_url.rb', line 39 def get_object_url(bucket_name, object_name, expires) unless bucket_name raise ArgumentError.new('bucket_name is required') end unless object_name raise ArgumentError.new('object_name is required') end url({ :headers => {}, :host => @host, :method => 'GET', :path => [bucket_name, CGI.escape(object_name)].join('/') }, expires) end |
#get_request_payment(bucket_name) ⇒ Object
37 38 39 40 41 42 43 44 45 46 47 |
# File 'lib/fog/aws/requests/storage/get_request_payment.rb', line 37 def get_request_payment(bucket_name) response = Excon::Response.new if bucket = @data[:buckets][bucket_name] response.status = 200 response.body = { 'Payer' => bucket['Payer'] } else response.status = 404 raise(Excon::Errors.status_error({:expects => 200}, response)) end response end |
#get_service ⇒ Object
39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/fog/aws/requests/storage/get_service.rb', line 39 def get_service response = Excon::Response.new response.headers['Status'] = 200 buckets = @data[:buckets].values.map do |bucket| bucket.reject do |key, value| !['CreationDate', 'Name'].include?(key) end end response.body = { 'Buckets' => buckets, 'Owner' => { 'DisplayName' => 'owner', 'ID' => 'some_id'} } response end |
#head_object(bucket_name, object_name, options = {}) ⇒ Object
59 60 61 62 63 |
# File 'lib/fog/aws/requests/storage/head_object.rb', line 59 def head_object(bucket_name, object_name, = {}) response = get_object(bucket_name, object_name, ) response.body = nil response end |
#post_object_hidden_fields(options = {}) ⇒ Object
43 44 45 |
# File 'lib/fog/aws/requests/storage/post_object_hidden_fields.rb', line 43 def post_object_hidden_fields( = {}) Fog::Mock.not_implemented end |
#put_bucket(bucket_name, options = {}) ⇒ Object
46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
# File 'lib/fog/aws/requests/storage/put_bucket.rb', line 46 def put_bucket(bucket_name, = {}) response = Excon::Response.new response.status = 200 bucket = { :objects => {}, 'Name' => bucket_name, 'CreationDate' => Time.now, 'Owner' => { 'DisplayName' => 'owner', 'ID' => 'some_id'}, 'Payer' => 'BucketOwner' } if ['LocationConstraint'] bucket['LocationConstraint'] = ['LocationConstraint'] else bucket['LocationConstraint'] = nil end unless @data[:buckets][bucket_name] @data[:buckets][bucket_name] = bucket end response end |
#put_bucket_acl(bucket_name, acl) ⇒ Object
77 78 79 |
# File 'lib/fog/aws/requests/storage/put_bucket_acl.rb', line 77 def put_bucket_acl(bucket_name, acl) Fog::Mock.not_implemented end |
#put_bucket_logging(bucket_name, logging_status) ⇒ Object
84 85 86 |
# File 'lib/fog/aws/requests/storage/put_bucket_logging.rb', line 84 def put_bucket_logging(bucket_name, logging_status) Fog::Mock.not_implemented end |
#put_bucket_versioning(bucket_name, status) ⇒ Object
37 38 39 |
# File 'lib/fog/aws/requests/storage/put_bucket_versioning.rb', line 37 def put_bucket_versioning(bucket_name, status) Fog::Mock.not_implemented end |
#put_object(bucket_name, object_name, data, options = {}) ⇒ Object
48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 |
# File 'lib/fog/aws/requests/storage/put_object.rb', line 48 def put_object(bucket_name, object_name, data, = {}) data = parse_data(data) unless data[:body].is_a?(String) data[:body] = data[:body].read end response = Excon::Response.new if (bucket = @data[:buckets][bucket_name]) response.status = 200 bucket[:objects][object_name] = { :body => data[:body], 'ETag' => Fog::AWS::Mock.etag, 'Key' => object_name, 'LastModified' => Time.now.utc.strftime("%a, %d %b %Y %H:%M:%S +0000"), 'Size' => data[:headers]['Content-Length'], 'StorageClass' => 'STANDARD' } bucket[:objects][object_name]['Content-Type'] = data[:headers]['Content-Type'] else response.status = 404 raise(Excon::Errors.status_error({:expects => 200}, response)) end response end |
#put_object_url(bucket_name, object_name, expires) ⇒ Object
39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/fog/aws/requests/storage/put_object_url.rb', line 39 def put_object_url(bucket_name, object_name, expires) unless bucket_name raise ArgumentError.new('bucket_name is required') end unless object_name raise ArgumentError.new('object_name is required') end url({ :headers => {}, :host => @host, :method => 'PUT', :path => [bucket_name, CGI.escape(object_name)].join('/') }, expires) end |
#put_request_payment(bucket_name, payer) ⇒ Object
36 37 38 39 40 41 42 43 44 45 46 |
# File 'lib/fog/aws/requests/storage/put_request_payment.rb', line 36 def put_request_payment(bucket_name, payer) response = Excon::Response.new if bucket = @data[:buckets][bucket_name] response.status = 200 bucket['Payer'] = payer else response.status = 404 raise(Excon::Errors.status_error({:expects => 200}, response)) end response end |
#signature(params) ⇒ Object
112 113 114 |
# File 'lib/fog/aws/storage.rb', line 112 def signature(params) "foo" end |