Contents

require 'aws-sdk'

class AwsSns < Oxidized::Hook
  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

  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
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
oxidized-0.25.1	lib/oxidized/hook/awssns.rb
oxidized-0.25.0	lib/oxidized/hook/awssns.rb
oxidized-0.24.0	lib/oxidized/hook/awssns.rb
oxidized-0.23.0	lib/oxidized/hook/awssns.rb
oxidized-0.22.0	lib/oxidized/hook/awssns.rb