class AwsSns

Public Instance Methods

run_hook(ctx) click to toggle source
# File lib/oxidized/hook/awssns.rb, line 9
def run_hook(ctx)
  sns = Aws::SNS::Resource.new(region: cfg.region)
  topic = sns.topic(cfg.topic_arn)
  message = {
    event: ctx.event.to_s
  }
  if ctx.node
    message.merge!(
      group: ctx.node.group.to_s,
      model: ctx.node.model.class.name.to_s.downcase,
      node:  ctx.node.name.to_s
    )
  end
  topic.publish(
    message: message.to_json
  )
end
validate_cfg!() click to toggle source
# File lib/oxidized/hook/awssns.rb, line 4
def validate_cfg!
  raise KeyError, 'hook.region is required' unless cfg.has_key?('region')
  raise KeyError, 'hook.topic_arn is required' unless cfg.has_key?('topic_arn')
end