repeat_until

in qa/qa/support/repeater.rb [13:83]
58 lines of code
21 McCabe index (conditional complexity)

      def repeat_until(
        max_attempts: nil,
        max_duration: nil,
        reload_page: nil,
        sleep_interval: 0,
        raise_on_failure: true,
        retry_on_exception: false,
        log: true,
        message: nil
      )
        attempts = 0
        start = Time.now

        begin
          while remaining_attempts?(attempts, max_attempts) && remaining_time?(start, max_duration)
            
            if log && attempts == 1
              msg = ["Retrying action with:"]
              msg << "max_attempts: #{max_attempts};" if max_attempts
              msg << "max_duration: #{max_duration};" if max_duration
              msg << "reload_page: #{reload_page};" if reload_page
              msg << "sleep_interval: #{sleep_interval};"
              msg << "raise_on_failure: #{raise_on_failure};"
              msg << "retry_on_exception: #{retry_on_exception}"

              QA::Runtime::Logger.debug(msg.join(' '))
            end

            if log && max_attempts && attempts > 0
              QA::Runtime::Logger.debug("Attempt number #{attempts + 1}".bg(:yellow).black)
            end

            result = yield
            if result
              log_completion(log, attempts)
              return result
            end

            sleep_and_reload_if_needed(sleep_interval, reload_page)
            attempts += 1
          end
        rescue StandardError, RSpec::Expectations::ExpectationNotMetError => e
          raise unless retry_on_exception

          attempts += 1
          raise unless remaining_attempts?(attempts, max_attempts) && remaining_time?(start, max_duration)

          QA::Runtime::Logger.debug("Retry block rescued following error: #{e}, trying again...")
          sleep_and_reload_if_needed(sleep_interval, reload_page)
          retry
        end

        if raise_on_failure
          unless remaining_attempts?(attempts, max_attempts)
            raise(
              RetriesExceededError,
              "#{message || 'Retry'} failed after #{max_attempts} #{'attempt'.pluralize(max_attempts)}"
            )
          end

          raise(
            WaitExceededError,
            "#{message || 'Wait'} failed after #{max_duration} #{'second'.pluralize(max_duration)}"
          )
        end

        log_completion(log, attempts)

        false
      end