/[pxelator]/lib/PXElator/syslogd.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /lib/PXElator/syslogd.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 230 by dpavlin, Sun Aug 16 22:23:55 2009 UTC revision 239 by dpavlin, Mon Aug 17 00:51:24 2009 UTC
# Line 7  use IO::Socket; Line 7  use IO::Socket;
7  use Data::Dump qw/dump/;  use Data::Dump qw/dump/;
8  use CouchDB;  use CouchDB;
9    
10    use server;
11    
12  our $port = 514;  our $port = 514;
13  our $MAXLEN = 1524;  our $MAXLEN = 1524;
14    
15    sub message {
16            my $sock = shift;
17    
18            my $buf;
19            $sock->recv($buf, $MAXLEN);
20    
21            next unless $buf;
22    
23            my ($port, $ipaddr) = sockaddr_in($sock->peername);
24            my $log = {
25                    ip => join('.', unpack('C4',$ipaddr)),
26                    buf => $buf,
27            };
28    
29            if ( $buf =~ s/<(\d+)>// ) {
30                    $log->{pri}    = $1 % 8;
31                    $log->{facility} = ( $1 - $log->{pri} ) / 8;
32            
33                    $log->{timestamp} = $1 if $buf =~ s/^(\w\w\w\s+\d+\s+\d\d:\d\d:\d\d)\s*//;      # strip timestamp which some syslog servers insert here
34    
35                    if ( $buf =~ s/^([^:]+)\s*:\s*// ) {
36                            my $tag = $1;
37                            if ( $tag =~ m{^(\S+)\s(\S+)} ) {
38                                    $log->{tag} = $2;
39                                    $log->{hostname} = $1;
40                            } else {
41                                    $log->{tag} = $tag;
42                            }
43    
44                            if ( $log->{tag} =~ s/\[(\d+)\]$// ) {
45                                    $log->{pid} = $1;
46                            } elsif ( $buf =~ s/^(\d+):\s*// ) {
47                                    $log->{pid} = $1;
48                            }
49                    }
50    
51                    if ( $log->{tag} =~ m{CRON}i && $buf =~ m{^\((\w+)\) (.+) \((.+)\)$} ) {
52                            $log->{cron} = {
53                                    user => $1,
54                                    command => $2,
55                                    argument => $3,
56                            };
57                    }
58    
59                    $log->{message} = $buf;
60            }
61    
62            warn "log ",dump( $log );
63            CouchDB::audit( 'syslog', $log );
64    }
65    
66  sub start {  sub start {
67    
68          my $sock = IO::Socket::INET->new(          my $sock = IO::Socket::INET->new(
# Line 20  sub start { Line 73  sub start {
73    
74          CouchDB::audit('start', { port => $port });          CouchDB::audit('start', { port => $port });
75    
         my $buf;  
76          while(1) {          while(1) {
77                  $sock->recv($buf, $MAXLEN);                  message($sock);
78                  my ($port, $ipaddr) = sockaddr_in($sock->peername);                  server->refresh;
                 my $log = {  
                         ip => join('.', unpack('C4',$ipaddr)),  
                         hostname => gethostbyaddr($ipaddr, AF_INET),  
                         message => $buf,  
                 };  
   
                 if ( $buf =~ /<(\d+)>\s*(\S*)\s*:\s*(.*)/ ) {  
                         my $level = $1 % 8;  
   
                         my $overlay = {  
                                 message => $3,  
                                 level   => $level,  
                                 facility => ( $1-$level ) / 8,  
                                 program  => $2,  
                         };  
   
                         $log->{$_} = $overlay->{$_} foreach keys %$overlay;  
   
                         $log->{pid} = $1 if $log->{program} =~ s/\[(\d+)\]$//;  
                 }  
   
                 warn "log ",dump( $log );  
                 CouchDB::audit( 'syslog', $log );  
79          }          }
   
80  }  }
81    
82  1;  1;
Legend:
Removed from v.230  
changed lines
  Added in v.239
  ViewVC Help
Powered by ViewVC 1.1.26