lib/mongo/auth/sasl_conversation_base.rb in mongo-2.14.1 vs lib/mongo/auth/sasl_conversation_base.rb in mongo-2.15.0.alpha

@@ -33,22 +33,10 @@
       # @param [ Server::Connection ] connection The connection being authenticated.
       #
       # @return [ Protocol::Message ] The first SASL conversation message.
       def start(connection)
         selector = client_first_document
-        if connection && connection.features.op_msg_enabled?
-          selector[Protocol::Msg::DATABASE_IDENTIFIER] = user.auth_source
-          cluster_time = connection.mongos? && connection.cluster_time
-          selector[Operation::CLUSTER_TIME] = cluster_time if cluster_time
-          Protocol::Msg.new([], {}, selector)
-        else
-          Protocol::Query.new(
-            user.auth_source,
-            Database::COMMAND,
-            selector,
-            limit: -1,
-          )
-        end
+        build_message(connection, user.auth_source, selector)
       end
 
       private
 
       # Gets the auth mechanism name for the conversation class.