Method change_stream_resumable? has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def change_stream_resumable?
        if @result && @result.is_a?(Mongo::Operation::GetMore::Result)
          # CursorNotFound exceptions are always resumable because the server
          # is not aware of the cursor id, and thus cannot determine if
          # the cursor is a change stream and cannot add the

• Read up
  Read up

Method set_cert has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def set_cert(context, options)
        # Since we clear cert_text during processing, we need to examine
        # ssl_cert_object here to avoid considering it if we have also
        # processed the text.
        if options[:ssl_cert]

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

              if key.to_s.start_with?("$")
                if Mongo.validate_update_replace
                  raise Error::InvalidReplacementDocument.new(key: key)
                else
                  Error::InvalidReplacementDocument.warn(Logger.logger, key)

Method initialize has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def initialize(host, port, host_name, timeout, family, options = {})

Method delete_many has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def delete_many(documents, connection, context, operation_id, session, txn_num)

Method validate_address_str! has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

      def validate_address_str!(address_str)
        case address_str
        when /\A\[[\d:]+\](?::(\d+))?\z/
          # ipv6 with optional port
          if port_str = $1

• Read up
  Read up

Method socket has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def socket(socket_timeout, opts = {})
      opts = {
        connect_timeout: Server::CONNECT_TIMEOUT,
      }.update(options).update(Hash[opts.map { |k, v| [k.to_sym, v] }])

• Read up
  Read up

Method do_aes has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def do_aes(key_binary_p, iv_binary_p, input_binary_p, output_binary_p,
        response_length_p, status_p, decrypt: false, mode: :CBC)

Method initialize has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def initialize(address, cluster, monitoring, event_listeners, options = {})

Method command_completed has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def command_completed(result, address, operation_id, payload, duration,
        started_event:, server_connection_id: nil, service_id: nil

Method command_succeeded has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def command_succeeded(result, address, operation_id, payload, duration,
        started_event:, server_connection_id: nil, service_id: nil

Method generate has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

        def self.generate(address, operation_id, command_payload,
          reply_payload, duration, started_event:, server_connection_id: nil,
          service_id: nil

Method select_server_impl has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      private def select_server_impl(cluster, ping, session, write_aggregation, deprioritized)

Method create_encrypted_collection has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def create_encrypted_collection(database, coll_name, coll_opts, kms_provider, master_key)

Method initialize has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def initialize(host, port, timeout, family, options = {})

Method initialize has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def initialize(mongocrypt, io, master_key_document, key_alt_names, key_material)

Method initialize has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def initialize(host_name, cert, ca_cert, cert_store, **opts)

Method do_hmac_sha has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

      def do_hmac_sha(digest_name, key_binary_p, input_binary_p,
        output_binary_p, status_p)

Method generate_reply has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

        def self.generate_reply(command_payload, reply_payload)
          if reply_payload
            reply = reply_payload[:reply]
            if cursor = reply[:cursor]
              if !cursor.key?(Collection::NS)

• Read up
  Read up

Method handshake_document has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

      def handshake_document(app_metadata, speculative_auth_doc: nil, load_balancer: false, server_api: nil)
        serv_api = app_metadata.server_api || server_api
        document = if serv_api
                     HELLO_DOC.merge(Utils.transform_server_api(serv_api))
                   else

• Read up
  Read up