Failover authentication fixes

lib/moped/failover.rb

@@ -17,7 +17,7 @@ module Failover
     #
     # @since 2.0.0
     STRATEGIES = {
-      Errors::AuthenticationFailure => Ignore,
+      Errors::AuthenticationFailure => Retry,
       Errors::ConnectionFailure => Retry,
       Errors::CursorNotFound => Ignore,
       Errors::OperationFailure => Reconfigure,

lib/moped/operation/read.rb

@@ -47,6 +47,7 @@ def initialize(operation)
       def execute(node)
         node.process(operation) do |reply|
           if operation.failure?(reply)
+            node.down! if reply.unauthorized?
             raise operation.failure_exception(reply)
           end
           operation.results(reply)

spec/moped/failover_spec.rb

@@ -56,8 +56,8 @@
           described_class.get(Moped::Errors::AuthenticationFailure.new({}, {}))
         end
 
-        it "returns an ignore" do
-          expect(failover).to be_a(Moped::Failover::Ignore)
+        it "returns a retry" do
+          expect(failover).to be_a(Moped::Failover::Retry)
         end
       end
 

spec/moped/operation/read_spec.rb

@@ -39,6 +39,11 @@
             replica_set_node.unauthorized_on_next_message!
           end
 
+          it "should mark the node as down" do
+            expect(node).to receive(:down!)
+            read.execute(node) rescue nil
+          end
+
           it "raises a failure error" do
             expect {
               read.execute(node)
@@ -53,6 +58,10 @@
           replica_set_node.query_failure_on_next_message!
         end
 
+        it "should not mark the node as down" do
+          expect(node).to_not receive(:down!)
+        end
+
         it "raises a failure error" do
           expect {
             read.execute(node)