# Andrew Burke # # Man, this is way bigger than I thought it would be # # This is a combination of a bunch of people's work, # including Jeremy Muhlich and # Phil Fibiger # # TODO: make it use channel keys for password protection of the logs... ? # make this thing die cleanly package Perlbot::Plugin::LogServer; use Perlbot::Plugin; @ISA = qw(Perlbot::Plugin); use Perlbot::Utils; use HTTP::Daemon; use HTTP::Response; use HTTP::Headers; use File::Spec; our $VERSION = '1.0.0'; sub init { my $self = shift; $self->want_msg(0); $self->want_public(0); $self->{logdir} = $self->perlbot->config->value(bot => 'logdir'); $self->hook_event('endofmotd', sub { $self->logserver }); $self->hook_event('nomotd', sub { $self->logserver }); } sub logserver { my $self = shift; my $logdir = $self->{logdir}; my $server = HTTP::Daemon->new(LocalAddr => $self->config->value(server => 'hostname'), LocalPort => $self->config->value(server => 'port')); if(!$server) { debug("Could not start LogServer: $!"); return; } while (my $connection = $server->accept()) { my $pid; if (!defined($pid = fork)) { return; } if ($pid) { # parent $SIG{CHLD} = IGNORE; #sub { wait }; next; } else { $self->perlbot->ircconn->{_connected} = 0; while (my $request = $connection->get_request()) { my $search = 0; if ($request->method() eq 'GET') { my $response = 'Perlbot Logs

Perlbot Logs

'; my ($garbage, $chan, $year, $month, $day) = split('/', $request->url->path()); if($year eq 'search') { $year = undef; $search = 1; } if(!$chan && !$search) { if(opendir(DIR, $logdir)) { my @channels = readdir(DIR); closedir(DIR); $response .= '

$channel"; } } } $response .= '

'; } else { $response .= 'Could not open the bot\'s logdir!'; } } if($chan && !$year && !$search) { $response .= "[search] [${chan}] [top]

"; if(!opendir(LOGLIST, File::Spec->catfile($logdir, $chan))) { $response .= "No logs for channel: $chan"; } else { my @tmpfiles = readdir(LOGLIST); my @logfiles = sort(@tmpfiles); close LOGLIST; my @years; foreach my $logfile (@logfiles) { if (!($logfile =~ /^\.\.?$/)) { my ($tmpyear) = $logfile =~ /^(\d+)\./; if(!grep { /$tmpyear/ } @years) { push(@years, $tmpyear); } } } $response .= "

Logs for $chan in:

"; $response .= '

$year"; } $response .= '

'; } } if($chan && $year && !$month && !$search) { $response .= "[search] [${chan}] [top]

"; use HTML::CalendarMonth; if(!opendir(LOGLIST, File::Spec->catfile($logdir, $chan))) { $response .= "No logs for channel: $chan"; } else { my @tmpfiles = readdir(LOGLIST); my @logfiles = sort(@tmpfiles); close LOGLIST; $response .= "

Logs for channel: $chan

"; $response .= '

'; $response .= "

$year

\n"; $response .= "\n \n"; foreach my $month ((1..12)) { $response .= " \n"; if($month % 4 == 0) { $response .=" \n \n"; } } $response .= "

\n"; $month = sprintf("%02d", $month); my $cal = HTML::CalendarMonth->new(year => $year, month => $month); foreach my $day ((1..31)) { my $paddedday = sprintf("%02d", $day); my $filename = "$year.$month.$paddedday"; if(grep { /\Q$filename\E/ } @logfiles) { $cal->item($day)->wrap_content(HTML::Element->new('a', href => "/${chan}/${year}/${month}/${paddedday}")); } } $response .= $cal->as_HTML(); $response .= "

\n"; } } if($chan && $year && $month && !$day && !$search) { $response .= "[search] [${chan}] [top]

Logs for channel: $chan

"; $response .= '

'; $response .= "

$year

"; my $filename = File::Spec->catfile($logdir, $chan, "$year.$month.$day"); if(open(FILE, $filename)) { my @lines = ; close(FILE); foreach (@lines) { s//\>\;/g; s/(\<\;.*?\>\;)/$1<\/b>/; s|^(\d+:\d+:\d+) \* (\w+) (.*)|$1 * $2 $3|; s|^(\d+:\d+:\d+\s)(.*? joined \#.*?$)|$1$2|; s|^(\d+:\d+:\d+\s)(.*? left \#.*?$)|$1$2|; s|^(\d+:\d+:\d+\s)(\[.*?\])|$1$2|; s|(\d+\:\d+:\d+)|$1|; s#(\w+://.*?|www\d*\..*?|ftp\d*\..*?|web\d*\..*?)(\s+|'|,|$)#$1$2#; $response .= "$_
"; } } } if($search) { if($request->uri() !~ /\?/) { $response .= "[search] [${chan}] [top]

"; $response .= "

Search logs for channel: $chan

"; $response .= "

"; $response .= "Enter words to search for: "; $response .= ""; $response .= ""; } else { $response .= "[search] [${chan}] [top]
"; my ($tmpwords) = $request->uri() =~ /words\=(.*?)(?:\&|$)/; my @words = split(/\+/, $tmpwords); if(opendir(DIR, File::Spec->catfile($logdir, $chan))) { @tmp = readdir(DIR); @files = sort(@tmp); my $results_found = 0; foreach $file (@files) { open(FILE, File::Spec->catfile($logdir, $chan, $file)); @lines = ; close FILE; foreach $word (@words) { @lines = grep(/\Q$word\E/i, @lines); } foreach (@lines) { s//>/g; } if (@lines) { $results_found = 1; ($year, $month, $day) = split(/\./, $file); $response .= "
$file"; $response .= "
"; foreach (@lines) { s//\>\;/g; s/(\<\;.*?\>\;)/$1<\/b>/; s|^(\d+:\d+:\d+) \* (\w+) (.*)|$1 * $2 $3|; s|^(\d+:\d+:\d+\s)(.*? joined \#.*?$)|$1$2|; s|^(\d+:\d+:\d+\s)(.*? left \#.*?$)|$1$2|; s|^(\d+:\d+:\d+\s)(\[.*?\])|$1$2|; s|(\d+:\d+:\d+)|$1|; s#(\w+://.*?|www\d*\..*?|ftp\d*\..*?|web\d*\..*?)(\s+|'|,|$)#$1$2#; $response .= "$_
"; } } } if(!$results_found) { $response .= '
No results found for: ' . join(' ', @words) . '
'; } closedir(DIR); } } } $response .= ''; $connection->send_response(HTTP::Response->new(HTTP::Response::RC_OK, 'yay!', HTTP::Headers->new(Content_Type => 'text/html;'), $response)); undef($response); $search = 0; } } $connection->close; undef($connection); } exit; } } 1;