File tables.rb has 3148 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Mongo
  module Auth
    module StringPrep
      # Contains character tables defined by RFC 3454 (string preparation).
      #

File tables.rb has 1161 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module UnicodeNormalize  # :nodoc:
  accents = "" \
    "[\u0300-\u034E\u0350-\u036F\u0483-\u0487\u0591-\u05BD\u05BF\u05C1\u05C2\u05C4\u05C5\u05C7" \
    "\u0610-\u061A\u064B-\u065F\u0670\u06D6-\u06DC\u06DF-\u06E4\u06E7\u06E8\u06EA-\u06ED\u0711" \
    "\u0730-\u074A\u07EB-\u07F3\u0816-\u0819\u081B-\u0823\u0825-\u0827\u0829-\u082D\u0859-\u085B\u08D4-\u08E1" \

Method select_server has a Cognitive Complexity of 74 (exceeds 5 allowed). Consider refactoring.

Open

      def select_server(cluster, ping = nil, session = nil)
        if cluster.topology.is_a?(Cluster::Topology::LoadBalanced)
          return cluster.servers.first
        end

• Read up
  Read up

File client.rb has 640 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.
  #

Method validate_options! has a Cognitive Complexity of 54 (exceeds 5 allowed). Consider refactoring.

Open

    def validate_options!(addresses = nil)
      if options[:write] && options[:write_concern] && options[:write] != options[:write_concern]
        raise ArgumentError, "If :write and :write_concern are both given, they must be identical: #{options.inspect}"
      end

• Read up
  Read up

File session.rb has 498 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'mongo/session/session_pool'
require 'mongo/session/server_session'

module Mongo

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

Open

require 'mongo/server/connection_pool/populator'

module Mongo
  class Server

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

• Read up
  Read up

File cluster.rb has 445 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'

Class Description has 48 methods (exceeds 20 allowed). Consider refactoring.

Open

    class Description

      # Constant for reading arbiter info from config.
      #
      # @since 2.0.0

Method check_out has a Cognitive Complexity of 43 (exceeds 5 allowed). Consider refactoring.

Open

      def check_out(service_id: nil)
        check_invariants

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

• Read up
  Read up

Method verify_one_responder has a Cognitive Complexity of 42 (exceeds 5 allowed). Consider refactoring.

Open

      def verify_one_responder(uri)
        original_uri = uri
        redirect_count = 0
        http_response = nil
        loop do

• Read up
  Read up

Method validate_new_options! has a Cognitive Complexity of 41 (exceeds 5 allowed). Consider refactoring.

Open

    def validate_new_options!(opts)
      return Options::Redacted.new unless opts
      if opts[:read_concern]
        # Raise an error for non user-settable options
        if opts[:read_concern][:after_cluster_time]

• Read up
  Read up

Class Session has 45 methods (exceeds 20 allowed). Consider refactoring.

Open

  class Session
    extend Forwardable
    include Retryable
    include Loggable
    include ClusterTime::Consumer

Method validate_uri_options! has a Cognitive Complexity of 40 (exceeds 5 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?

• Read up
  Read up

File binding.rb has 415 lines of code (exceeds 250 allowed). Consider refactoring.

Open

unless ENV['LIBMONGOCRYPT_PATH']
  # It seems that MRI maintains autoload configuration for a module until
  # that module is defined, but JRuby removes autoload configuration as soon
  # as the referenced file is attempted to be loaded, even if the module
  # never ends up being defined.

Class Client has 43 methods (exceeds 20 allowed). Consider refactoring.

Open

  class Client
    extend Forwardable
    include Loggable

    # The options that do not affect the behavior of a cluster and its

File sdam_flow.rb has 399 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 add_txn_opts! has a Cognitive Complexity of 36 (exceeds 5 allowed). Consider refactoring.

Open

    def add_txn_opts!(command, read)
      command.tap do |c|
        # The read concern should be added to any command that starts a transaction.
        if starting_transaction?
          # https://jira.mongodb.org/browse/SPEC-1161: transaction's

• Read up
  Read up

Method read_from_socket has a Cognitive Complexity of 35 (exceeds 5 allowed). Consider refactoring.

Open

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

• Read up
  Read up