module Jets::Job::Dsl::RuleEvent

def cron(expression, props={})
  schedule_job("cron(#{expression})", props)
end

def event_pattern(props)
  puts "DEPRECATED: events_rule. Instead use rule_event. The events_rule will be removed in the future.  Pausing for 5 seconds".color(:yellow)
  puts caller[0]
  sleep 5
  rule_event(props)
end

def events_rule(props)
  puts "DEPRECATED: events_rule. Instead use rule_event. The events_rule will be removed in the future.  Pausing for 5 seconds".color(:yellow)
  puts caller[0]
  sleep 5
  rule_event(props)
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

def rate(expression, props={})
  schedule_job("rate(#{expression})", props)
end

def rule_description
  self.rule_counter += 1
  "#{self.name} event rule #{rule_counter}"
end

def rule_event(props={})
  if props.key?(:detail)
    description = props.key?(:description) ? props.delete(:description) : rule_description
    rule_props = { event_pattern: props, description: description }
  else # if props.key?(:event_pattern)
    props[:description] ||= rule_description
    rule_props = props
  end
  with_fresh_properties(multiple_resources: false) do
    associated_properties(rule_props) # TODO: consider getting rid of @associated_properties concept
    resource(events_rule_definition) # add associated resource immediately
  end
end

def schedule_job(expression, props={})
  props = props.merge(schedule_expression: expression)
  rule_event(props)
end