mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
Merge pull request #1856 from burns/openstack_object_manifest
[openstack|storage] allow headers to be specified for object manifest
This commit is contained in:
commit
5b079c74d6
2 changed files with 94 additions and 17 deletions
|
@ -3,17 +3,30 @@ module Fog
|
|||
class OpenStack
|
||||
class Real
|
||||
|
||||
# Create a new object
|
||||
# Create a new manifest object
|
||||
#
|
||||
# ==== Parameters
|
||||
# * container<~String> - Name for container, should be < 256 bytes and must not contain '/'
|
||||
# * object<~String> - Name for object
|
||||
# Creates an object with a +X-Object-Manifest+ header that specifies the common prefix ("<container>/<prefix>")
|
||||
# for all uploaded segments. Retrieving the manifest object streams all segments matching this prefix.
|
||||
# Segments must sort in the order they should be concatenated. Note that any future objects stored in the container
|
||||
# along with the segments that match the prefix will be included when retrieving the manifest object.
|
||||
#
|
||||
def put_object_manifest(container, object)
|
||||
# All segments must be stored in the same container, but may be in a different container than the manifest object.
|
||||
# The default +X-Object-Manifest+ header is set to "+container+/+object+", but may be overridden in +options+
|
||||
# to specify the prefix and/or the container where segments were stored.
|
||||
# If overridden, names should be CGI escaped (excluding spaces) if needed (see {Fog::Rackspace.escape}).
|
||||
#
|
||||
# @param container [String] Name for container where +object+ will be stored. Should be < 256 bytes and must not contain '/'
|
||||
# @param object [String] Name for manifest object.
|
||||
# @param options [Hash] Config headers for +object+.
|
||||
# @option options [String] 'X-Object-Manifest' ("container/object") "<container>/<prefix>" for segment objects.
|
||||
#
|
||||
# @see http://docs.openstack.org/api/openstack-object-storage/1.0/content/large-object-creation.html
|
||||
def put_object_manifest(container, object, options = {})
|
||||
path = "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}"
|
||||
headers = {'X-Object-Manifest' => path}.merge(options)
|
||||
request(
|
||||
:expects => 201,
|
||||
:headers => {'X-Object-Manifest' => path},
|
||||
:headers => headers,
|
||||
:method => 'PUT',
|
||||
:path => path
|
||||
)
|
||||
|
|
|
@ -2,34 +2,98 @@ Shindo.tests('Fog::Storage[:openstack] | large object requests', ["openstack"])
|
|||
|
||||
unless Fog.mocking?
|
||||
@directory = Fog::Storage[:openstack].directories.create(:key => 'foglargeobjecttests')
|
||||
@directory2 = Fog::Storage[:openstack].directories.create(:key => 'foglargeobjecttests2')
|
||||
end
|
||||
|
||||
tests('success') do
|
||||
|
||||
tests("#put_object('foglargeobjecttests', 'fog_large_object/1', ('x' * 6 * 1024 * 1024))").succeeds do
|
||||
tests("#put_object('foglargeobjecttests', 'fog_large_object/1', ('x' * 4 * 1024 * 1024))").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].put_object(@directory.identity, 'fog_large_object/1', ('x' * 6 * 1024 * 1024))
|
||||
Fog::Storage[:openstack].put_object(@directory.identity, 'fog_large_object/1', ('x' * 4 * 1024 * 1024))
|
||||
end
|
||||
|
||||
tests("#put_object('foglargeobjecttests', 'fog_large_object/2', ('x' * 4 * 1024 * 1024))").succeeds do
|
||||
tests("#put_object('foglargeobjecttests', 'fog_large_object/2', ('x' * 2 * 1024 * 1024))").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].put_object(@directory.identity, 'fog_large_object/2', ('x' * 4 * 1024 * 1024))
|
||||
Fog::Storage[:openstack].put_object(@directory.identity, 'fog_large_object/2', ('x' * 2 * 1024 * 1024))
|
||||
end
|
||||
|
||||
tests("#put_object_manifest('foglargeobjecttests', 'fog_large_object')").succeeds do
|
||||
tests("#put_object('foglargeobjecttests', 'fog_large_object2/1', ('x' * 1 * 1024 * 1024))").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].put_object_manifest(@directory.identity, 'fog_large_object')
|
||||
Fog::Storage[:openstack].put_object(@directory.identity, 'fog_large_object2/1', ('x' * 1 * 1024 * 1024))
|
||||
end
|
||||
|
||||
tests("#get_object('foglargeobjecttests', 'fog_large_object').body").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].get_object(@directory.identity, 'fog_large_object').body == ('x' * 10 * 1024 * 1024)
|
||||
tests("using default X-Object-Manifest header") do
|
||||
|
||||
tests("#put_object_manifest('foglargeobjecttests', 'fog_large_object')").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].put_object_manifest(@directory.identity, 'fog_large_object')
|
||||
end
|
||||
|
||||
tests("#get_object streams all segments matching the default prefix").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].get_object(@directory.identity, 'fog_large_object').body == ('x' * 7 * 1024 * 1024)
|
||||
end
|
||||
|
||||
tests("#head_object returns Etag that includes manifest object in calculation").succeeds do
|
||||
pending if Fog.mocking?
|
||||
|
||||
etags = []
|
||||
# When the manifest object name is equal to the prefix, OpenStack treats it as if it's the first segment.
|
||||
etags << Digest::MD5.hexdigest('') # Etag for manifest object => "d41d8cd98f00b204e9800998ecf8427e"
|
||||
etags << Digest::MD5.hexdigest('x' * 4 * 1024 * 1024) # => "44981362d3ba9b5bacaf017c2f29d355"
|
||||
etags << Digest::MD5.hexdigest('x' * 2 * 1024 * 1024) # => "67b2f816a30e8956149b2d7beb479e51"
|
||||
etags << Digest::MD5.hexdigest('x' * 1 * 1024 * 1024) # => "b561f87202d04959e37588ee05cf5b10"
|
||||
expected = Digest::MD5.hexdigest(etags.join) # => "42e92048bd2c8085e7072b0b55fd76ab"
|
||||
actual = Fog::Storage[:openstack].head_object(@directory.identity, 'fog_large_object').headers['Etag']
|
||||
actual.gsub('"', '') == expected # actual is returned in quotes "\"42e92048bd2c8085e7072b0b55fd76abu"\"
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
tests("specifying X-Object-Manifest segment prefix") do
|
||||
|
||||
tests("#put_object_manifest('foglargeobjecttests', 'fog_large_object', {'X-Object-Manifest' => 'foglargeobjecttests/fog_large_object/')").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].put_object_manifest(@directory.identity, 'fog_large_object', {'X-Object-Manifest' => "#{@directory.identity}/fog_large_object/"})
|
||||
end
|
||||
|
||||
tests("#get_object streams segments only matching the specified prefix").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].get_object(@directory.identity, 'fog_large_object').body == ('x' * 6 * 1024 * 1024)
|
||||
end
|
||||
|
||||
tests("#head_object returns Etag that does not include manifest object in calculation").succeeds do
|
||||
pending if Fog.mocking?
|
||||
|
||||
etags = []
|
||||
etags << Digest::MD5.hexdigest('x' * 4 * 1024 * 1024) # => "44981362d3ba9b5bacaf017c2f29d355"
|
||||
etags << Digest::MD5.hexdigest('x' * 2 * 1024 * 1024) # => "67b2f816a30e8956149b2d7beb479e51"
|
||||
expected = Digest::MD5.hexdigest(etags.join) # => "0b348495a774eaa4d4c4bbf770820f84"
|
||||
actual = Fog::Storage[:openstack].head_object(@directory.identity, 'fog_large_object').headers['Etag']
|
||||
actual.gsub('"', '') == expected # actual is returned in quotes "\"0b348495a774eaa4d4c4bbf770820f84"\"
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
tests("storing manifest object in a different container than the segments") do
|
||||
|
||||
tests("#put_object_manifest('foglargeobjecttests2', 'fog_large_object', {'X-Object-Manifest' => 'foglargeobjecttests/fog_large_object/'})").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].put_object_manifest(@directory2.identity, 'fog_large_object', {'X-Object-Manifest' => "#{@directory.identity}/fog_large_object/"})
|
||||
end
|
||||
|
||||
tests("#get_object('foglargeobjecttests2', 'fog_large_object').body").succeeds do
|
||||
pending if Fog.mocking?
|
||||
Fog::Storage[:openstack].get_object(@directory2.identity, 'fog_large_object').body == ('x' * 6 * 1024 * 1024)
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
unless Fog.mocking?
|
||||
['fog_large_object', 'fog_large_object/1', 'fog_large_object/2'].each do |key|
|
||||
['fog_large_object', 'fog_large_object/1', 'fog_large_object/2', 'fog_large_object2/1'].each do |key|
|
||||
@directory.files.new(:key => key).destroy
|
||||
end
|
||||
@directory2.files.new(:key => 'fog_large_object').destroy
|
||||
end
|
||||
|
||||
end
|
||||
|
@ -42,6 +106,6 @@ Shindo.tests('Fog::Storage[:openstack] | large object requests', ["openstack"])
|
|||
|
||||
unless Fog.mocking?
|
||||
@directory.destroy
|
||||
@directory2.destroy
|
||||
end
|
||||
|
||||
end
|
||||
|
|
Loading…
Reference in a new issue