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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
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 = " * "+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 += "-- \n"+@signature
m.to_s
end
include Debug
end
end
end
end
|
