--- trunk/irc-logger.pl 2006/03/01 21:29:14 7 +++ trunk/irc-logger.pl 2006/03/02 00:19:12 10 @@ -18,11 +18,11 @@ ## CONFIG -my $NICK = 'irc-logger-dev'; +my $NICK = 'irc-logger'; my $CONNECT = {Server => 'irc.freenode.net', Nick => $NICK, - Ircname => 'logger: ask dpavlin@rot13.org' + Ircname => "try /msg $NICK help", }; my $CHANNEL = '#razmjenavjestina'; my $IRC_ALIAS = "log"; @@ -84,7 +84,7 @@ $_[KERNEL]->post($IRC_ALIAS => register => 'all'); $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT); }, - irc_255 => sub { # server is done blabbing + irc_255 => sub { # server is done blabbing $_[KERNEL]->post($IRC_ALIAS => join => $CHANNEL); $_[KERNEL]->post($IRC_ALIAS => join => '#logger'); $_[KERNEL]->yield("heartbeat"); # start heartbeat @@ -107,11 +107,21 @@ my $msg = $_[ARG2]; from_to($msg, 'UTF-8', 'ISO-8859-2'); - my $res = 'unknown command ' . $msg; + my $res = "unknown command '$msg', try /msg $NICK help!"; print "<< $msg\n"; - if ($msg =~ m/^stat.*\s*(\d*)/) { + if ($msg =~ m/^help/i) { + + $res = "usage: /msg $NICK stat - shows user statistics | /msg $NICK last - show backtrace of conversations"; + + } elsif ($msg =~ m/^msg\s+(\S+)\s+(.*)$/i) { + + print ">> /msg $1 $2\n"; + $_[KERNEL]->post( $IRC_ALIAS => privmsg => $1, $2 ); + $res = ''; + + } elsif ($msg =~ m/^stat.*?\s*(\d*)/i) { my $nr = $1 || 10; @@ -120,36 +130,117 @@ }); $sth->execute(); $res = "Top $nr users: "; + my @users; while (my $row = $sth->fetchrow_hashref) { - $res .= $row->{nick} . ': ' . $row->{count} . ", "; + push @users,$row->{nick} . ': ' . $row->{count}; } - } + $res .= join(" | ", @users); + } elsif ($msg =~ m/^last.*?\s*(\d*)/i) { + + my $nr = $1 || 10; + + my $sth = $dbh->prepare(qq{ + select + time::date as date, + time::time as time, + channel, + nick, + message + from log order by log.time desc limit $nr + }); + $sth->execute(); + $res = "Last $nr messages: "; + my $last_row = { + date => '', + time => '', + channel => '', + nick => '', + }; + + my @rows; + + while (my $row = $sth->fetchrow_hashref) { + unshift @rows, $row; + } + + my @msgs; + + foreach my $row (@rows) { + + $row->{time} =~ s#\.\d+##; + + my $t; + $t = $row->{date} . ' ' if ($last_row->{date} ne $row->{date}); + $t .= $row->{time}; - $res =~ s/,\s*$//; - print ">> [$nick] $res\n"; + my $msg = ''; - from_to($res, 'ISO-8859-2', 'UTF-8'); - $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res ); + $msg .= "($t"; + $msg .= ' ' . $row->{channel} if ($last_row->{channel} ne $row->{channel}); + $msg .= ") "; + $msg .= $row->{nick} . ': ' if ($last_row->{nick} ne $row->{nick}); + + $msg .= $row->{message}; + + push @msgs, $msg; + + $last_row = $row; + } + + foreach my $res (@msgs) { + print "last: $res\n"; + from_to($res, 'ISO-8859-2', 'UTF-8'); + $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res ); + } + + $res = ''; + } + + if ($res) { + print ">> [$nick] $res\n"; + from_to($res, 'ISO-8859-2', 'UTF-8'); + $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res ); + } + + }, + irc_477 => sub { + print "# irc_477: ",$_[ARG1], "\n"; + $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" ); }, irc_505 => sub { - print "# irc_505: ",$_[ARG1], "\n"; + print "# irc_505: ",$_[ARG1], "\n"; $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" ); - warn "## register $NICK\n"; +# $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set hide email on" ); +# $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set email dpavlin\@rot13.org" ); + }, + irc_registered => sub { + warn "## indetify $NICK\n"; $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" ); + }, + irc_433 => sub { + print "# irc_433: ",$_[ARG1], "\n"; warn "## indetify $NICK\n"; + $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" ); + }, + irc_372 => sub { + print "MOTD: ", $_[ARG1], "\n"; + }, + irc_snotice => sub { + print "(server notice): ", $_[ARG0], "\n"; }, (map { ;"irc_$_" => sub { }} - qw(join - ctcp_version - connected snotice ctcp_action ping notice mode part quit - 001 002 003 004 005 - 250 251 252 253 254 265 266 - 332 333 353 366 372 375 376 - 477 + qw( )), +# join +# ctcp_version +# connected snotice ctcp_action ping notice mode part quit +# 001 002 003 004 005 +# 250 251 252 253 254 265 266 +# 332 333 353 366 372 375 376 +# 477 _child => sub {}, _default => sub { printf "%s: session %s caught an unhandled %s event.\n",