5 use Digest::SHA1 qw(sha1_hex);
13 use vars qw($dbhost $dbname $dbuser $dbpass $dbport
14 $all_stat $fail_stat $change_stat $green_stat
18 require "$ENV{BFConfDir}/BuildFarmWeb.pl";
20 die "no dbname" unless $dbname;
21 die "no dbuser" unless $dbuser;
23 # don't use configged dbuser/dbpass
25 $dbuser=""; $dbpass="";
27 my $dsn="dbi:Pg:dbname=$dbname";
28 $dsn .= ";host=$dbhost" if $dbhost;
29 $dsn .= ";port=$dbport" if $dbport;
31 my $db = DBI->connect($dsn,$dbuser,$dbpass);
33 die $DBI::errstr unless $db;
35 my $clear_old = $db->do(q[
39 (SELECT name FROM buildsystems WHERE no_alerts)
43 my $sth = $db->prepare(q[
45 SELECT DISTINCT ON (sysname, branch)
47 extract(epoch from snapshot at time zone 'GMT')::int as snapshot,
49 FROM build_status s join buildsystems b on (s.sysname = b.name)
50 WHERE NOT b.no_alerts and
51 snapshot > current_timestamp - interval '30 days'
52 ORDER BY sysname, branch, snapshot desc
60 while (my $row = $sth->fetchrow_hashref)
62 push(@last_heard, $row);
69 SELECT sysname, branch,
70 extract(epoch from first_alert) as first_alert,
71 extract(epoch from last_notification) as last_notification
76 my $alerts = $db->selectall_hashref($sql,['sysname','branch']);
81 my $clear_sth = $db->prepare(q[
88 my $update_sth = $db->prepare(q[
91 SET last_notification = timestamp '1970-01-01' + ( interval '1 second' * $1)
96 my $insert_sth = $db->prepare(q[
98 INSERT INTO alerts ( sysname, branch, first_alert, last_notification )
100 timestamp '1970-01-01' + ( interval '1 second' * $3),
101 timestamp '1970-01-01' + ( interval '1 second' * $4))
106 my $lts = scalar(localtime);
107 print "starting alert run: $lts\n";
109 foreach my $sysbranch (@last_heard)
111 # eval the config in a Safe container to protect ourselves
112 my $container = new Safe;
113 my $sconf = $sysbranch->{config};
114 unless ($sconf =~ s/.*(\$Script_Config)/$1/ms )
116 $sconf = '$Script_Config={};';
118 my $client_conf = $container->reval("$sconf;");
120 my %client_alert_settings = %{ $client_conf->{alerts} || {} };
121 my $setting = $client_alert_settings{$sysbranch->{branch}};
122 unless ($setting && $setting->{alert_after} && $setting->{alert_every})
124 # if no valid setting, clear any alert and keep going
125 if ($alerts->{$sysbranch->{sysname}}->{$sysbranch->{branch}})
127 $clear_sth->execute($sysbranch->{sysname},$sysbranch->{branch});
128 push(@need_cleared,[$sysbranch]);
132 # ok, we have valid settings. should the alert be on?
133 my $hours_since_heard = ($now - $sysbranch->{snapshot}) / 3600;
136 "have settings for $sysbranch->{sysname}:$sysbranch->{branch} ",
137 "hours since heard = $hours_since_heard, ",
138 "setting = $setting->{alert_after} / $setting->{alert_every} \n";
140 if ($hours_since_heard > $setting->{alert_after})
143 $alerts->{$sysbranch->{sysname}}->{$sysbranch->{branch}};
145 ($now - (3600 * $setting->{alert_every})) >
146 $known_alert->{last_notification})
148 # check if it's too old - 15 days and twice initial seems plenty
149 if ($hours_since_heard > 360 &&
150 $hours_since_heard > 2 * $setting->{alert_after} )
152 print "alert is too old ... giving up\n";
156 # old alert, but time to alert again
157 print "alert is on, but time to alert again\n";
158 $update_sth->execute($now,
159 $sysbranch->{sysname},
160 $sysbranch->{branch},
162 push(@need_alerts,[$sysbranch,$setting]);
163 print "alert updated\n";
165 elsif ( ! $known_alert )
168 print "new alert needed\n";
169 $insert_sth->execute($sysbranch->{sysname},
170 $sysbranch->{branch},
172 print "new record inserted\n";
173 push(@need_alerts,[$sysbranch,$setting]);
176 # nope, so clear the alert if it exists
177 elsif ($alerts->{$sysbranch->{sysname}}->{$sysbranch->{branch}})
179 print "clear exisiting alerts";
180 $clear_sth->execute($sysbranch->{sysname},$sysbranch->{branch});
181 push(@need_cleared,[$sysbranch,$setting]);
186 print "start emails\n";
188 my $addr_sth = $db->prepare(q[
196 my $me = `id -un`; chomp $me;
197 my $host = `hostname`; chomp ($host);
198 $host = $default_host unless ($host =~ m/[.]/ || !defined($default_host));
200 my $from_addr = "PG Build Farm <$me\@$host>";
201 $from_addr =~ tr /\r\n//d;
205 foreach my $clearme (@need_cleared)
207 my ($sysbranch, $setting) = @$clearme;
208 my ($animal, $branch) = ($sysbranch->{sysname},$sysbranch->{branch});
212 my $hours = sprintf("%.2f",($now - $sysbranch->{snapshot}) / 3600);
213 $text = "$sysbranch->{sysname} has now reported " .
214 "on $sysbranch->{branch} $hours hours ago.";
218 $text = "$sysbranch->{sysname} has lost alarm settings on branch: " .
219 "$sysbranch->{branch}. Resetting alarm to off.";
221 my $msg = new Mail::Send;
223 $msg->set('From',$from_addr);
225 $addr_sth->execute($animal);
227 my $mailto = $addr_sth->fetchrow_array;
229 print "sending clear to $mailto\n";
234 $msg->subject("PGBuildfarm member $animal Branch $branch Alert cleared");
236 print $fh "\n\n$text\n";
239 print "alert cleared $animal $branch\n";
242 foreach my $clearme (@need_alerts)
244 my ($sysbranch, $setting) = @$clearme;
245 my ($animal, $branch) = ($sysbranch->{sysname},$sysbranch->{branch});
246 my $hours = sprintf("%.2f",($now - $sysbranch->{snapshot}) / 3600);
247 my $text = "$sysbranch->{sysname} has not reported " .
248 "on $sysbranch->{branch} for $hours hours.";
249 my $msg = new Mail::Send;
251 $msg->set('From',$from_addr);
253 $addr_sth->execute($animal);
255 my ($mailto) = $addr_sth->fetchrow_array;
259 print "sending alert to $mailto\n";
263 $msg->subject("PGBuildfarm member $animal Branch $branch " .
264 "Alert notification");
266 print $fh "\n\n$text\n";
269 print "alert sent $animal $branch\n";
273 print "=================================\n";