Sha256: 14d0b16113d71e7f81c16aa7b166a122446022c8efa7e0cba65d49bf2fae7950
Contents?: true
Size: 1.95 KB
Versions: 12
Compression:
Stored size: 1.95 KB
Contents
# encoding: utf-8
require "elasticsearch"
require "elasticsearch/transport/transport/http/manticore"
es_client_version = Gem.loaded_specs['elasticsearch-transport'].version
if es_client_version >= Gem::Version.new('7.2') && es_client_version < Gem::Version.new('7.16')
# elasticsearch-transport 7.2.0 - 7.14.0 had a bug where setting http headers
# ES::Client.new ..., transport_options: { headers: { 'Authorization' => ... } }
# would be lost https://github.com/elastic/elasticsearch-ruby/issues/1428
#
# NOTE: needs to be idempotent as input ES plugin might apply the same patch!
#
# @private
module Elasticsearch
module Transport
module Transport
module HTTP
class Manticore
def apply_headers(request_options, options)
headers = (options && options[:headers]) || {}
headers[CONTENT_TYPE_STR] = find_value(headers, CONTENT_TYPE_REGEX) || DEFAULT_CONTENT_TYPE
# this code is necessary to grab the correct user-agent header
# when this method is invoked with apply_headers(@request_options, options)
# from https://github.com/elastic/elasticsearch-ruby/blob/v7.14.0/elasticsearch-transport/lib/elasticsearch/transport/transport/http/manticore.rb#L113-L114
transport_user_agent = nil
if (options && options[:transport_options] && options[:transport_options][:headers])
transport_headers = {}
transport_headers = options[:transport_options][:headers]
transport_user_agent = find_value(transport_headers, USER_AGENT_REGEX)
end
headers[USER_AGENT_STR] = transport_user_agent || find_value(headers, USER_AGENT_REGEX) || user_agent_header
headers[ACCEPT_ENCODING] = GZIP if use_compression?
(request_options[:headers] ||= {}).merge!(headers) # this line was changed
end
end
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems