File sdam_flow.rb has 319 lines of code (exceeds 250 allowed). Consider refactoring.

Open

class Mongo::Cluster
  # Handles SDAM flow for a server description changed event.
  #
  # Updates server descriptions, topology descriptions and publishes
  # SDAM events.

Method parse! has a Cognitive Complexity of 24 (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 read_from_socket has a Cognitive Complexity of 24 (exceeds 5 allowed). Consider refactoring.

Open

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

• Read up
  Read up

Method check_out has 83 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def check_out
        publish_cmap_event(
          Monitoring::Event::Cmap::ConnectionCheckOutStarted.new(@server.address)
        )

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

Open

    def server_description_changed
      unless update_server_descriptions
        # All of the transitions require that server whose updated_desc we are
        # processing is still in the cluster (i.e., was not removed as a result
        # of processing another response, potentially concurrently).

• Read up
  Read up

Method initialize has 77 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 with_transaction has 76 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

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

Open

  class Cursor
    extend Forwardable
    include Enumerable
    include Retryable

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

Open

  class Server
    extend Forwardable
    include Monitoring::Publishable
    include Event::Publisher

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

Open

    def commit_transaction(options=nil)
      check_if_ended!
      check_if_no_transaction!

      if within_states?(TRANSACTION_ABORTED_STATE)

• Read up
  Read up

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

Open

    class Result
      extend Forwardable
      include Enumerable

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

Method change_doc has a Cognitive Complexity of 20 (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

Class ConnectionPool has 24 methods (exceeds 20 allowed). Consider refactoring.

Open

    class ConnectionPool
      include Loggable
      include Monitoring::Publishable
      extend Forwardable

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

Open

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

• Read up
  Read up

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

Open

    def initialize(string, options = {})
      @string = string
      @options = options
      parsed_scheme, _, remaining = string.partition(SCHEME_DELIM)
      unless parsed_scheme == scheme

• Read up
  Read up

File selectable.rb has 267 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Mongo
  module ServerSelector

    # Provides common behavior for filtering a list of servers by server mode or tag set.
    #

Method write_with_retry has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def write_with_retry(session, write_concern, ending_transaction = false, &block)
      if ending_transaction && !session
        raise ArgumentError, 'Cannot end a transaction without a session'
      end

• Read up
  Read up

Method create_context has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

      def create_context(options)
        OpenSSL::SSL::SSLContext.new.tap do |context|
          if OpenSSL::SSL.const_defined?(:OP_NO_RENEGOTIATION)
            context.options = context.options | OpenSSL::SSL::OP_NO_RENEGOTIATION
          end

• Read up
  Read up

Class MapReduce has 21 methods (exceeds 20 allowed). Consider refactoring.

Open

      class MapReduce
        extend Forwardable
        include Enumerable
        include Immutable
        include Loggable

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

Open

    def server_description_changed
      unless update_server_descriptions
        # All of the transitions require that server whose updated_desc we are
        # processing is still in the cluster (i.e., was not removed as a result
        # of processing another response, potentially concurrently).