aboutsummaryrefslogtreecommitdiff
path: root/lib/mauve/notifiers
diff options
context:
space:
mode:
authorJames Hannah <jhannah@bytemark.co.uk>2017-01-26 10:28:14 +0000
committerJames Hannah <jhannah@bytemark.co.uk>2017-01-26 10:28:14 +0000
commit99eb81c4447f093f9e4b19a263ab8d1f5e8f8986 (patch)
tree06cab9cdbb0c34e4a1bf4fb4825721511ec0c9d8 /lib/mauve/notifiers
parent5c62ccc2858f8f8245cb6e8f7058c58de9363419 (diff)
Pushover supportpushover2
Based on the Hipchat notifier. API Reference: https://pushover.net/api
Diffstat (limited to 'lib/mauve/notifiers')
-rw-r--r--lib/mauve/notifiers/hipchat.rb1
-rw-r--r--lib/mauve/notifiers/pushover.rb114
-rw-r--r--lib/mauve/notifiers/templates/pushover.html.erb22
3 files changed, 136 insertions, 1 deletions
diff --git a/lib/mauve/notifiers/hipchat.rb b/lib/mauve/notifiers/hipchat.rb
index 7537bc5..dd549ac 100644
--- a/lib/mauve/notifiers/hipchat.rb
+++ b/lib/mauve/notifiers/hipchat.rb
@@ -42,7 +42,6 @@ module Mauve
"notify" => true,
}
-
uri = @gateway.dup
#
diff --git a/lib/mauve/notifiers/pushover.rb b/lib/mauve/notifiers/pushover.rb
new file mode 100644
index 0000000..39caaf6
--- /dev/null
+++ b/lib/mauve/notifiers/pushover.rb
@@ -0,0 +1,114 @@
+require 'mauve/notifiers/debug'
+
+module Mauve
+ module Notifiers
+ require 'net/https'
+ require 'json'
+ require 'cgi'
+ require 'uri'
+
+ class Pushover
+
+ attr_accessor :token
+ attr_reader :name
+
+ def initialize(name)
+ @name = name
+ end
+
+ def gateway
+ @gateway
+ end
+
+ def gateway=(uri)
+ @gateway = URI.parse(uri)
+ end
+
+ def send_alert(destination, alert, all_alerts, conditions = {})
+ msg = prepare_message(destination, alert, all_alerts, conditions)
+
+ priority = case alert.level
+ when :urgent
+ 1
+ when :normal
+ 0
+ else
+ -1
+ end
+
+ opts = {
+ "priority" => priority,
+ "message" => msg,
+ "url" => WebInterface.url_for(alert),
+ "url_title" => "View alert",
+ "html" => 1,
+ }
+
+ uri = @gateway.dup
+ uri.path = "/1/messages.json"
+
+ #
+ # If the destination is an email, it is a user
+ #
+ if destination =~ /@/
+ (device,user) = destination.split(/@/,2)
+ opts['device'] = device
+ opts['user'] = user
+ else
+ opts['user'] = user
+ end
+
+ uri.query = "auth_token="+CGI::escape(self.token)
+
+ http = Net::HTTP.new(uri.host, uri.port)
+
+ if uri.port == 443
+ http.use_ssl = true
+ http.verify_mode = OpenSSL::SSL::VERIFY_PEER
+ end
+
+ case alert.update_type
+ when "cleared"
+ opts['timestamp'] = alert.cleared_at
+ when "acknowledged"
+ opts['timestamp'] = alert.acknowledged_at
+ else
+ opts['timestamp'] = alert.raised_at
+ end
+
+ response, data = http.post(uri.request_uri, opts, {
+ 'Content-Type' => 'application/json',
+ 'Content-Length' => opts.length.to_s
+ })
+
+ if response.kind_of?(Net::HTTPSuccess)
+ #
+ # Woo -- return true!
+ #
+ true
+ else
+ false
+ end
+
+ end
+
+ protected
+
+ def prepare_message(destination, alert, all_alerts, conditions={})
+ was_suppressed = conditions[:was_suppressed] || false
+ will_suppress = conditions[:will_suppress] || false
+
+ template_file = File.join(File.dirname(__FILE__),"templates","pushover.html.erb")
+
+ txt = if File.exists?(template_file)
+ ERB.new(File.read(template_file)).result(binding).chomp
+ else
+ logger.error("Could not find #{template_file} template")
+ alert.to_s
+ end
+ end
+
+ end
+ end
+end
+
diff --git a/lib/mauve/notifiers/templates/pushover.html.erb b/lib/mauve/notifiers/templates/pushover.html.erb
new file mode 100644
index 0000000..4506c57
--- /dev/null
+++ b/lib/mauve/notifiers/templates/pushover.html.erb
@@ -0,0 +1,22 @@
+<a href="<%=WebInterface.url_for(alert)%>"><%= alert.id%>: <%= alert.update_type.upcase %></a> (<%= alert.level %>): <%
+case alert.update_type
+when "cleared"
+%><%= alert.cleared_at.to_s_relative %><%
+when "acknowledged"
+%><%= alert.acknowledged_at.to_s_relative %> by <%= alert.acknowledged_by %> until <%= alert.will_unacknowledge_at.to_s_human %><%
+else
+%><%= alert.raised_at.to_s_relative %><%
+end
+%>: <strong><%= alert.subject %></strong> <%= alert.summary %><%
+if alert.source != alert.subject
+%> -- from <%= alert.source %><%
+end
+%>.<%
+if defined? was_suppressed and defined? will_suppress
+ if was_suppressed and not will_suppress
+%><br /><em>Normal service for <%= alert.level %> alerts has resumed.</em><%
+ elsif will_suppress and not was_suppressed
+%><br /><em>Further <%= alert.level %> alerts suppressed until things calm down.</em><%
+ end
+end
+%>