Sha256: 0e5ffd718bf278afa7fee92f90b8609684fffc6217b378cdb2401ab3f3eeb1e5
Contents?: true
Size: 1.42 KB
Versions: 50
Compression:
Stored size: 1.42 KB
Contents
module Aws
module Plugins
# For Streaming Input Operations, when `requiresLength` is enabled
# checking whether `Content-Length` header can be set,
# for `v4-unsigned-body` operations, set `Transfer-Encoding` header
class TransferEncoding < Seahorse::Client::Plugin
# @api private
class Handler < Seahorse::Client::Handler
def call(context)
if streaming?(context.operation.input)
begin
context.http_request.body.size
rescue
if requires_length?(context.operation.input)
# if size of the IO is not available but required
raise Aws::Errors::MissingContentLength.new
elsif context.operation['authtype'] == "v4-unsigned-body"
context.http_request.headers['Transfer-Encoding'] = 'chunked'
end
end
end
@handler.call(context)
end
private
def streaming?(ref)
if payload = ref[:payload_member]
payload["streaming"] || # checking ref and shape
payload.shape["streaming"]
else
false
end
end
def requires_length?(ref)
payload = ref[:payload_member]
payload["requiresLength"] || # checking ref and shape
payload.shape["requiresLength"]
end
end
handler(Handler, step: :sign)
end
end
end
Version data entries
50 entries across 50 versions & 1 rubygems