Method validate_update_documents! has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

        def validate_update_documents!(spec)
          if update = spec.is_a?(Array) ? spec&.first : spec
            if key = update.keys&.first
              unless key.to_s.start_with?("$")
                if Mongo.validate_update_replace

• Read up
  Read up

Method convert_limit_and_batch_size! has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

          module_function def convert_limit_and_batch_size!(command)
            if command[:limit] && command[:limit] < 0 &&
              command[:batchSize] && command[:batchSize] < 0
            then
              command[:limit] = command[:limit].abs

• Read up
  Read up

Method maybe_set_schema_map has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def maybe_set_schema_map(options)
        if !options[:schema_map] && !options[:schema_map_path]
          @schema_map = nil
        elsif options[:schema_map] && options[:schema_map_path]
          raise ArgumentError.new(

• Read up
  Read up

Method set_algorithm_opts has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def set_algorithm_opts(options)
        Binding.ctx_setopt_algorithm(self, options[:algorithm])
        if %w(Indexed RangePreview).include?(options[:algorithm])
          if options[:contention_factor]
            Binding.ctx_setopt_contention_factor(self, options[:contention_factor])

• Read up
  Read up

Method get_records has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def get_records(hostname, srv_service_name=nil, srv_max_hosts=nil)
        query_name = record_prefix(srv_service_name) + hostname
        resources = @resolver.getresources(query_name, Resolv::DNS::Resource::IN::SRV)

        # Collect all of the records into a Result object, raising an error

• Read up
  Read up

Method initialize has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def initialize(flags, options, main_document, *sequences)
        if flags
          flags.each do |flag|
            unless KNOWN_FLAGS.key?(flag)
              raise ArgumentError, "Unknown flag: #{flag.inspect}"

• Read up
  Read up

Method initialize has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def initialize(address, cluster, monitoring, event_listeners, options = {})
      @address = address
      @cluster = cluster
      @monitoring = monitoring
      options = options.dup

Method check has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def check
        @lock.synchronize do
          if @connection && @connection.pid != Process.pid
            log_warn("Detected PID change - Mongo client should have been reconnected (old pid #{@connection.pid}, new pid #{Process.pid}")
            @connection.disconnect!

Method initial has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def initial(cluster, monitoring, options)
        connect = options[:connect]&.to_sym
        cls = if options[:direct_connection]
          if connect && connect != :direct
            raise ArgumentError, "Conflicting topology options: direct_connection=true and connect=#{connect}"

Method create_and_add_connection has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def create_and_add_connection
        connection = nil

        @lock.synchronize do
          if !closed? && @ready &&

Method close has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def close
      @state_change_lock.synchronize do
        unless connecting? || connected?
          return nil
        end

Method get_connection has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def get_connection(pid, connection_global_id)
        if connection = next_available_connection(connection_global_id)
          unless valid_available_connection?(connection, pid, connection_global_id)
            return nil
          end

Method change_doc has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def change_doc
          {}.tap do |doc|
            if @options[:full_document]
              doc[:fullDocument] = @options[:full_document]
            end

Method delete_many has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def delete_many(opts = {})
          with_session(opts) do |session|
            write_concern = if opts[:write_concern]
              WriteConcern.get(opts[:write_concern])
            else

Method initialize has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def initialize(flags, options, main_document, *sequences)
        if flags
          flags.each do |flag|
            unless KNOWN_FLAGS.key?(flag)
              raise ArgumentError, "Unknown flag: #{flag.inspect}"

Method validate_requests! has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def validate_requests!
      requests_empty = true
      @requests.each do |req|
        requests_empty = false
        if op = req.keys.first

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            write_with_retry(write_concern, context: context) do |connection, txn_num, context|
              gte_4_4 = connection.server.description.server_version_gte?('4.4')
              if !gte_4_4 && opts[:hint] && write_concern && !write_concern.acknowledged?
                raise Error::UnsupportedOption.hint_error(unacknowledged_write: true)
              end

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            write_with_retry(write_concern, context: context) do |connection, txn_num, context|
              gte_4_4 = connection.server.description.server_version_gte?('4.4')
              if !gte_4_4 && opts[:hint] && write_concern && !write_concern.acknowledged?
                raise Error::UnsupportedOption.hint_error(unacknowledged_write: true)
              end

• Read up
  Read up

Method create has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def create(opts = {})
      # Passing read options to create command causes it to break.
      # Filter the read options out. Session is also excluded here as it gets
      # used by the call to with_session and should not be part of the
      # operation. If it gets passed to the operation it would fail BSON

Method update_rs_with_primary_from_member has 30 lines of code (exceeds 25 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}); " +