#pusher = Qfill::Pusher.new(
#  Qfill::Result.new( :name => "Best Results",
#                        :filter => filter3,
#                        :ratio => 0.5,
#                        :list_ratios => {
#                          "High List" => 0.4,
#                          "Medium List" => 0.2,
#                          "Low List" => 0.4
#                        }
#  ),
#  Qfill::Result.new( :name => "More Results",
#                        :ratio => 0.5,
#                        :list_ratios => {
#                          "High List" => 0.2,
#                          "Medium List" => 0.4,
#                          "Low List" => 0.4
#                        }
#  )
#)
#
#pusher = Qfill::Pusher.from_array_of_hashes([
#  { :name => "First Result",
#    :ratio => 0.125,
#    :filter => filter3,
#    :list_ratios => {
#      "High List" => 0.4,
#      "Medium List" => 0.2,
#      "Low List" => 0.4
#    }
#  },
#  { :name => "Second Result",
#    :ratio => 0.25 },
#  { :name => "Third Result",
#    :ratio => 0.125 },
#  { :name => "Fourth Result",
#    :ratio => 0.50 },
#])
#
# Pusher is made up of an array (called queues) of Result objects.
module Qfill
  class Pusher < Qfill::ListSet

    def initialize(*args)
      super(*args)
      with_ratio = self.queues.map {|x| x.ratio}.compact
      ratio_to_split = (1 - with_ratio.inject(0, :+))
      if ratio_to_split < 0
        raise ArgumentError, "#{self.class}: mismatched ratios for queues #{with_ratio.join(' + ')} must not total more than 1"
      end
      num_without_ratio = self.queues.length - with_ratio.length
      if num_without_ratio > 0 && ratio_to_split < 1
        equal_portion = ratio_to_split / num_without_ratio
        self.queues.each do |queue|
          if queue.ratio.nil?
            queue.tap do |q|
              q.ratio = equal_portion
            end
          end
        end
      end
    end

    def current_list
      self.queues[self.current_index]
    end

    def set_next_as_current!
      next_index = self.current_index + 1
      if (next_index) == self.queues.length
        # If we have iterated through all the queues, then we reset
        self.reset!
      else
        self.current_index = next_index
      end
    end

    def self.from_array_of_hashes(array_of_hashes = [])
      args = array_of_hashes.map do |hash|
        Qfill::Result.new(hash)
      end
      Qfill::Pusher.new(*args)
    end

  end
end