Contents

module Propono
  class QueueSubscription

    include Sns
    include Sqs

    attr_reader :topic_arn, :queue_name, :queue, :failed_queue, :corrupt_queue, :slow_queue

    def self.create(topic_id, options = {})
      new(topic_id, options).tap do |subscription|
        subscription.create
      end
    end

    def initialize(topic_id, options = {})
      @topic_id = topic_id
      @suffixed_topic_id = "#{topic_id}#{Propono.config.queue_suffix}"
      @suffixed_slow_topic_id = "#{topic_id}#{Propono.config.queue_suffix}-slow"
      @queue_name = "#{Propono.config.application_name.gsub(" ", "_")}-#{@suffixed_topic_id}"
    end

    def create
      raise ProponoError.new("topic_id is nil") unless @topic_id
      @topic = TopicCreator.find_or_create(@suffixed_topic_id)
      @queue = QueueCreator.find_or_create(queue_name)
      @failed_queue = QueueCreator.find_or_create("#{queue_name}-failed")
      @corrupt_queue = QueueCreator.find_or_create("#{queue_name}-corrupt")
      sns.subscribe(@topic.arn, @queue.arn, 'sqs')
      sqs.set_queue_attributes(@queue.url, "Policy", generate_policy(@queue, @topic))

      @slow_queue = QueueCreator.find_or_create("#{queue_name}-slow")
      @slow_topic = TopicCreator.find_or_create(@suffixed_slow_topic_id)
      sns.subscribe(@slow_topic.arn, @slow_queue.arn, 'sqs')
      sqs.set_queue_attributes(@slow_queue.url, "Policy", generate_policy(@slow_queue, @slow_topic))
    end

    private

    def generate_policy(queue, topic)
      <<-EOS
{
  "Version": "2008-10-17",
  "Id": "#{queue.arn}/SQSDefaultPolicy",
  "Statement": [
    {
      "Sid": "#{queue.arn}-Sid",
      "Effect": "Allow",
      "Principal": {
        "AWS": "*"
      },
      "Action": "SQS:*",
      "Resource": "#{queue.arn}",
      "Condition": {
        "StringEquals": {
          "aws:SourceArn": "#{topic.arn}"
        }
      }
    }
  ]
}
      EOS
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
propono-1.7.0	lib/propono/components/queue_subscription.rb
propono-1.6.0	lib/propono/components/queue_subscription.rb
propono-1.5.0	lib/propono/components/queue_subscription.rb
propono-1.4.0	lib/propono/components/queue_subscription.rb
propono-1.3.0	lib/propono/components/queue_subscription.rb
propono-1.2.0	lib/propono/components/queue_subscription.rb