source: server/fedora/config/etc/syslog-ng/d_zroot.pl @ 784

Last change on this file since 784 was 784, checked in by quentin, 16 years ago
Use explicit recipients for non-root log messages
  • Property svn:executable set to *
File size: 3.6 KB
RevLine 
[645]1#!/usr/bin/perl
2
3use strict;
4use warnings;
5use Sys::Hostname;
[666]6use Time::HiRes qw(ualarm);
[770]7use File::Temp;
[645]8
[666]9our $ZCLASS = "scripts-auto";
10our @USERS = qw/root logview/;
[783]11my $k5login;
12open $k5login, '/root/.k5login';
13our @RECIPIENTS = map {chomp; m|([^/@]*)| && $1} <$k5login>;
14close $k5login;
[666]15
16our %USERS;
17@USERS{@USERS} = undef;
18
[783]19sub zwrite($;$$@) {
20    my ($message, $class, $instance, @recipients) = @_;
[666]21    $class ||= $ZCLASS;
[665]22    $instance ||= 'root.'.hostname;
[784]23    open(ZWRITE, "|-", qw|/usr/bin/zwrite -d -n -O log -c|, $class, '-i', $instance, '-s', hostname, @recipients) or die "Couldn't open zwrite";
[645]24    print ZWRITE $message;
25    close(ZWRITE);
26}
27
[666]28my %toclass;
[645]29
[770]30my %sshkeys;
31
32sub buildKeyMap($) {
33    my ($file) = @_;
34    open (KEYS, $file) or warn "Couldn't open $file: $!";
35    while (<KEYS>) {
36        chomp;
37        my ($fingerprint, $comment) = parseKey($_);
38        $sshkeys{$fingerprint} = $comment;
39    }
40    close(KEYS);
41}
42
43sub parseKey($) {
44    my ($key) = @_;
45    my $tmp = new File::Temp;
46    print $tmp $key;
47    close $tmp;
48    open (KEYGEN, "-|", qw(/usr/bin/ssh-keygen -l -f), $tmp) or die "Couldn't call ssh-keygen: $!";
49    my ($line) = <KEYGEN>;
50    close(KEYGEN);
51    my (undef, $fingerprint, undef) = split(' ', $line, 3);
52    my (undef, undef, $comment) = split(' ', $key, 3);
[784]53    #print "$fingerprint $comment";
[770]54    return ($fingerprint, $comment);
55}
56
57buildKeyMap("/root/.ssh/authorized_keys2");
58
[666]59while (1) {
60    my @message = scalar(<>);
61    eval {
62        local $SIG{ALRM} = sub { die "alarm\n" }; # NB: \n required
63        ualarm(500*1000);
64        while (<>) { push @message, $_; }
65    };
66    chomp @message;
67    map { s/^(.*?): // } @message;
68    %toclass = ();
69    foreach my $message (@message) {
70        sub sendmsg ($;$) {
71            my ($message, $class) = @_;
72            $class ||= $ZCLASS;
73            $toclass{$class} .= $message."\n";
[645]74        }
[666]75        if ($message =~ m|Accepted (\S+) for (\S+)|) {
76            sendmsg($message) if exists $USERS{$2}
77        } elsif ($message =~ m|Authorized to (\S+),|) {
78            sendmsg($message) if exists $USERS{$1};
79        } elsif ($message =~ m|Root (\S+) shell|) {
80            sendmsg($message);
[667]81        } elsif ($message =~ m|session \S+ for user (\S+)|) {
82            sendmsg($message) if exists $USERS{$1};
[770]83        } elsif ($message =~ m|^Found matching (\w+) key: (\S+)|) {
84            if ($sshkeys{$2}) {
85                sendmsg($message." (".$sshkeys{$2}.")");
86            } else {
87                sendmsg($message." (UNKNOWN KEY)");
88            }
[666]89        } elsif ($message =~ m|^Connection closed|) {
90            # Do nothing
[770]91        } elsif ($message =~ m|^Closing connection to |) {
92        } elsif ($message =~ m|^Connection from (\S+) port (\S+)|) {
[666]93        } elsif ($message =~ m|^Invalid user|) {
94        } elsif ($message =~ m|^input_userauth_request: invalid user|) {
95        } elsif ($message =~ m|^Received disconnect from|) {
[668]96        } elsif ($message =~ m|^fatal: Read from socket failed: Connection reset by peer$|) {
[690]97        } elsif ($message =~ m|^reverse mapping checking getaddrinfo|) {
98        } elsif ($message =~ m|^pam_succeed_if\(sshd\:auth\)\:|) {
[749]99        } elsif ($message =~ m|^error: PAM: Authentication failure|) {
100        } elsif ($message =~ m|^pam_unix\(sshd:auth\): authentication failure|) {
[738]101        } elsif ($message =~ m|^Postponed keyboard-interactive for invalid user |) {
102        } elsif ($message =~ m|^Failed keyboard-interactive/pam for invalid user |) {
[770]103        } elsif ($message =~ m|^Postponed gssapi-with-mic for |) {
[739]104        } elsif ($message =~ m|^Address \S+ maps to \S+, but this does not map back to the address|) {
[666]105        } else {
[770]106            sendmsg($message, "scripts-spew");
[646]107        }
[645]108    }
[665]109
[666]110    foreach my $class (keys %toclass) {
[784]111        if ($class eq "scripts-auto") {
112            zwrite($toclass{$class}, $class);
113        } else {
114            zwrite($toclass{$class}, $class, undef, @RECIPIENTS);
115        }
[666]116    }
[645]117}
Note: See TracBrowser for help on using the repository browser.