new version.

1 files changed, 138 insertions, 0 deletions

diff --git a/lib/mauve/notifiers/email.rb b/lib/mauve/notifiers/email.rb
new file mode 100644
index 0000000..c445e09
--- /dev/null
+++ b/lib/mauve/notifiers/email.rb
@@ -0,0 +1,138 @@
+require 'time'
+require 'net/smtp'
+require 'rmail'
+require 'mauve/notifiers/debug'
+
+module Mauve
+  module Notifiers
+    module Email
+    
+      
+      class Default        
+        attr_reader :name
+        attr :server, true
+        attr :port, true
+        attr :username, true
+        attr :password, true
+        attr :login_method, true
+        attr :from, true
+        attr :subject_prefix, true
+        attr :email_suffix, true
+        
+        def username=(username)
+          @login_method ||= :plain
+          @username = username
+        end
+        
+        def initialize(name)
+          @name = name
+          @server = '127.0.0.1'
+          @port = 25
+          @username = nil
+          @password = nil
+          @login_method = nil
+          @from = "mauve@localhost" 
+          @hostname = "localhost"
+          @signature = "This is an automatic mailing, please do not reply."
+          @subject_prefix = ""
+          @suppressed_changed = nil
+        end
+
+        def send_alert(destination, alert, all_alerts, conditions = nil)
+          message = prepare_message(destination, alert, all_alerts, conditions)
+          args  = [@server, @port]
+          args += [@username, @password, @login_method.to_sym] if @login_method
+          begin
+            Net::SMTP.start(*args) do |smtp|
+              smtp.send_message(message, @from, destination)
+            end
+          rescue Errno::ECONNREFUSED => e
+            @logger = Log4r::Logger.new "mauve::email_send_alert"
+            @logger.error("#{e.class}: #{e.message} raised. " +
+                          "args = #{args.inspect} "
+                         )
+            raise e
+          rescue => e
+            raise e
+          end
+        end
+        
+        protected
+        
+        def prepare_message(destination, alert, all_alerts, conditions = nil)
+          if conditions
+            @suppressed_changed = conditions[:suppressed_changed]
+          end
+          
+          other_alerts = all_alerts - [alert]
+          
+          m = RMail::Message.new
+          
+          m.header.subject = subject_prefix + 
+            case @suppressed_changed
+            when true
+              "Suppressing notifications (#{all_alerts.length} total)"
+            
+            else
+              alert.summary_one_line.to_s 
+          end
+          m.header.to = destination
+          m.header.from = @from
+          m.header.date = MauveTime.now
+
+          summary_formatted = ""          
+#          summary_formatted = "  * "+alert.summary_two_lines.join("\n  ")
+                    
+          case alert.update_type.to_sym
+            when :cleared
+              m.body = "An alert has been cleared:\n"+summary_formatted+"\n\n"
+            when :raised
+              m.body = "An alert has been raised:\n"+summary_formatted+"\n\n"
+            when :acknowledged
+              m.body = "An alert has been acknowledged by #{alert.acknowledged_by}:\n"+summary_formatted+"\n\n"
+            when :changed
+              m.body = "An alert has changed in nature:\n"+summary_formatted+"\n\n"
+            else
+              raise ArgumentError.new("Unknown update_type #{alert.update_type}")
+          end
+          
+          # FIXME: include alert.detail as multipart mime
+          ##Thread.abort_on_exception = true
+          m.body += "\n" + '-'*10 + " This is the detail field " + '-'*44 + "\n\n"
+          #m.body += alert.get_details()
+          #m.body += alert.get_details_plain_text()
+          m.body += "\n" + '-'*80 + "\n\n"
+          
+          if @suppressed_changed == true
+            m.body += <<-END
+IMPORTANT: I've been configured to suppress notification of individual changes
+to alerts until their rate decreases.  If you still need notification of evrey
+single alert, you must watch the web front-end instead.
+
+            END
+          elsif @suppressed_changed == false
+            m.body += "(Notifications have slowed down - you will now be notified of every change)\n\n"
+          end
+          
+          if other_alerts.empty?
+            m.body += (alert.update_type == :cleared ? "That was" : "This is")+
+              " currently the only alert outstanding\n\n"
+          else
+            m.body += other_alerts.length == 1 ? 
+              "There is currently one other alert outstanding:\n\n" :
+              "There are currently #{other_alerts.length} other alerts outstanding:\n\n"
+            
+#            other_alerts.each do |other|
+#              m.body += "  * "+other.summary_two_lines.join("\n  ")+"\n\n"
+#            end
+          end
+          
+          m.body += @email_suffix
+          
+          m.to_s
+        end
+        include Debug
+      end
+    end
+  end
+end