aboutsummaryrefslogtreecommitdiff
path: root/lib/mauve/notifiers/sms_aql.rb
blob: 77cd012a3908c662695972f0b1aa86a9c0d901b6 (plain)
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
require 'mauve/notifiers/debug'
require 'cgi'

module Mauve
  module Notifiers
    module Sms
      
      require 'net/https'

      # Simple SMS-sending wrapper.  Use like so:
      # 
      #   aql = Mauve::Notifiers::Sms::AQLGateway.new(username, password)
      #   aql.send_sms(to_number="077711234567",
      #                from_number="0190412345678",
      #                message="This is my message!")
      class AQLGateway
        GATEWAY = "https://gw1.aql.com/sms/sms_gw.php"

        def initialize(username, password)
          @username = username
          @password = password
        end

        def send_sms(destination, from, message, flash=0)
          uri = URI.parse(GATEWAY)

          opts_string = {
            :username => @username,
            :password => @password,
            :destination => destination,
            :message => message,
            :originator => @from,
            :flash => flash
          }.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
      end # class AQLGateway


      class AQL

        attr_writer :username, :password, :from
        attr_reader :name

        def initialize(name)
          @name = name
        end

        def send_alert(destination, alert, all_alerts, conditions = {})
          to = normalize_number(destination)
          msg = prepare_message(destination, alert, all_alerts, conditions)
          AQLGateway.new(@username, @password).send_sms(to, @from, msg)
        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