Sha256: 8df45f2b672f2a3abd51c72c2c6afd4a71633af529ccca504a3bda7bddfe207b
Contents?: true
Size: 1.49 KB
Versions: 5
Compression:
Stored size: 1.49 KB
Contents
require 'faraday_middleware/ext/uri_ext' require 'faraday_middleware/aws_signers_v4_ext' class FaradayMiddleware::AwsSignersV4 < Faraday::Middleware class Request def initialize(env) @env = env end def headers @env.request_headers end def body @env.body || '' end def endpoint url = @env.url.dup # Escape the query string or the request won't sign correctly if url and url.query re_escape_query!(url) end url end def http_method @env.method.to_s.upcase end private def re_escape_query!(url) params = URI.decode_www_form(url.query) if params.any? {|k, v| v =~ / / } url.query = URI.seahorse_encode_www_form(params) end end end # of class Request def initialize(app, options = nil) super(app) @credentials = options.fetch(:credentials) @service_name = options.fetch(:service_name) @region = options.fetch(:region) @net_http = net_http?(app) end def call(env) normalize_for_net_http!(env) req = Request.new(env) Aws::Signers::V4.new(@credentials, @service_name, @region).sign(req) @app.call(env) end private def net_http?(app) app.is_a?(Faraday::Adapter::NetHttp) end def normalize_for_net_http!(env) return unless @net_http if Net::HTTP::HAVE_ZLIB env.request_headers['Accept-Encoding'] ||= 'gzip;q=1.0,deflate;q=0.6,identity;q=0.3' end env.request_headers['Accept'] ||= '*/*' end end
Version data entries
5 entries across 5 versions & 1 rubygems