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

Open

        def count(opts = {})
          opts = @options.merge(opts) unless Mongo.broken_view_options
          cmd = { :count => collection.name, :query => filter }
          cmd[:skip] = opts[:skip] if opts[:skip]
          cmd[:hint] = opts[:hint] if opts[:hint]

• Read up
  Read up

Method select! has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

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

• Read up
  Read up

Method end_session has a Cognitive Complexity of 9 (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 retry_write has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def retry_write(original_error, txn_num, context:, failed_server: nil, &block)
        context&.check_timeout!

        session = context.session

• Read up
  Read up

Method each has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def each
      if @cached_docs
        @cached_docs.each do |doc|
          yield doc
        end

• Read up
  Read up

Method serialize_fields has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

      def serialize_fields(buffer, max_bson_size = nil)
        fields.each do |field|
          value = instance_variable_get(field[:name])
          if field[:multi]
            value.each do |item|

• Read up
  Read up

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

Open

        def initialize(command_name, database_name, address, request_id,
          operation_id, reply, duration, started_event:,
          server_connection_id: nil, service_id: nil

Method setopt_crypto_hooks has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def self.setopt_crypto_hooks(handle,
        aes_encrypt_cb, aes_decrypt_cb, random_cb,
        hmac_sha_512_cb, hmac_sha_256_cb, hmac_hash_cb

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

Open

    def set_server_list(server_address_strs)
      @sdam_flow_lock.synchronize do
        # If one of the new addresses is not in the current servers list,
        # add it to the servers list.
        server_address_strs.each do |address_str|

• Read up
  Read up

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

Open

      def check_invariants
        return unless Lint.enabled?

        # Server summary calls pool summary which requires pool lock -> deadlock.
        # Obtain the server summary ahead of time.

• Read up
  Read up

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

Open

        def self.generate(address, operation_id, payload, message,
          failure, duration, started_event:, server_connection_id: nil,
          service_id: nil

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

Open

      def summarize_perf_data(data)
        puts '===== Performance Results ====='
        data.each do |item|
          puts format('%s : %4.4g', item['info']['test_name'], item['metrics'][0]['value'])
          next unless item['metrics'].length > 1

• Read up
  Read up

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

Open

    def read_without_timeout(length, socket_timeout = nil)
      map_exceptions do
        String.new.tap do |data|
          while data.length < length
            chunk = read_from_socket(length - data.length, socket_timeout: socket_timeout)

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

        def initialize(command_name, database_name, address, request_id,
          operation_id, command, socket_object_id: nil, connection_id: nil,
          connection_generation: nil, server_connection_id: nil,
          service_id: nil

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

Open

      def stop!
        @lock.synchronize do
          @stop_requested = true
          if @connection
            # Interrupt any in-progress exhausted hello reads by

• Read up
  Read up

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

Open

      def command_failed(failure, address, operation_id, payload, message, duration,
        started_event:, server_connection_id: nil, service_id: nil

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

Open

      def set_compressor!(reply)
        server_compressors = reply['compression']

        if options[:compressors]
          if intersection = (server_compressors & options[:compressors])

• Read up
  Read up

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

Open

      def check_bidi!(out)
        if out.each_char.any? { |c| table_contains?(Tables::C8, c) }
          raise Mongo::Error::FailedStringPrepValidation.new(Error::FailedStringPrepValidation::INVALID_BIDIRECTIONAL)
        end

• Read up
  Read up

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

Open

      def do_work
        @lock.synchronize do
          return if @stop_requested
        end

• Read up
  Read up