1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
require 'mauve/notifiers/debug'
require 'cgi'
module Mauve
module Notifiers
module Sms
require 'net/https'
class AQL
GATEWAY = "https://gw1.aql.com/sms/sms_gw.php"
attr_writer :username, :password, :from
attr_reader :name
def initialize(name)
@name = name
end
def send_alert(destination, alert, all_alerts, conditions = {})
uri = URI.parse(GATEWAY)
opts_string = {
:username => @username,
:password => @password,
:destination => normalize_number(destination),
:message => prepare_message(destination, alert, all_alerts, conditions),
:originator => @from,
:flash => @flash ? 1 : 0
}.map { |k,v| "#{k}=#{CGI::escape(v.to_s)}" }.join("&")
http = Net::HTTP.new(uri.host, uri.port)
if uri.port == 443
http.use_ssl = true
http.verify_mode = OpenSSL::SSL::VERIFY_NONE
end
response, data = http.post(uri.path, opts_string, {
'Content-Type' => 'application/x-www-form-urlencoded',
'Content-Length' => opts_string.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","sms.txt.erb")
txt = if File.exists?(template_file)
ERB.new(File.read(template_file)).result(binding).chomp
else
logger.error("Could not find sms.txt.erb template")
alert.to_s
end
end
def normalize_number(n)
n.split("").select { |s| (?0..?9).include?(s[0]) }.join.gsub(/^0/, "44")
end
end
end
end
end
|
