dvmonroe/box-office

# frozen_string_literal: true

module Box
  module Office
    class Booth
      include Box::Office::Connection
      attr_reader :showing

      delegate :config, to: Box::Office

      def initialize(showing:)
        @showing = showing
      end

      def first_available_opening(conn)
        1.upto(showing.showings) do |idx|
          queue = find_queue(idx)

          Redlock::Client.new([conn]).lock("#{queue.name}-locked", 3000) do |locked|
            if locked && !Janitor.locked?(queue.name) && queue.length < showing.capacity
              yield queue
              return
            end
          end

          next if idx < showing.showings

          raise NoOpenings, "No available openings for #{showing.name}"
        end
      end

      private

      def find_queue(idx)
        showing.send(config.reserved, idx)
      end
    end
  end
end