From 57e29a719e10cffbf93a72bfe021c87834486425 Mon Sep 17 00:00:00 2001
From: Theo Schlossnagle <postwait@users.noreply.github.com>
Date: Tue, 4 Oct 2016 11:16:56 -0400
Subject: [PATCH] Add Sparkpost reporting support

!sparkpost <email> to get a report of attempted deliveries and results to a specific email address.
---
 src/scripts/sparkpost.coffee | 55 ++++++++++++++++++++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100644 src/scripts/sparkpost.coffee

diff --git a/src/scripts/sparkpost.coffee b/src/scripts/sparkpost.coffee
new file mode 100644
index 000000000..4838af7de
--- /dev/null
+++ b/src/scripts/sparkpost.coffee
@@ -0,0 +1,55 @@
+# Description:
+#   interacts with the Sparkpost reporting API.
+#
+# Dependencies:
+#   None
+#
+# Configuration:
+#   HUBOT_SPARKPOST_API_TOKEN your API token with reporting privileges
+#   HUBOT_SPARKPOST_TIMEZONE the timezone (default America/New_York)
+#
+# Commands:
+#   !sparkpost <email>
+#
+# Notes:
+#
+# Author:
+#   postwait
+
+env = process.env
+
+tz = if env.HUBOT_SPARKPOST_TIMEZONE then env.HUBOT_SPARKPOST_TIMEZONE else "America/New_York"
+api_url = "https://api.sparkpost.com/api/v1/message-events?timezone=#{tz}&recipients="
+api_reporting_token = env.HUBOT_SPARKPOST_API_TOKEN
+
+tssimple = (a) ->
+  a.replace("T", " ").replace(".000", " (") + ")"
+
+module.exports = (robot) ->
+  robot.hear /!sparkpost\s+(.*)$/i, (res) ->
+    if res.match[1] == 'help'
+      res.send "!sparkpost <email> -> show event logs involving the specified email address\n"
+      return
+    robot.http(api_url + res.match[1].toLowerCase())
+        .header('Authorization', api_reporting_token)
+        .header('Accept', 'application/json')
+        .get() (err, httpres, body) ->
+          if err
+            res.send "Encountered an error :( #{err}"
+            return
+
+          data = JSON.parse(body)
+          out = (i) ->
+            type = i.type
+            tsstr = tssimple(i.timestamp)
+            if i.reason
+              type = "#{type} '#{i.reason}'"
+            return "[#{tsstr}] (#{type} of #{i.template_id}) to #{i.raw_rcpt_to} \"#{i.subject}\""
+          if (! data.results?)
+            res.send "No results returned: #{body}"
+            return
+          if data.results.length == 0
+            res.send "No logs for #{ res.match[1] }"
+            return
+          payload = (out(d) for d in data.results.reverse()).join("\n")
+          res.send "Logs for #{ res.match[1] }\n#{payload}"