lib/jets/job/dsl.rb in jets-1.8.2 vs lib/jets/job/dsl.rb in jets-1.8.3

@@ -6,95 +6,29 @@
 #
 #   default_associated_resource_definition
 #
 module Jets::Job::Dsl
   extend ActiveSupport::Concern
+  autoload :CloudwatchEvent, "jets/job/dsl/cloudwatch_event"
   autoload :EventSourceMapping, "jets/job/dsl/event_source_mapping" # base for sqs_event, etc
+  autoload :IotEvent, "jets/job/dsl/iot_event"
+  autoload :LogEvent, "jets/job/dsl/log_event"
   autoload :S3Event, "jets/job/dsl/s3_event"
   autoload :SnsEvent, "jets/job/dsl/sns_event"
   autoload :SqsEvent, "jets/job/dsl/sqs_event"
 
   included do
     class << self
+      include CloudwatchEvent
       include EventSourceMapping
+      include IotEvent
+      include LogEvent
       include S3Event
       include SnsEvent
       include SqsEvent
 
-      # Public: Creates CloudWatch Event Rule
-      #
-      # expression - The rate expression.
-      #
-      # Examples
-      #
-      #   rate("10 minutes")
-      #   rate("10 minutes", description: "Hard job")
-      #
-      def rate(expression, props={})
-        schedule_job("rate(#{expression})", props)
-      end
-
-      # Public: Creates CloudWatch Event Rule
-      #
-      # expression - The cron expression.
-      #
-      # Examples
-      #
-      #   cron("0 */12 * * ? *")
-      #   cron("0 */12 * * ? *", description: "Hard job")
-      #
-      def cron(expression, props={})
-        schedule_job("cron(#{expression})", props)
-      end
-
-      def schedule_job(expression, props={})
-        with_fresh_properties(multiple_resources: false) do
-          props = props.merge(schedule_expression: expression)
-          associated_properties(props)
-          resource(events_rule_definition) # add associated resource immediately
-        end
-      end
-
-      def event_pattern(details={}, props={})
-        with_fresh_properties(multiple_resources: false) do
-          props = props.merge(event_pattern: details)
-          associated_properties(props)
-          resource(events_rule_definition) # add associated resource immediately
-        end
-        add_descriptions # useful: generic description in the Event Rule console
-      end
-
-      def events_rule(props={})
-        with_fresh_properties(multiple_resources: false) do
-          associated_properties(props)
-          resource(events_rule_definition) # add associated resource immediately
-        end
-      end
-
-      # Works with eager definitions
-      def add_descriptions
-        numbered_resources = []
-        n = 1
-        @associated_resources.map do |associated|
-          # definition = associated.definition
-          # puts "associated #{associated.inspect}"
-          # puts "definition #{definition.inspect}"
-
-          # logical_id = definition.keys.first
-          # attributes = definition.values.first
-
-          logical_id = associated.logical_id
-          attributes = associated.attributes
-
-          attributes[:properties][:description] ||= "#{self.name} Event Rule #{n}"
-          new_definition = { "#{logical_id}" => attributes }
-          numbered_resources << Jets::Resource::Associated.new(new_definition)
-          n += 1
-        end
-        @associated_resources = numbered_resources
-      end
-
+      # Need to be in here
       ASSOCIATED_PROPERTIES = %W[
         description
         state
         schedule_expression
       ]
@@ -103,12 +37,8 @@
 
       def default_associated_resource_definition(meth)
         events_rule_definition
       end
 
-      def events_rule_definition
-        resource = Jets::Resource::Events::Rule.new(associated_properties)
-        resource.definition # returns a definition to be added by associated_resources
-      end
     end
   end
 end