--- trunk/irc-logger.pl 2006/03/12 13:33:20 12
+++ trunk/irc-logger.pl 2006/03/13 12:56:26 15
@@ -18,7 +18,7 @@
## CONFIG
-my $NICK = 'irc-logger-dev';
+my $NICK = 'irc-logger';
my $CONNECT =
{Server => 'irc.freenode.net',
Nick => $NICK,
@@ -35,13 +35,17 @@
my $DSN = 'DBI:Pg:dbname=irc-logger';
+my $ENCODING = 'ISO-8859-2';
+
## END CONFIG
-use POE qw(Component::IRC Wheel::FollowTail);
+use POE qw(Component::IRC Wheel::FollowTail Component::Server::HTTP);
+use HTTP::Status;
use DBI;
use Encode qw/from_to/;
+use Regexp::Common qw /URI/;
my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr;
@@ -77,6 +81,16 @@
my @messages = get_from_log(
limit => 42,
search => '%what to stuff in ilike%',
+ fmt => {
+ time => '{%s} ',
+ time_channel => '{%s %s} ',
+ nick => '%s: ',
+ message => '%s',
+ },
+ message_filter => sub {
+ # modify message content
+ return shift;
+ }
);
=cut
@@ -86,6 +100,13 @@
$args->{limit} ||= 10;
+ $args->{fmt} ||= {
+ time => '{%s} ',
+ time_channel => '{%s %s} ',
+ nick => '%s: ',
+ message => '%s',
+ };
+
my $sql = qq{
select
time::date as date,
@@ -130,18 +151,28 @@
my $msg = '';
- $msg .= "{$t";
- $msg .= ' ' . $row->{channel} if ($last_row->{channel} ne $row->{channel});
- $msg .= "} ";
+ if ($last_row->{channel} ne $row->{channel}) {
+ $msg .= sprintf($args->{fmt}->{time_channel}, $t, $row->{channel});
+ } else {
+ $msg .= sprintf($args->{fmt}->{time}, $t);
+ }
my $append = 1;
if ($last_row->{nick} ne $row->{nick}) {
- $msg .= $row->{nick} . ': ';
+ $msg .= sprintf($args->{fmt}->{nick}, $row->{nick});
$append = 0;
}
- $msg .= $row->{message};
+ if (ref($args->{message_filter}) eq 'CODE') {
+ $msg .= sprintf($args->{fmt}->{message},
+ $args->{message_filter}->(
+ $row->{message}
+ )
+ );
+ } else {
+ $msg .= sprintf($args->{fmt}->{message}, $row->{message});
+ }
if ($append && @msgs) {
$msgs[$#msgs] .= " " . $msg;
@@ -180,7 +211,7 @@
my $channel = $_[ARG1]->[0];
my $msg = $_[ARG2];
- from_to($msg, 'UTF-8', 'ISO-8859-2');
+ from_to($msg, 'UTF-8', $ENCODING);
print "$channel: <$nick> $msg\n";
$sth->execute($channel, $nick, $msg);
@@ -189,7 +220,7 @@
my $kernel = $_[KERNEL];
my $nick = (split /!/, $_[ARG0])[0];
my $msg = $_[ARG2];
- from_to($msg, 'UTF-8', 'ISO-8859-2');
+ from_to($msg, 'UTF-8', $ENCODING);
my $res = "unknown command '$msg', try /msg $NICK help!";
my @out;
@@ -224,7 +255,7 @@
foreach my $res (get_from_log( limit => $1 )) {
print "last: $res\n";
- from_to($res, 'ISO-8859-2', 'UTF-8');
+ from_to($res, $ENCODING, 'UTF-8');
$_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
}
@@ -236,7 +267,7 @@
foreach my $res (get_from_log( limit => 20, search => "%${what}%" )) {
print "search [$what]: $res\n";
- from_to($res, 'ISO-8859-2', 'UTF-8');
+ from_to($res, $ENCODING, 'UTF-8');
$_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
}
@@ -246,7 +277,7 @@
if ($res) {
print ">> [$nick] $res\n";
- from_to($res, 'ISO-8859-2', 'UTF-8');
+ from_to($res, $ENCODING, 'UTF-8');
$_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
}
@@ -359,4 +390,46 @@
},
);
+# http server
+
+my $httpd = POE::Component::Server::HTTP->new(
+ Port => $NICK =~ m/-dev/ ? 8001 : 8000,
+ ContentHandler => { '/' => \&root_handler },
+ Headers => { Server => 'irc-logger' },
+);
+
+my $style = <<'_END_OF_STYLE_';
+.time, .channel { color: #808080; font-size: 60%; }
+.nick { color: #0000ff; font-size: 80%; }
+.message { color: #000000; font-size: 100%; }
+_END_OF_STYLE_
+
+sub root_handler {
+ my ($request, $response) = @_;
+ $response->code(RC_OK);
+ $response->content_type("text/html; charset=$ENCODING");
+ $response->content(
+ qq{$NICK} .
+ "irc-logger url: " . $request->uri . '
' .
+ join("
",
+ get_from_log(
+ limit => 100,
+ fmt => {
+ time => '%s ',
+ time_channel => '%s %s ',
+ nick => '%s: ',
+ message => '%s',
+ },
+ message_filter => sub {
+ my $m = shift || return;
+ $m =~ s#($RE{URI}{HTTP})#$1#gs;
+ return $m;
+ },
+ )
+ ) .
+ qq{}
+ );
+ return RC_OK;
+}
+
POE::Kernel->run;