Module: Jets::Job::Dsl::SqsEvent

Defined in:
lib/jets/job/dsl/sqs_event.rb

Instance Method Summary collapse

Instance Method Details

#declare_sqs_queue(props) ⇒ Object 



68
69
70
71
72
73
74
 
# File 'lib/jets/job/dsl/sqs_event.rb', line 68

def declare_sqs_queue(props)
  props ||= {} # since options.delete(:queue_properties) can be nil
  r = Jets::Cfn::Resource::Sqs::Queue.new(props)
  with_fresh_properties do
    resource(r.definition) # add associated resource immediately
  end
end

#default_sqs_iam_policy(queue_name_arn = '*') ⇒ Object 



87
88
89
90
91
92
93
94
95
 
# File 'lib/jets/job/dsl/sqs_event.rb', line 87

def default_sqs_iam_policy(queue_name_arn='*')
  {
    Action: ["sqs:ReceiveMessage",
             "sqs:DeleteMessage",
             "sqs:GetQueueAttributes"],
    Effect: "Allow",
    Resource: queue_name_arn,
  }
end

#full_sqs_queue_arn(queue_name) ⇒ Object

Expands simple queue name to full arn. Example:

hello-queue

To:

arn:aws:sqs:us-west-2:112233445566:hello-queue



81
82
83
84
85
 
# File 'lib/jets/job/dsl/sqs_event.rb', line 81

def full_sqs_queue_arn(queue_name)
  return queue_name if queue_name.include?("arn:aws:sqs")

  "arn:aws:sqs:#{Jets.aws.region}:#{Jets.aws.}:#{queue_name}"
end

#sqs_event(queue_name, options = {}) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/jets/job/dsl/sqs_event.rb', line 40

def sqs_event(queue_name, options={})
  if queue_name.to_s =~ /generate/
    queue_arn = "!GetAtt {namespace}SqsQueue.Arn"
    default_iam_policy = default_sqs_iam_policy('*') # Dont have access to full ARN on initial creation
    declare_sqs_queue(options.delete(:queue_properties)) # delete to avoid using them for event_source_mapping
  elsif queue_name.include?('!Ref') # reference shared resource
    queue_arn = queue_name
    default_iam_policy = default_sqs_iam_policy('*') # Dont have access to full ARN on initial creation
  else # existing queue: short name or full arn
    queue_arn = full_sqs_queue_arn(queue_name)
    default_iam_policy = default_sqs_iam_policy(queue_arn)
  end

  # Create iam policy allows access to queue
  iam_policy_option = [options.delete(:iam_policy)].compact.flatten
  user_iam_policy = [@iam_policy].compact.flatten
  iam_policy_props = iam_policy_option + user_iam_policy + [default_iam_policy]
  iam_policy(iam_policy_props)

  props = options # by this time options only has EventSourceMapping properties
  default = {
    EventSourceArn: queue_arn
  }
  props = default.merge(props)

  event_source_mapping(props)
end