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

Open

    def decode_token(auth_token)
      return unless token_format_valid?(auth_token)

      if symmetric_key
        decode_token_with_symmetric_key(auth_token)

• Read up
  Read up

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

Open

        def image_layers
          return [] unless @config.get(:diego, :enable_declarative_asset_downloads)

          lifecycle_bundle_key = :"buildpack/#{@stack}"
          lifecycle_bundle = @config.get(:diego, :lifecycle_bundles)[lifecycle_bundle_key]

• Read up
  Read up

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

Open

      def fetch(klass, message, omniscient: false, readable_orgs_query: nil, readable_spaces_query: nil, eager_loaded_associations: [])
        # The base dataset for the given model; other tables might be joined later on for filtering,
        # but we are only interested in the columns from the base table.
        dataset = klass.dataset.select_all(klass.table_name)

• Read up
  Read up

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

Open

    def validate_process(process)
      raise CloudController::Errors::ApiError.new_from_details('DockerDisabled') if process.docker? && FeatureFlag.disabled?(:diego_docker)

      raise CloudController::Errors::ApiError.new_from_details('AppPackageInvalid', 'The app package hash is empty') if process.package_hash.blank?

• Read up
  Read up

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

Open

      def filter(message, dataset)
        dataset = dataset.where(type: message.types) if message.requested?(:types)

        if message.requested?(:target_guids)
          dataset = if message.exclude_target_guids?

• Read up
  Read up

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

Open

      def filter(message, dataset, klass)
        dataset = dataset.where { Sequel[:service_plans][:active] =~ message.available? } if message.requested?(:available)

        dataset = dataset.where { Sequel[:service_plans][:name] =~ message.names } if message.requested?(:names)

• Read up
  Read up

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

Open

    def format(validation_errors)
      message = "\n"
      validation_errors.messages.each { |e| message += "#{e}\n" }
      validation_errors.nested_errors.each do |service, service_errors|
        next if service_errors.empty?

• Read up
  Read up

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

Open

  def String(name, opts={})
    if opts[:case_insensitive]
      raise Error.new('DB adapter does not support case insensitive strings') unless @db.respond_to?(:case_insensitive_string_column_type)

      column(

• Read up
  Read up

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

Open

    def validate!
      validate_string!(:broker_provided_id, broker_provided_id, required: true)
      validate_string!(:name, name, required: true)
      validate_description!(:description, description, required: true)
      validate_hash!(:metadata, metadata) if metadata

• Read up
  Read up

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

Open

    def with_request_error_handling(_source_guid)
      tries ||= 3
      yield
    rescue StandardError => e
      raise CloudController::Errors::ApiError.new_from_details('ServiceUnavailable', 'Connection to Log Cache timed out') if e.is_a?(GRPC::DeadlineExceeded)

• Read up
  Read up

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

Open

  def run
    starts.each_with_index do |block, index|
      thread = Thread.start do
        sleep 0.01
        block.call

• Read up
  Read up

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

Open

      def on_send(node)
        return unless node.send_type?

        if node.children[1] == :require
          @requires << node.child_nodes[0].children[0]

• Read up
  Read up

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

Open

  def instrument(target, method_name, before: nil, after: nil, &block)
    example.allow(target).
      to example.receive(method_name).and_wrap_original do |original_method, *args, **kwargs, &method_block|
      result = nil
      if before

• Read up
  Read up

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

Open

  def step(message, &block)
    full_message = "[#{Thread.current.name}] #{message}"
    puts("expecting #{full_message}") if debug

    retries = 0

• Read up
  Read up

Avoid too many return statements within this function.

Open

    if (pivotElem === elem) return pivot

Avoid too many return statements within this method.

Open

    return if verify_ports

Avoid too many return statements within this method.

Open

      return MetadataError.error('key cannot be empty string') unless valid_key_presence?(name)

Avoid too many return statements within this method.

Open

      return false unless has_valid_optional_binding_name(service)

Avoid too many return statements within this method.

Open

      return MetadataError.error("prefix 'cloudfoundry.org' is reserved") unless is_not_reserved

Avoid too many return statements within this method.

Open

      return MetadataError.error("'#{name[0...8]}...' is greater than #{MetadataValidatorHelper::MAX_METADATA_KEY_SIZE} characters") unless valid_size?(name)