Sha256: 131ab75005f562e7714ffaf58b4cce791426e2f2a30e6748b0b941aee5519c10
Contents?: true
Size: 1.83 KB
Versions: 11
Compression:
Stored size: 1.83 KB
Contents
module ESHelper
def self.get_host_port
return "elasticsearch:9200" if ENV["INTEGRATION"] == "true" || ENV["SECURE_INTEGRATION"] == "true"
raise "This setting is only used for integration tests"
end
def self.get_client(options = {})
ssl_options = {}
hosts = [get_host_port]
if options[:ca_file]
ssl_options = { :ssl => true, :ca_file => options[:ca_file] }
hosts.map! do |h|
host, port = h.split(":")
{ :host => host, :scheme => 'https', :port => port }
end
end
transport_options = {}
if options[:user] && options[:password]
token = Base64.strict_encode64("#{options[:user]}:#{options[:password]}")
transport_options[:headers] = { :Authorization => "Basic #{token}" }
end
@client = Elasticsearch::Client.new(:hosts => hosts, :transport_options => transport_options, :ssl => ssl_options,
:transport_class => ::Elasticsearch::Transport::Transport::HTTP::Manticore)
end
def self.doc_type
if ESHelper.es_version_satisfies?(">=8")
nil
elsif ESHelper.es_version_satisfies?(">=7")
"_doc"
else
"doc"
end
end
def self.index_doc(es, params)
type = doc_type
params[:type] = doc_type unless type.nil?
es.index(params)
end
def self.es_version
ENV['ES_VERSION'] || ENV['ELASTIC_STACK_VERSION']
end
def self.es_version_satisfies?(*requirement)
es_version = RSpec.configuration.filter[:es_version] || ENV['ES_VERSION'] || ENV['ELASTIC_STACK_VERSION']
if es_version.nil?
puts "Info: ES_VERSION, ELASTIC_STACK_VERSION or 'es_version' tag wasn't set. Returning false to all `es_version_satisfies?` call."
return false
end
es_release_version = Gem::Version.new(es_version).release
Gem::Requirement.new(requirement).satisfied_by?(es_release_version)
end
end
Version data entries
11 entries across 11 versions & 1 rubygems