Method initialize has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def initialize(host, port, timeout, family, options = {})

Method update_one has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def update_one(documents, server, operation_id, session, txn_num)

Method initialize has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def initialize(database, collection, selector, update, options = {})

Method start has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

        def start(connection = nil)
          login = LOGIN.merge(mechanism: X509::MECHANISM)
          login[:user] = user.name if user.name
          if connection && connection.features.op_msg_enabled?
            selector = login

• Read up
  Read up

Method clear has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def clear(options = nil)
        raise_if_closed!

        @lock.synchronize do
          @generation += 1

• Read up
  Read up

Method update_rs_with_primary_from_member has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def update_rs_with_primary_from_member
      if topology.replica_set_name != updated_desc.replica_set_name
        log_warn(
          "Removing server #{updated_desc.address.to_s} because it has an " +
          "incorrect replica set name (#{updated_desc.replica_set_name}); " +

• Read up
  Read up

Method command has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def command(server)
        sel = selector(server).dup
        add_write_concern!(sel)
        sel[Protocol::Msg::DATABASE_IDENTIFIER] = db_name
        sel['$readPreference'] = read.to_doc if read

• Read up
  Read up

Method end_session has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def end_session
      if !ended? && @client
        if within_states?(TRANSACTION_IN_PROGRESS_STATE)
          begin
            abort_transaction

• Read up
  Read up

Method populate has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def populate
        return if closed?

        catch(:done) do
          loop do

• Read up
  Read up

Method document has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def document
        client_document = full_client_document
        while client_document.to_bson.to_s.size > MAX_DOCUMENT_SIZE do
          if client_document[:os][:name] || client_document[:os][:architecture]
            client_document[:os].delete(:name)

• Read up
  Read up

Method generate_reply has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

        def self.generate_reply(command_payload, reply_payload)
          if reply_payload
            reply = reply_payload[:reply]
            if cursor = reply[:cursor]
              if !cursor.key?(Collection::NS)

• Read up
  Read up

Method server_type has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def server_type
        return :arbiter if arbiter?
        return :ghost if ghost?
        return :sharded if mongos?
        return :primary if primary?

• Read up
  Read up

Method count has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

        def count(opts = {})
          cmd = { :count => collection.name, :query => filter }
          cmd[:skip] = opts[:skip] if opts[:skip]
          cmd[:hint] = opts[:hint] if opts[:hint]
          cmd[:limit] = opts[:limit] if opts[:limit]

• Read up
  Read up

Method open_download_stream_by_name has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def open_download_stream_by_name(filename, opts = {}, &block)
        revision = opts.fetch(:revision, -1)
        if revision < 0
          skip = revision.abs - 1
          sort = { 'uploadDate' => Mongo::Index::DESCENDING }

• Read up
  Read up

Method initial has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def initial(cluster, monitoring, options)
        cls = if options.key?(:connect)
          OPTIONS.fetch(options[:connect].to_sym)
        elsif options.key?(:replica_set) || options.key?(:replica_set_name)
          ReplicaSetNoPrimary

• Read up
  Read up

Method set_cert_verification has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def set_cert_verification(context, options)
        context.verify_mode = OpenSSL::SSL::VERIFY_PEER
        cert_store = OpenSSL::X509::Store.new
        if options[:ssl_ca_cert]
          cert_store.add_file(options[:ssl_ca_cert])

• Read up
  Read up

Method deserialize has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def self.deserialize(io, max_message_size = MAX_MESSAGE_SIZE, expected_response_to = nil)
        length, _request_id, response_to, _op_code = deserialize_header(BSON::ByteBuffer.new(io.read(16)))

        # Protection from potential DOS man-in-the-middle attacks. See
        # DRIVERS-276.

• Read up
  Read up

Avoid too many return statements within this method.

Open

        return :secondary if secondary?

Avoid too many return statements within this method.

Open

        return :standalone if standalone?

Avoid too many return statements within this method.

Open

        return :other if other?