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

Open

        def change_doc
          { fullDocument: ( @options[:full_document] || FULL_DOCUMENT_DEFAULT ) }.tap do |doc|
            if resuming?
              # We have a resume token once we retrieved any documents.
              # However, if the first getMore fails and the user didn't pass

• Read up
  Read up

Method select_server has 71 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def select_server(cluster, ping = nil)
        if cluster.replica_set?
          validate_max_staleness_value_early!
        end
        if cluster.addresses.empty?

File client.rb has 280 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Mongo

  # The client is the entry point to the driver and is the main object that
  # will be interacted with.
  #

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

Open

  class Cursor
    extend Forwardable
    include Enumerable
    include Retryable

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

Open

    class Result
      extend Forwardable
      include Enumerable

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

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

Open

    def initialize(seeds, monitoring, options = Options::Redacted.new)
      if options[:monitoring_io] != false && !options[:server_selection_semaphore]
        raise ArgumentError, 'Need server selection semaphore'
      end

File cluster.rb has 269 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'mongo/cluster/topology'
require 'mongo/cluster/reapers/socket_reaper'
require 'mongo/cluster/reapers/cursor_reaper'
require 'mongo/cluster/periodic_executor'

Method read_from_socket has a Cognitive Complexity of 18 (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 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)
      raise_invalid_error!(INVALID_SCHEME) unless parsed_scheme == scheme

• Read up
  Read up

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

Open

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

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

Open

      class MapReduce
        extend Forwardable
        include Enumerable
        include Immutable
        include Loggable

Method commit_transaction has 53 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def commit_transaction(options=nil)
      check_if_ended!
      check_if_no_transaction!

      if within_states?(TRANSACTION_ABORTED_STATE)

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

Open

    def initialize(seeds, monitoring, options = Options::Redacted.new)
      if options[:monitoring_io] != false && !options[:server_selection_semaphore]
        raise ArgumentError, 'Need server selection semaphore'
      end

• Read up
  Read up

Method parse_servers! has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    def parse_servers!(string)
      raise_invalid_error!(INVALID_HOST) unless string.size > 0
      string.split(HOST_DELIM).reduce([]) do |servers, host|
        if host[0] == '['
          if host.index(']:')

• Read up
  Read up

Method write_with_retry has a Cognitive Complexity of 16 (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

File connection_pool.rb has 252 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Mongo
  class Server

    # Represents a connection pool for server connections.
    #

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).

Method update_rs_from_primary has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def update_rs_from_primary
      if topology.replica_set_name.nil?
        @topology = Topology::ReplicaSetWithPrimary.new(
          topology.options.merge(replica_set_name: updated_desc.replica_set_name),
          topology.monitoring, self)

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

Open

        def initialize(options, monitoring, cluster)
          options = validate_options(options, cluster)

          @options = options
          @monitoring = monitoring

• Read up
  Read up

Method normalized? has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

  def self.normalized?(string, form = :nfc)
    encoding = string.encoding
    case encoding
    when Encoding::UTF_8
      case form

• Read up
  Read up