Method run_sdam_flow has 33 lines of code (exceeds 25 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|

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

Open

          def initialize(opts)
            @opts = opts
            return if empty?

            if opts[:access_token]

Method delete_one has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def delete_one(opts = {})
          with_session(opts) do |session|
            write_concern = if opts[:write_concern]
              WriteConcern.get(opts[:write_concern])
            else

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

Open

      def initialize(kms_providers, kms_tls_options, options={})
        # FFI::AutoPointer uses a custom release strategy to automatically free
        # the pointer once this object goes out of scope
        @mongocrypt = FFI::AutoPointer.new(
          Binding.mongocrypt_new,

Method publish_heartbeat has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def publish_heartbeat(server, awaited: false)
      if monitoring?
        started_event = Event::ServerHeartbeatStarted.new(
          server.address, awaited: awaited)
        started(SERVER_HEARTBEAT, started_event)

Method deliver has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def deliver(message, context, options = {})
        if Lint.enabled? && !@socket
          raise Error::LintError, "Trying to deliver a message over a disconnected connection (to #{address})"
        end
        buffer = serialize(message, context)

• Read up
  Read up

Method close_available_connections has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def close_available_connections(service_id)
        if @server.load_balancer? && service_id
          loop do
            conn = @available_connections.detect do |conn|
              conn.service_id == service_id &&

• Read up
  Read up

Method do_clear has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def do_clear(options = nil)
        check_invariants

        service_id = options && options[:service_id]

• Read up
  Read up

Method create_and_add_connection has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def create_and_add_connection
        connection = nil

        @lock.synchronize do
          if !closed? && @ready &&

• Read up
  Read up

Method validate_read! has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

    def validate_read!(option, opts)
      if option == :read && opts.has_key?(:read)
        read = opts[:read]
        # We could check if read is a Hash, but this would fail
        # for custom classes implementing key access ([]).

• Read up
  Read up

Method convert_limit_and_batch_size! has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

          module_function def convert_limit_and_batch_size!(command)
            if command[:limit] && command[:limit] < 0 &&
              command[:batchSize] && command[:batchSize] < 0
            then
              command[:limit] = command[:limit].abs

• Read up
  Read up

Method collections_info_spec has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def collections_info_spec(session, options = {})
        { selector: {
            listCollections: 1,
            cursor: batch_size ? { batchSize: batch_size } : {} },
          db_name: @database.name,

• Read up
  Read up

Method validate_update_documents! has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

        def validate_update_documents!(spec)
          if update = spec.is_a?(Array) ? spec&.first : spec
            if key = update.keys&.first
              unless key.to_s.start_with?("$")
                if Mongo.validate_update_replace

• Read up
  Read up

Method suppress_read_write_concern! has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

    def suppress_read_write_concern!(command)
      command.tap do |c|
        next unless in_transaction?

        c.delete(:readConcern) unless starting_transaction?

• Read up
  Read up

Method maybe_set_schema_map has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def maybe_set_schema_map(options)
        if !options[:schema_map] && !options[:schema_map_path]
          @schema_map = nil
        elsif options[:schema_map] && options[:schema_map_path]
          raise ArgumentError.new(

• Read up
  Read up

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

Open

      def initialize(flags, options, main_document, *sequences)
        if flags
          flags.each do |flag|
            unless KNOWN_FLAGS.key?(flag)
              raise ArgumentError, "Unknown flag: #{flag.inspect}"

• Read up
  Read up

Method set_algorithm_opts has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def set_algorithm_opts(options)
        Binding.ctx_setopt_algorithm(self, options[:algorithm])
        if %w(Indexed RangePreview).include?(options[:algorithm])
          if options[:contention_factor]
            Binding.ctx_setopt_contention_factor(self, options[:contention_factor])

• Read up
  Read up

Method get_records has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def get_records(hostname, srv_service_name=nil, srv_max_hosts=nil)
        query_name = record_prefix(srv_service_name) + hostname
        resources = @resolver.getresources(query_name, Resolv::DNS::Resource::IN::SRV)

        # Collect all of the records into a Result object, raising an error

• Read up
  Read up

Method get_connection has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def get_connection(pid, connection_global_id)
        if connection = next_available_connection(connection_global_id)
          unless valid_available_connection?(connection, pid, connection_global_id)
            return nil
          end

Method close has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def close
      @state_change_lock.synchronize do
        unless connecting? || connected?
          return nil
        end