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

Last change on this file since 749 was 749, checked in by andersk, 14 years ago
Nope. Don't care.
  • Property svn:executable set to *
File size: 2.2 KB
Line 
1#!/usr/bin/perl
2
3use strict;
4use warnings;
5use Sys::Hostname;
6use Time::HiRes qw(ualarm);
7
8our $ZCLASS = "scripts-auto";
9our @USERS = qw/root logview/;
10
11our %USERS;
12@USERS{@USERS} = undef;
13
14sub zwrite($;$$) {
15    my ($message, $class, $instance) = @_;
16    $class ||= $ZCLASS;
17    $instance ||= 'root.'.hostname;
18    open(ZWRITE, "|-", qw|/usr/bin/zwrite -d -O log -c|, $class, '-i', $instance, '-s', hostname) or die "Couldn't open zwrite";
19    print ZWRITE $message;
20    close(ZWRITE);
21}
22
23my %toclass;
24
25while (1) {
26    my @message = scalar(<>);
27    eval {
28        local $SIG{ALRM} = sub { die "alarm\n" }; # NB: \n required
29        ualarm(500*1000);
30        while (<>) { push @message, $_; }
31    };
32    chomp @message;
33    map { s/^(.*?): // } @message;
34    %toclass = ();
35    foreach my $message (@message) {
36        sub sendmsg ($;$) {
37            my ($message, $class) = @_;
38            $class ||= $ZCLASS;
39            $toclass{$class} .= $message."\n";
40        }
41        if ($message =~ m|Accepted (\S+) for (\S+)|) {
42            sendmsg($message) if exists $USERS{$2}
43        } elsif ($message =~ m|Authorized to (\S+),|) {
44            sendmsg($message) if exists $USERS{$1};
45        } elsif ($message =~ m|Root (\S+) shell|) {
46            sendmsg($message);
47        } elsif ($message =~ m|session \S+ for user (\S+)|) {
48            sendmsg($message) if exists $USERS{$1};
49        } elsif ($message =~ m|^Connection closed|) {
50            # Do nothing
51        } elsif ($message =~ m|^Invalid user|) {
52        } elsif ($message =~ m|^input_userauth_request: invalid user|) {
53        } elsif ($message =~ m|^Received disconnect from|) {
54        } elsif ($message =~ m|^fatal: Read from socket failed: Connection reset by peer$|) {
55        } elsif ($message =~ m|^reverse mapping checking getaddrinfo|) {
56        } elsif ($message =~ m|^pam_succeed_if\(sshd\:auth\)\:|) {
57        } elsif ($message =~ m|^error: PAM: Authentication failure|) {
58        } elsif ($message =~ m|^pam_unix\(sshd:auth\): authentication failure|) {
59        } elsif ($message =~ m|^Postponed keyboard-interactive for invalid user |) {
60        } elsif ($message =~ m|^Failed keyboard-interactive/pam for invalid user |) {
61        } elsif ($message =~ m|^Address \S+ maps to \S+, but this does not map back to the address|) {
62        } else {
63            sendmsg($message, "scripts-spew");
64        }
65    }
66
67    foreach my $class (keys %toclass) {
68        zwrite($toclass{$class}, $class);
69    }
70}
Note: See TracBrowser for help on using the repository browser.