mirror of
https://github.com/fog/fog-aws.git
synced 2022-11-09 13:50:52 -05:00
61892e3ffe
Some S3 providers (e.g. Ceph) appear to send responses with lowercase HTTP headers (e.g. content-length vs. Content-Length). This appears to confuse fog-aws. The attributes were not being loaded because the aliases did not contain the lowercased version, and the attributes themselves use underscores rather than dashes. To fix this issue, we normalize the headers by fetching the value via excon's case-insensitive lookup, storing the canonical key, and then deleting other matches.
90 lines
3 KiB
Ruby
90 lines
3 KiB
Ruby
Shindo.tests("Storage[:aws] | files", ["aws"]) do
|
|
|
|
file_attributes = {
|
|
:key => 'fog_file_tests',
|
|
:body => lorem_file,
|
|
:public => true
|
|
}
|
|
|
|
directory_attributes = {
|
|
:key => uniq_id('fogfilestests')
|
|
}
|
|
|
|
@directory = Fog::Storage[:aws].directories.create(directory_attributes)
|
|
@directory.versioning = true
|
|
|
|
model_tests(@directory.files, file_attributes, Fog.mocking?) do
|
|
|
|
v1 = @instance.version
|
|
v2 = @directory.service.put_object(@directory.key, @instance.key, 'version 2 content').headers['x-amz-version-id']
|
|
v3 = @directory.service.delete_object(@directory.key, @instance.key).headers['x-amz-version-id']
|
|
v4 = @directory.service.put_object(@directory.key, @instance.key, 'version 3 content').headers['x-amz-version-id']
|
|
|
|
tests("#get") do
|
|
tests("#get without version fetches the latest version").returns(v4) do
|
|
@directory.files.get(@instance.key).version
|
|
end
|
|
|
|
tests("#get with version fetches that exact version").returns(v2) do
|
|
@directory.files.get(@instance.key, 'versionId' => v2).version
|
|
end
|
|
|
|
tests("#get with a deleted version returns nil").returns(nil) do
|
|
pending # getting 405 Method Not Allowed
|
|
@directory.files.get(@instance.key, 'versionId' => v3)
|
|
end
|
|
end
|
|
|
|
tests("#head") do
|
|
tests("#head without version fetches the latest version").returns(v4) do
|
|
@directory.files.head(@instance.key).version
|
|
end
|
|
|
|
tests("#head with version fetches that exact version").returns(v2) do
|
|
@directory.files.head(@instance.key, 'versionId' => v2).version
|
|
end
|
|
|
|
tests("#head with a deleted version returns nil").returns(nil) do
|
|
pending # getting 405 Method Not Allowed
|
|
@directory.files.head(@instance.key, 'versionId' => v3)
|
|
end
|
|
end
|
|
|
|
tests('#normalize_headers') do
|
|
files = @directory.files
|
|
response = Excon::Response.new
|
|
current_time = Time.new(2021, 02, 21)
|
|
|
|
response.headers['last-modified'] = current_time.to_s
|
|
response.headers['etag'] = '12345'
|
|
response.headers['ETAG'] = '12345'
|
|
response.headers['Cache-Control'] = 'no-cache'
|
|
response.headers['Content-disposition'] = 'attachment'
|
|
response.headers['content-length'] = 100
|
|
response.headers['content-Encoding'] = 'gzip'
|
|
response.headers['content-md5'] = 'ABCDEAB'
|
|
response.headers['content-Md5'] = 'ABCDEAB'
|
|
response.headers['ConTent-Type'] = 'application/json'
|
|
|
|
expected = {
|
|
'Last-Modified' => current_time,
|
|
'ETag' => '12345',
|
|
'Cache-Control' => 'no-cache',
|
|
'Content-Disposition' => 'attachment',
|
|
'Content-Length' => 100,
|
|
'Content-Encoding' => 'gzip',
|
|
'Content-MD5' => 'ABCDEAB',
|
|
'Content-Type' => 'application/json'
|
|
}
|
|
|
|
tests('header keys are normalized').returns(expected) do
|
|
files.normalize_headers(response)
|
|
response.headers
|
|
end
|
|
end
|
|
end
|
|
|
|
@directory.versions.each(&:destroy)
|
|
@directory.destroy
|
|
|
|
end
|