Sha256: 689d37165a755b429b11aa20e7db0f4ab2ed7b308b0b2560663a5c8a273ff6cb
Contents?: true
Size: 1.63 KB
Versions: 143
Compression:
Stored size: 1.63 KB
Contents
require 'openssl'
require 'base64'
module Aws
module Plugins
# @seahorse.client.option [Boolean] :compute_checksums (true)
# When `true` a MD5 checksum will be computed for every request that
# sends a body. When `false`, MD5 checksums will only be computed
# for operations that require them. Checksum errors returned by Amazon
# S3 are automatically retried up to `:retry_limit` times.
class S3Md5s < Seahorse::Client::Plugin
# Amazon S3 requires these operations to have an MD5 checksum
REQUIRED_OPERATIONS = [
:delete_objects,
:put_bucket_cors,
:put_bucket_lifecycle,
:put_bucket_policy,
:put_bucket_tagging,
]
# @api private
class Handler < Seahorse::Client::Handler
OneMB = 1024 * 1024
def call(context)
body = context.http_request.body
if body.size > 0
context.http_request.headers['Content-Md5'] ||= md5(body)
end
@handler.call(context)
end
def md5(body)
md5 = OpenSSL::Digest::MD5.new
while chunk = body.read(OneMB)
md5.update(chunk)
end
body.rewind
Base64.encode64(md5.digest).strip
end
end
option(:compute_checksums, true)
def add_handlers(handlers, config)
# priority set low to ensure md5 is computed AFTER the request is
# built but before it is signed
handlers.add(Handler, {
priority: 10,
step: :build,
operations: config.compute_checksums ? nil : REQUIRED_OPERATIONS,
})
end
end
end
end
Version data entries
143 entries across 143 versions & 1 rubygems