+++ /dev/null
-#!/usr/bin/perl
-
-use strict;
-
-use Digest::SHA1 qw(sha1_hex);
-use MIME::Base64;
-use DBI;
-use DBD::Pg;
-use Data::Dumper;
-use Mail::Send;
-use Safe;
-
-use vars qw($dbhost $dbname $dbuser $dbpass $dbport
- $all_stat $fail_stat $change_stat $green_stat
-);
-
-require "$ENV{BFConfDir}/BuildFarmWeb.pl";
-
-die "no dbname" unless $dbname;
-die "no dbuser" unless $dbuser;
-
-# don't use configged dbuser/dbpass
-
-$dbuser=""; $dbpass="";
-
-my $dsn="dbi:Pg:dbname=$dbname";
-$dsn .= ";host=$dbhost" if $dbhost;
-$dsn .= ";port=$dbport" if $dbport;
-
-my $db = DBI->connect($dsn,$dbuser,$dbpass);
-
-die $DBI::errstr unless $db;
-
-my $clear_old = $db->do(q[
-
- DELETE FROM alerts
- WHERE sysname IN
- (SELECT name FROM buildsystems WHERE no_alerts)
- ]);
-
-
-my $sth = $db->prepare(q[
-
- SELECT DISTINCT ON (sysname, branch)
- sysname, branch,
- extract(epoch from snapshot at time zone 'GMT')::int as snapshot,
- conf_sum as config
- FROM build_status s join buildsystems b on (s.sysname = b.name)
- WHERE NOT b.no_alerts and
- snapshot > current_timestamp - interval '30 days'
- ORDER BY sysname, branch, snapshot desc
-
- ]);
-
-$sth->execute;
-
-my @last_heard;
-
-while (my $row = $sth->fetchrow_hashref)
-{
- push(@last_heard, $row);
-}
-
-$sth->finish;
-
-my $sql = q[
-
- SELECT sysname, branch,
- extract(epoch from first_alert) as first_alert,
- extract(epoch from last_notification) as last_notification
- FROM alerts
-
- ];
-
-my $alerts = $db->selectall_hashref($sql,['sysname','branch']);
-
-my @need_cleared;
-my @need_alerts;
-
-my $clear_sth = $db->prepare(q[
-
- DELETE FROM alerts
- WHERE sysname = ?
- AND branch = ?
- ]);
-
-my $update_sth = $db->prepare(q[
-
- UPDATE alerts
- SET last_notification = timestamp '1970-01-01' + ( interval '1 second' * $1)
- WHERE sysname = $2
- AND branch = $3
- ]);
-
-my $insert_sth = $db->prepare(q[
-
- INSERT INTO alerts ( sysname, branch, first_alert, last_notification )
- VALUES ($1, $2,
- timestamp '1970-01-01' + ( interval '1 second' * $3),
- timestamp '1970-01-01' + ( interval '1 second' * $4))
- ]);
-
-
-my $now = time;
-my $lts = scalar(localtime);
-print "starting alert run: $lts\n";
-
-foreach my $sysbranch (@last_heard)
-{
- # eval the config in a Safe container to protect ourselves
- my $container = new Safe;
- my $sconf = $sysbranch->{config};
- unless ($sconf =~ s/.*(\$Script_Config)/$1/ms )
- {
- $sconf = '$Script_Config={};';
- }
- my $client_conf = $container->reval("$sconf;");
-
- my %client_alert_settings = %{ $client_conf->{alerts} || {} };
- my $setting = $client_alert_settings{$sysbranch->{branch}};
- unless ($setting && $setting->{alert_after} && $setting->{alert_every})
- {
- # if no valid setting, clear any alert and keep going
- if ($alerts->{$sysbranch->{sysname}}->{$sysbranch->{branch}})
- {
- $clear_sth->execute($sysbranch->{sysname},$sysbranch->{branch});
- push(@need_cleared,[$sysbranch]);
- }
- next;
- }
- # ok, we have valid settings. should the alert be on?
- my $hours_since_heard = ($now - $sysbranch->{snapshot}) / 3600;
- # yep
- print
- "have settings for $sysbranch->{sysname}:$sysbranch->{branch} ",
- "hours since heard = $hours_since_heard, ",
- "setting = $setting->{alert_after} / $setting->{alert_every} \n";
-
- if ($hours_since_heard > $setting->{alert_after})
- {
- my $known_alert =
- $alerts->{$sysbranch->{sysname}}->{$sysbranch->{branch}};
- if ($known_alert &&
- ($now - (3600 * $setting->{alert_every})) >
- $known_alert->{last_notification})
- {
- # check if it's too old - 15 days and twice initial seems plenty
- if ($hours_since_heard > 360 &&
- $hours_since_heard > 2 * $setting->{alert_after} )
- {
- print "alert is too old ... giving up\n";
- next;
- }
-
- # old alert, but time to alert again
- print "alert is on, but time to alert again\n";
- $update_sth->execute($now,
- $sysbranch->{sysname},
- $sysbranch->{branch},
- );
- push(@need_alerts,[$sysbranch,$setting]);
- print "alert updated\n";
- }
- elsif ( ! $known_alert )
- {
- # new alert
- print "new alert needed\n";
- $insert_sth->execute($sysbranch->{sysname},
- $sysbranch->{branch},
- $now,$now);
- print "new record inserted\n";
- push(@need_alerts,[$sysbranch,$setting]);
- }
- }
- # nope, so clear the alert if it exists
- elsif ($alerts->{$sysbranch->{sysname}}->{$sysbranch->{branch}})
- {
- print "clear exisiting alerts";
- $clear_sth->execute($sysbranch->{sysname},$sysbranch->{branch});
- push(@need_cleared,[$sysbranch,$setting]);
- }
-
-}
-
-print "start emails\n";
-
-my $addr_sth = $db->prepare(q[
-
- SELECT owner_email
- FROM buildsystems
- WHERE name = ?
- ]);
-
-
-my $me = `id -un`; chomp $me;
-
-my $host = `hostname`; chomp $host;
-
-
-
-foreach my $clearme (@need_cleared)
-{
- my ($sysbranch, $setting) = @$clearme;
- my ($animal, $branch) = ($sysbranch->{sysname},$sysbranch->{branch});
- my $text;
- if ($setting)
- {
- my $hours = sprintf("%.2f",($now - $sysbranch->{snapshot}) / 3600);
- $text = "$sysbranch->{sysname} has now reported " .
- "on $sysbranch->{branch} $hours hours ago.";
- }
- else
- {
- $text = "$sysbranch->{sysname} has lost alarm settings on branch: " .
- "$sysbranch->{branch}. Resetting alarm to off.";
- }
- my $msg = new Mail::Send;
-
- $msg->set('From',"PG Build Farm <$me\@$host>");
-
- $addr_sth->execute($animal);
-
- my $mailto = $addr_sth->fetchrow_array;
-
- print "sending clear to $mailto\n";
-
- # $sth->finish;
-
- $msg->to($mailto);
- $msg->subject("PGBuildfarm member $animal Branch $branch Alert cleared");
- my $fh = $msg->open;
- print $fh "\n\n$text\n";
- $fh->close;
-
- print "alert cleared $animal $branch\n";
-}
-
-foreach my $clearme (@need_alerts)
-{
- my ($sysbranch, $setting) = @$clearme;
- my ($animal, $branch) = ($sysbranch->{sysname},$sysbranch->{branch});
- my $hours = sprintf("%.2f",($now - $sysbranch->{snapshot}) / 3600);
- my $text = "$sysbranch->{sysname} has not reported " .
- "on $sysbranch->{branch} for $hours hours.";
- my $msg = new Mail::Send;
-
- $msg->set('From',"PG Build Farm <$me\@$host>");
-
- $addr_sth->execute($animal);
-
- my ($mailto) = $addr_sth->fetchrow_array;
-
- # $sth->finish;
-
- print "sending alert to $mailto\n";
-
- $msg->to($mailto);
-
- $msg->subject("PGBuildfarm member $animal Branch $branch " .
- "Alert notification");
- my $fh = $msg->open;
- print $fh "\n\n$text\n";
- $fh->close;
-
- print "alert sent $animal $branch\n";
-}
-
-
-print "=================================\n";
-
-
-
git://git.exim.org / buildfarm-server.git / blobdiff