require 'aws-sdk'
require 'alephant/logger'

module Alephant
  class Queue
    include ::Alephant::Logger

    attr_accessor :q

    def initialize(id)
      @sqs = AWS::SQS.new
      @q = @sqs.queues[id]

      unless @q.exists?
        @q = @sqs.queues.create(id)
        sleep_until_queue_exists
        logger.info("Queue.initialize: created queue with id #{id}")
      end

      logger.info("Queue.initialize: ended with id #{id}")
    end

    def sleep_until_queue_exists
      sleep 1 until @q.exists?
    end

    def poll(*args, &block)
      logger.info("Queue.poll: polling with arguments #{args}")
      @q.poll(*args, &block)
    end
  end
end