Contents

module CI
  module Queue
    class Static
      class << self
        def from_uri(uri, config)
          tests = uri.opaque.split(':').map { |t| CGI.unescape(t) }
          new(tests, config)
        end
      end

      attr_reader :progress, :total

      def initialize(tests, config)
        @queue = tests
        @config = config
        @progress = 0
        @total = tests.size
      end

      def minitest_reporters
        require 'minitest/reporters/queue_reporter'
        @minitest_reporters ||= [
          Minitest::Reporters::QueueReporter.new,
        ]
      end

      def supervisor
        raise NotImplementedError, "This type of queue can't be supervised"
      end

      def retry_queue
        self
      end

      def populate(tests, random: nil)
        @index = tests.map { |t| [t.id, t] }.to_h
        self
      end

      def populated?
        !!defined?(@index)
      end

      def to_a
        @queue.map { |i| index.fetch(i) }
      end

      def size
        @queue.size
      end

      def poll
        while test = @queue.shift
          yield index.fetch(test)
          @progress += 1
        end
      end

      def exhausted?
        @queue.empty?
      end

      def acknowledge(test)
        true
      end

      def requeue(test)
        test_key = test.id
        return false unless should_requeue?(test_key)
        requeues[test_key] += 1
        @queue.unshift(test_key)
        true
      end

      private

      attr_reader :index, :config

      def should_requeue?(key)
        requeues[key] < config.max_requeues && requeues.values.inject(0, :+) < config.global_max_requeues(total)
      end

      def requeues
        @requeues ||= Hash.new(0)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
ci-queue-0.10.1	lib/ci/queue/static.rb
ci-queue-0.10.0	lib/ci/queue/static.rb
ci-queue-0.9.2	lib/ci/queue/static.rb