Handle security config for ES8

Author: sinisterchipmunk

Rakefile

@@ -38,14 +38,16 @@ def admin_client
 
     if test_suite == 'security'
       transport_options.merge!(:ssl => { verify: false,
-                                         ca_path: CERT_DIR })
+                                         ca_path: defined?(CERT_DIR) ? CERT_DIR : nil
+                                       }.compact)
 
       password = ENV['ELASTIC_PASSWORD']
       user = ENV['ELASTIC_USER'] || 'elastic'
-      url = "https://#{user}:#{password}@#{host}:#{port}"
+      url = "https://#{user}:#{password}@#{host || 'localhost'}:#{port || 9200}"
     else
       url = "http://#{host || 'localhost'}:#{port || 9200}"
     end
+    ENV['ELASTICSEARCH_URL'] ||= url
     Elasticsearch::Client.new(host: url, transport_options: transport_options)
   end
 end
@@ -140,7 +142,7 @@ namespace :test do
   end
 
   desc "Run all tests in all subprojects"
-  task all: :wait_for_green do
+  task all: :wait_for_green_or_yellow do
     subprojects.each do |project|
       puts '-'*80
       sh "cd #{project} && " +
@@ -151,20 +153,20 @@ namespace :test do
   end
 end
 
-desc "Wait for elasticsearch cluster to be in green state"
-task :wait_for_green do
+desc "Wait for elasticsearch cluster to be in green or yellow state"
+task :wait_for_green_or_yellow do
   require 'elasticsearch'
 
   ready = nil
   5.times do |i|
     begin
-      puts "Attempting to wait for green status: #{i + 1}"
-      if admin_client.cluster.health(wait_for_status: 'green', timeout: '50s')
+      puts "Attempting to wait for green or yellow status: #{i + 1}"
+      if admin_client.cluster.health(wait_for_status: 'yellow', timeout: '50s')
         ready = true
         break
       end
     rescue Elastic::Transport::Transport::Errors::RequestTimeout => ex
-      puts "Couldn't confirm green status.\n#{ex.inspect}."
+      puts "Couldn't confirm green or yellow status.\n#{ex.inspect}."
     rescue Faraday::ConnectionFailed => ex
       puts "Couldn't connect to Elasticsearch.\n#{ex.inspect}."
       sleep(30)

elasticsearch-model/spec/elasticsearch/model/indexing_spec.rb

@@ -591,7 +591,7 @@ class ::DummyIndexingModelForRecreate
 
     context 'when the index is not found' do
       let(:logger) { nil }
-      let(:client) { Elasticsearch::Client.new(logger: logger) }
+      let(:client) { Elasticsearch::Client.new(logger: logger, transport_options: { ssl: { verify: false } }) }
 
       before do
         expect(DummyIndexingModelForRecreate).to receive(:client).at_most(3).times.and_return(client)

elasticsearch-model/spec/spec_helper.rb

@@ -45,7 +45,8 @@
     tracer.formatter = lambda { |s, d, p, m| "#{m.gsub(/^.*$/) { |n| '   ' + n }.ansi(:faint)}\n" }
     Elasticsearch::Model.client = Elasticsearch::Client.new(
       host: ELASTICSEARCH_URL,
-      tracer: (ENV['QUIET'] ? nil : tracer)
+      tracer: (ENV['QUIET'] ? nil : tracer),
+      transport_options: { :ssl => { verify: false } }
     )
     puts "Elasticsearch Version: #{Elasticsearch::Model.client.info['version']}"
 

elasticsearch-persistence/spec/spec_helper.rb

@@ -36,7 +36,8 @@
 #
 # @since 6.0.0
 DEFAULT_CLIENT = Elasticsearch::Client.new(host: ELASTICSEARCH_URL,
-                                           tracer: (ENV['QUIET'] ? nil : ::Logger.new(STDERR)))
+                                           tracer: (ENV['QUIET'] ? nil : ::Logger.new(STDERR)),
+                                           transport_options: { :ssl => { verify: false } })
 
 class MyTestRepository
   include Elasticsearch::Persistence::Repository

elasticsearch-rails/spec/spec_helper.rb

@@ -36,7 +36,8 @@
     tracer = ::Logger.new(STDERR)
     tracer.formatter = lambda { |s, d, p, m| "#{m.gsub(/^.*$/) { |n| '   ' + n }.ansi(:faint)}\n" }
     Elasticsearch::Model.client = Elasticsearch::Client.new host: ELASTICSEARCH_URL,
-                                                            tracer: (ENV['QUIET'] ? nil : tracer)
+                                                            tracer: (ENV['QUIET'] ? nil : tracer),
+                                                            transport_options: { :ssl => { verify: false } }
     puts "Elasticsearch Version: #{Elasticsearch::Model.client.info['version']}"
 
     unless ActiveRecord::Base.connected?