1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
# frozen_string_literal: true
require 'securerandom'
module Aws
module Plugins
# @api private
class InvocationId < Seahorse::Client::Plugin
# @api private
class Handler < Seahorse::Client::Handler
def call(context)
apply_invocation_id(context)
@handler.call(context)
end
private
def apply_invocation_id(context)
context.http_request.headers['amz-sdk-invocation-id'] = SecureRandom.uuid
if context[:input_event_emitter]
# only used for eventstreaming at input
context.http_request.headers['x-amz-content-sha256'] = 'STREAMING-AWS4-HMAC-SHA256-EVENTS'
end
end
end
handler(Handler, step: :initialize)
end
end
end
|
