[MODEL] Use logger to log index not found message (elastic#868)

* [MODEL] Use logger to log index not found message

* [CI] Remove Gemfile.lock on Travis

* [CI] Update Travis matrix

Author: estolfo

.travis.yml

@@ -25,22 +25,18 @@ matrix:
       jdk: oraclejdk8
       env: RAILS_VERSIONS=3.0
 
-    - rvm: 2.3
+    - rvm: 2.3.8
       jdk: oraclejdk8
       env: RAILS_VERSIONS=5.0
 
-    - rvm: 2.4
+    - rvm: 2.6.1
       jdk: oraclejdk8
-      env: RAILS_VERSIONS=5.0
+      env: RAILS_VERSIONS=4.0,5.0
 
-    - rvm: jruby-9.1
+    - rvm: jruby-9.2.5.0
       jdk: oraclejdk8
       env: RAILS_VERSIONS=5.0
 
-    - rvm: 2.5
-      jdk: oraclejdk8
-      env: RAILS_VERSIONS=4.0,5.0
-
 env:
   global:
     - ELASTICSEARCH_VERSION=7.0.0
@@ -49,8 +45,8 @@ env:
 
 before_install:
   - ELASTICSEARCH_VERSION=7.0.0 TEST_CLUSTER_PORT=9250 source ./travis_before_script.sh
-  - gem update --system -q
-  - gem update bundler -q
+  - gem update --system
+  - gem update bundler
   - gem --version
   - bundle version
 

elasticsearch-model/lib/elasticsearch/model/indexing.rb

@@ -286,7 +286,8 @@ def delete_index!(options={})
             self.client.indices.delete index: target_index
           rescue Exception => e
             if e.class.to_s =~ /NotFound/ && options[:force]
-              STDERR.puts "[!!!] Index does not exist (#{e.class})"
+              client.transport.logger.debug("[!!!] Index does not exist (#{e.class})") if client.transport.logger
+              nil
             else
               raise e
             end
@@ -312,7 +313,8 @@ def refresh_index!(options={})
             self.client.indices.refresh index: target_index
           rescue Exception => e
             if e.class.to_s =~ /NotFound/ && options[:force]
-              STDERR.puts "[!!!] Index does not exist (#{e.class})"
+              client.transport.logger.debug("[!!!] Index does not exist (#{e.class})") if client.transport.logger
+              nil
             else
               raise e
             end

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

@@ -629,7 +629,7 @@ class ::DummyIndexingModelForRecreate
     context 'when the index is not found' do
 
       let(:client) do
-        double('client', indices: indices)
+        double('client', indices: indices, transport: double('transport', { logger: nil }))
       end
 
       let(:indices) do
@@ -639,14 +639,34 @@ class ::DummyIndexingModelForRecreate
       end
 
       before do
-        expect(DummyIndexingModelForRecreate).to receive(:client).and_return(client)
+        expect(DummyIndexingModelForRecreate).to receive(:client).at_most(3).times.and_return(client)
       end
 
       context 'when the force option is true' do
 
         it 'deletes the index without raising an exception' do
           expect(DummyIndexingModelForRecreate.delete_index!(force: true)).to be_nil
         end
+
+        context 'when the client has a logger' do
+
+          let(:logger) do
+            Logger.new(STDOUT).tap { |l| l.level = Logger::DEBUG }
+          end
+
+          let(:client) do
+            double('client', indices: indices, transport: double('transport', { logger: logger }))
+          end
+
+          it 'deletes the index without raising an exception' do
+            expect(DummyIndexingModelForRecreate.delete_index!(force: true)).to be_nil
+          end
+
+          it 'logs the message that the index is not found' do
+            expect(logger).to receive(:debug)
+            expect(DummyIndexingModelForRecreate.delete_index!(force: true)).to be_nil
+          end
+        end
       end
 
       context 'when the force option is not provided' do
@@ -816,6 +836,8 @@ class ::DummyIndexingModelForCreate
         expect(DummyIndexingModelForCreate.create_index!(index: 'custom-foo'))
       end
     end
+
+    context 'when the logging level is debug'
   end
 
   describe '#refresh_index!' do
@@ -841,15 +863,15 @@ class ::DummyIndexingModelForRefresh
     end
 
     let(:client) do
-      double('client', indices: indices)
+      double('client', indices: indices, transport: double('transport', { logger: nil }))
     end
 
     let(:indices) do
       double('indices')
     end
 
     before do
-      expect(DummyIndexingModelForRefresh).to receive(:client).and_return(client)
+      expect(DummyIndexingModelForRefresh).to receive(:client).at_most(3).times.and_return(client)
     end
 
     context 'when the force option is true' do
@@ -863,6 +885,26 @@ class ::DummyIndexingModelForRefresh
         it 'does not raise an exception' do
           expect(DummyIndexingModelForRefresh.refresh_index!(force: true)).to be_nil
         end
+
+        context 'when the client has a logger' do
+
+          let(:logger) do
+            Logger.new(STDOUT).tap { |l| l.level = Logger::DEBUG }
+          end
+
+          let(:client) do
+            double('client', indices: indices, transport: double('transport', { logger: logger }))
+          end
+
+          it 'does not raise an exception' do
+            expect(DummyIndexingModelForRefresh.refresh_index!(force: true)).to be_nil
+          end
+
+          it 'logs the message that the index is not found' do
+            expect(logger).to receive(:debug)
+            expect(DummyIndexingModelForRefresh.refresh_index!(force: true)).to be_nil
+          end
+        end
       end
 
       context 'when the operation raises another type of exception' do