Method set_crypto_hooks has 89 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def set_crypto_hooks
        @aes_encrypt = Proc.new do |_, key_binary_p, iv_binary_p, input_binary_p,
          output_binary_p, response_length_p, status_p|
          do_aes(
            key_binary_p,

Class Cursor has 29 methods (exceeds 20 allowed). Consider refactoring.

Open

  class Cursor
    extend Forwardable
    include Enumerable
    include Retryable

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

Open

    def initialize(seeds, monitoring, options = Options::Redacted.new)
      if seeds.nil?
        raise ArgumentError, 'Seeds cannot be nil'
      end

Method change_doc has a Cognitive Complexity of 24 (exceeds 5 allowed). Consider refactoring.

Open

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

• Read up
  Read up

File uri.rb has 308 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Mongo

  # The URI class provides a way for users to parse the MongoDB uri as
  # defined in the connection string format spec.
  #

File writable.rb has 301 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Mongo
  class Collection
    class View

      # Defines write related behavior for collection view.

Method server_description_changed has 80 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def server_description_changed
      @previous_server_descriptions = servers_list.map do |server|
        [server.address.to_s, server.description]
      end

Class Result has 27 methods (exceeds 20 allowed). Consider refactoring.

Open

    class Result
      extend Forwardable
      include Enumerable

      # The field name for the cursor document in an aggregation.

Method with_transaction has 78 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def with_transaction(options=nil)
      # Non-configurable 120 second timeout for the entire operation
      deadline = Utils.monotonic_time + 120
      transaction_in_progress = false
      loop do

Method parse! has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    def parse!(remaining)
      hosts_and_db, options = remaining.split('?', 2)
      if options && options.index('?')
        raise_invalid_error!("Options contain an unescaped question mark (?), or the database name contains a question mark and was not escaped")
      end

• Read up
  Read up

Method estimated_document_count has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

        def estimated_document_count(opts = {})
          unless view.filter.empty?
            raise ArgumentError, "Cannot call estimated_document_count when querying with a filter"
          end

• Read up
  Read up

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

Open

      def initialize(options)
        Crypt.validate_ffi!
        # Note that this call may eventually, via other method invocations,
        # create additional clients which have to be cleaned up.
        @options = set_default_options(options).freeze

• Read up
  Read up

File description.rb has 295 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Mongo
  class Server

    # Represents a description of the server, populated by the result of the
    # hello command.

Class ScramConversationBase has 26 methods (exceeds 20 allowed). Consider refactoring.

Open

    class ScramConversationBase < SaslConversationBase

      # The minimum iteration count for SCRAM-SHA-1 and SCRAM-SHA-256.
      MIN_ITER_COUNT = 4096

Method commit_transaction has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    def commit_transaction(options=nil)
      QueryCache.clear
      check_if_ended!
      check_if_no_transaction!

• Read up
  Read up

Method validate_uri_options! has 72 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def validate_uri_options!
      # The URI options spec requires that we raise an error if there are conflicting values of
      # 'tls' and 'ssl'. In order to fulfill this, we parse the values of each instance into an
      # array; assuming all values in the array are the same, we replace the array with that value.
      unless uri_options[:ssl].nil? || uri_options[:ssl].empty?

Method read_from_socket has 70 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def read_from_socket(length, timeout: nil)
      # Just in case
      if length == 0
        return ''.force_encoding('BINARY')
      end

Method run_sdam_flow has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

    def run_sdam_flow(previous_desc, updated_desc, options = {})
      if load_balanced?
        if updated_desc.config.empty?
          unless options[:keep_connection_pool]
            servers_list.each do |server|

• Read up
  Read up

Method initial has a Cognitive Complexity of 20 (exceeds 5 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}"

• Read up
  Read up

Method kill_cursors has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

      def kill_cursors
        # TODO optimize this to batch kill cursor operations for the same
        # server/database/collection instead of killing each cursor
        # individually.
        loop do

• Read up
  Read up