Method select_server_impl has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

      private def select_server_impl(cluster, ping, session, write_aggregation, deprioritized, csot_timeout)

Method reject! has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def reject!
        if block_given?
          n_keys = keys.size
          keys.each do |key|
            delete(key) if yield(key, self[key])

• Read up
  Read up

Method add_uri_option has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def add_uri_option(key, value, uri_options)
        strategy = URI_OPTION_MAP[key.downcase]
        if strategy.nil?
          log_warn("Unsupported URI option '#{key}' on URI '#{@string}'. It will be ignored.")
          return

• Read up
  Read up

Method find_one_and_delete has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

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

• Read up
  Read up

Method delete_many has a Cognitive Complexity of 8 (exceeds 5 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

• Read up
  Read up

Method process has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def process(result)
      unless implicit?
        set_operation_time(result)
        if cluster_time_doc = result.cluster_time
          advance_cluster_time(cluster_time_doc)

• Read up
  Read up

Method commit_changes has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def commit_changes
      # The application-visible sequence of events should be as follows:
      #
      # 1. Description change for the server which we are processing;
      # 2. Topology change, if any;

• Read up
  Read up

Method delete_one has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

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

• Read up
  Read up

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

Open

    def initialize(view, result, server, options = {})
      unless result.is_a?(Operation::Result)
        raise ArgumentError, "Second argument must be a Mongo::Operation::Result: #{result.inspect}"
      end

• Read up
  Read up

Method selector has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

          module_function def selector(spec, connection)
            if spec[:collation] && !connection.features.collation_enabled?
              raise Error::UnsupportedCollation
            end

• Read up
  Read up

Method aggregate_write_errors has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

        def aggregate_write_errors(count)
          return unless @replies
          @replies.reduce(nil) do |errors, reply|
            if write_errors = reply.documents.first['writeErrors']
              wes = write_errors.collect do |we|

• Read up
  Read up

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

Open

      def initialize(user, used_mechanism: nil, message: nil,
        server: nil, code: nil
      )
        @code = code

• Read up
  Read up

Method apply_get_more_timeouts_to has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

        def apply_get_more_timeouts_to(spec, timeout_ms)
          view = context&.view
          return spec unless view

          if view.cursor_type == :tailable_await

• Read up
  Read up

Method build_message has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def build_message(connection, context)
        if self.session != context.session
          if self.session
            raise Error::InternalDriverError, "Operation session #{self.session.inspect} does not match context session #{context.session.inspect}"
          else

• Read up
  Read up

Method update_many has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def update_many(documents, connection, context, operation_id, session, txn_num)

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

Open

      def initialize(options)
        options = Options::Mapper.transform_keys_to_symbols(options)
        options = Options::Mapper.transform_values_to_strings(options).freeze

        if options[:w]

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

              if key.to_s.start_with?("$")
                if Mongo.validate_update_replace
                  raise Error::InvalidReplacementDocument.new(key: key)
                else
                  Error::InvalidReplacementDocument.warn(Logger.logger, key)

Method modern_write_with_retry has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def modern_write_with_retry(session, server, context, &block)
        txn_num = nil
        connection_succeeded = false

        server.with_connection(

• Read up
  Read up

Method do_aes has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def do_aes(key_binary_p, iv_binary_p, input_binary_p, output_binary_p,
        response_length_p, status_p, decrypt: false, mode: :CBC)

Method transform_server_api has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    module_function def transform_server_api(server_api)
      {}.tap do |doc|
        if version = server_api[:version]
          doc['apiVersion'] = version
        end

• Read up
  Read up