From 0e26ca4e877570b5ba02370768fcd758c4b03cc8 Mon Sep 17 00:00:00 2001
From: Nat Morris <nat@netflix.com>
Date: Sun, 4 Dec 2016 17:06:07 +0000
Subject: New hook: awssns - Publish messages to AWS SNS topics

---
 lib/oxidized/hook/awssns.rb | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)
 create mode 100644 lib/oxidized/hook/awssns.rb

(limited to 'lib/oxidized/hook/awssns.rb')

diff --git a/lib/oxidized/hook/awssns.rb b/lib/oxidized/hook/awssns.rb
new file mode 100644
index 0000000..dbc2d47
--- /dev/null
+++ b/lib/oxidized/hook/awssns.rb
@@ -0,0 +1,27 @@
+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
-- 
cgit v1.2.1