Module: Jets::Job::Dsl::S3Event

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

Instance Method Summary collapse

Instance Method Details

#declare_s3_bucket_resources(bucket_name) ⇒ Object

Returns stack_name



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/jets/job/dsl/s3_event.rb', line 9

def declare_s3_bucket_resources(bucket_name)
  # If shared s3 bucket resources have already been declared.
  # We will not generate them again. However, we still need to always
  # add the depends_on declaration to ensure that the shared stack parameters
  # are properly passed to the nested child stack.
  stack_name = s3_events[bucket_name] # already registered
  if stack_name
    depends_on stack_name.underscore.to_sym, class_prefix: true # always add this
    return stack_name
  end

  # Create shared resources - one time
  stack_name = declare_shared_s3_event_resources(bucket_name)
  depends_on stack_name.underscore.to_sym, class_prefix: true # always add this
  self.s3_events[bucket_name] = stack_name # tracks buckets already set up
end

#declare_shared_s3_event_resources(bucket_name) ⇒ Object 



26
27
28
29
30
 
# File 'lib/jets/job/dsl/s3_event.rb', line 26

def declare_shared_s3_event_resources(bucket_name)
  s3_stack = Jets::Stack::S3Event.new(bucket_name)
  s3_stack.build_stack
  s3_stack.stack_name
end

#s3_event(bucket_name, props = {}) ⇒ Object 



3
4
5
6
 
# File 'lib/jets/job/dsl/s3_event.rb', line 3

def s3_event(bucket_name, props={})
  stack_name = declare_s3_bucket_resources(bucket_name) # only set up once per bucket
  declare_sns_subscription(topic_arn: "!Ref #{stack_name}SnsTopic") # set up subscription every time
end

#s3_events ⇒ Object 



32
33
34
 
# File 'lib/jets/job/dsl/s3_event.rb', line 32

def s3_events
  Jets::Job::Base.s3_events
end