/[irc-logger]/trunk/bin/irc-logger.pl
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Annotation of /trunk/bin/irc-logger.pl

Parent Directory Parent Directory | Revision Log Revision Log


Revision 65 - (hide annotations)
Fri Jun 8 12:17:35 2007 UTC (16 years, 9 months ago) by dpavlin
File MIME type: text/plain
File size: 25292 byte(s)
three calendars in a row on history page
1 dpavlin 4 #!/usr/bin/perl -w
2     use strict;
3     $|++;
4    
5 dpavlin 5 =head1 NAME
6    
7     irc-logger.pl
8    
9     =head1 SYNOPSIS
10    
11     ./irc-logger.pl
12    
13 dpavlin 37 =head2 Options
14    
15     =over 4
16    
17     =item --import-dircproxy=filename
18    
19     Import log from C<dircproxy> to C<irc-logger> database
20    
21 dpavlin 45 =item --log=irc-logger.log
22    
23     Name of log file
24    
25     =back
26    
27 dpavlin 5 =head1 DESCRIPTION
28    
29     log all conversation on irc channel
30    
31     =cut
32    
33 dpavlin 4 ## CONFIG
34    
35 dpavlin 33 my $HOSTNAME = `hostname`;
36    
37 dpavlin 29 my $NICK = 'irc-logger';
38 dpavlin 33 $NICK .= '-dev' if ($HOSTNAME =~ m/llin/);
39 dpavlin 4 my $CONNECT =
40     {Server => 'irc.freenode.net',
41     Nick => $NICK,
42 dpavlin 8 Ircname => "try /msg $NICK help",
43 dpavlin 4 };
44     my $CHANNEL = '#razmjenavjestina';
45 dpavlin 33 $CHANNEL = '#irc-logger' if ($HOSTNAME =~ m/llin/);
46 dpavlin 4 my $IRC_ALIAS = "log";
47    
48     my %FOLLOWS =
49     (
50     ACCESS => "/var/log/apache/access.log",
51     ERROR => "/var/log/apache/error.log",
52     );
53    
54 dpavlin 19 my $DSN = 'DBI:Pg:dbname=' . $NICK;
55 dpavlin 5
56 dpavlin 14 my $ENCODING = 'ISO-8859-2';
57 dpavlin 34 my $TIMESTAMP = '%Y-%m-%d %H:%M:%S';
58 dpavlin 14
59 dpavlin 41 my $sleep_on_error = 5;
60    
61 dpavlin 4 ## END CONFIG
62    
63 dpavlin 5
64    
65 dpavlin 13 use POE qw(Component::IRC Wheel::FollowTail Component::Server::HTTP);
66     use HTTP::Status;
67 dpavlin 5 use DBI;
68 dpavlin 30 use Encode qw/from_to is_utf8/;
69 dpavlin 15 use Regexp::Common qw /URI/;
70 dpavlin 16 use CGI::Simple;
71 dpavlin 28 use HTML::TagCloud;
72 dpavlin 34 use POSIX qw/strftime/;
73 dpavlin 35 use HTML::CalendarMonthSimple;
74 dpavlin 37 use Getopt::Long;
75     use DateTime;
76 dpavlin 61 use URI::Escape;
77 dpavlin 43 use Data::Dump qw/dump/;
78 dpavlin 63 use DateTime::Format::ISO8601;
79 dpavlin 5
80 dpavlin 54 my $use_twitter = 1;
81     eval { require Net::Twitter; };
82     $use_twitter = 0 if ($@);
83    
84 dpavlin 37 my $import_dircproxy;
85 dpavlin 45 my $log_path;
86 dpavlin 37 GetOptions(
87     'import-dircproxy:s' => \$import_dircproxy,
88 dpavlin 45 'log:s' => \$log_path,
89 dpavlin 37 );
90    
91 dpavlin 45 open(STDOUT, '>', $log_path) || warn "can't redirect log to $log_path: $!";
92    
93     sub _log {
94     print strftime($TIMESTAMP,localtime()), ' ', join(" ",@_), $/;
95     }
96    
97 dpavlin 5 my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr;
98    
99 dpavlin 50 my $sql_schema = {
100     log => '
101 dpavlin 5 create table log (
102     id serial,
103     time timestamp default now(),
104     channel text not null,
105 dpavlin 19 me boolean default false,
106 dpavlin 5 nick text not null,
107     message text not null,
108     primary key(id)
109     );
110    
111     create index log_time on log(time);
112     create index log_channel on log(channel);
113     create index log_nick on log(nick);
114 dpavlin 50 ',
115     meta => '
116     create table meta (
117     nick text not null,
118     channel text not null,
119     name text not null,
120     value text,
121     changed timestamp default now(),
122     primary key(nick,channel,name)
123     );
124     ',
125     };
126 dpavlin 5
127 dpavlin 50 foreach my $table ( keys %$sql_schema ) {
128    
129     eval {
130     $dbh->do(qq{ select count(*) from $table });
131     };
132    
133     if ($@) {
134     warn "creating database table $table in $DSN\n";
135     $dbh->do( $sql_schema->{ $table } );
136     }
137 dpavlin 19 }
138 dpavlin 5
139 dpavlin 50
140     =head2 meta
141    
142     Set or get some meta data into database
143    
144     meta('nick','channel','var_name', $var_value );
145    
146     $var_value = meta('nick','channel','var_name');
147     ( $var_value, $changed ) = meta('nick','channel','var_name');
148    
149     =cut
150    
151     sub meta {
152     my ($nick,$channel,$name,$value) = @_;
153    
154     # normalize channel name
155     $channel =~ s/^#//;
156    
157     if (defined($value)) {
158    
159     my $sth = $dbh->prepare(qq{ update meta set value = ?, changed = now() where nick = ? and channel = ? and name = ? });
160    
161     eval { $sth->execute( $value, $nick, $channel, $name ) };
162    
163     # error or no result
164     if ( $@ || ! $sth->rows ) {
165     $sth = $dbh->prepare(qq{ insert into meta (value,nick,channel,name,changed) values (?,?,?,?,now()) });
166     $sth->execute( $value, $nick, $channel, $name );
167     _log "created $nick/$channel/$name = $value";
168     } else {
169     _log "updated $nick/$channel/$name = $value ";
170     }
171    
172     return $value;
173    
174     } else {
175    
176     my $sth = $dbh->prepare(qq{ select value,changed from meta where nick = ? and channel = ? and name = ? });
177     $sth->execute( $nick, $channel, $name );
178     my ($v,$c) = $sth->fetchrow_array;
179     _log "fetched $nick/$channel/$name = $v [$c]";
180     return ($v,$c) if wantarray;
181     return $v;
182    
183     }
184     }
185    
186    
187    
188 dpavlin 5 my $sth = $dbh->prepare(qq{
189     insert into log
190 dpavlin 37 (channel, me, nick, message, time)
191     values (?,?,?,?,?)
192 dpavlin 5 });
193    
194 dpavlin 50
195 dpavlin 28 my $tags;
196 dpavlin 31 my $tag_regex = '\b([\w-_]+)//';
197 dpavlin 28
198 dpavlin 11 =head2 get_from_log
199 dpavlin 5
200 dpavlin 11 my @messages = get_from_log(
201     limit => 42,
202     search => '%what to stuff in ilike%',
203 dpavlin 13 fmt => {
204     time => '{%s} ',
205     time_channel => '{%s %s} ',
206     nick => '%s: ',
207 dpavlin 20 me_nick => '***%s ',
208 dpavlin 13 message => '%s',
209     },
210 dpavlin 20 filter => {
211     message => sub {
212     # modify message content
213     return shift;
214     }
215 dpavlin 21 },
216     context => 5,
217 dpavlin 42 full_rows => 1,
218 dpavlin 11 );
219    
220 dpavlin 20 Order is important. Fields are first passed through C<filter> (if available) and
221     then throgh C<< sprintf($fmt->{message}, $message >> if available.
222    
223 dpavlin 21 C<context> defines number of messages around each search hit for display.
224    
225 dpavlin 42 C<full_rows> will return database rows for each result with C<date>, C<time>, C<channel>,
226     C<me>, C<nick> and C<message> keys.
227    
228 dpavlin 11 =cut
229    
230     sub get_from_log {
231     my $args = {@_};
232    
233 dpavlin 13 $args->{fmt} ||= {
234 dpavlin 26 date => '[%s] ',
235 dpavlin 13 time => '{%s} ',
236     time_channel => '{%s %s} ',
237     nick => '%s: ',
238 dpavlin 20 me_nick => '***%s ',
239 dpavlin 13 message => '%s',
240     };
241    
242 dpavlin 21 my $sql_message = qq{
243 dpavlin 11 select
244     time::date as date,
245     time::time as time,
246     channel,
247 dpavlin 20 me,
248 dpavlin 11 nick,
249     message
250     from log
251     };
252 dpavlin 21
253     my $sql_context = qq{
254     select
255     id
256     from log
257     };
258    
259     my $context = $1 if ($args->{search} && $args->{search} =~ s/\s*\+(\d+)\s*/ /);
260    
261     my $sql = $context ? $sql_context : $sql_message;
262    
263 dpavlin 25 $sql .= " where message ilike ? or nick ilike ? " if ($args->{search});
264 dpavlin 28 $sql .= " where id in (" . join(",", @{ $tags->{ $args->{tag} } }) . ") " if ($args->{tag} && $tags->{ $args->{tag} });
265 dpavlin 63 if ($args->{date}) {
266 dpavlin 64 my $date = eval { DateTime::Format::ISO8601->parse_datetime( $args->{date} )->ymd; };
267     if ( $@ ) {
268     warn "invalid date ", $args->{date}, $/;
269     $date = DateTime->now->ymd;
270     }
271 dpavlin 63 $sql .= " where date(time) = ? ";
272 dpavlin 64 $args->{date} = $date;
273 dpavlin 63 }
274 dpavlin 11 $sql .= " order by log.time desc";
275 dpavlin 35 $sql .= " limit " . $args->{limit} if ($args->{limit});
276 dpavlin 11
277     my $sth = $dbh->prepare( $sql );
278 dpavlin 21 if (my $search = $args->{search}) {
279     $search =~ s/^\s+//;
280     $search =~ s/\s+$//;
281 dpavlin 25 $sth->execute( ( '%' . $search . '%' ) x 2 );
282 dpavlin 45 _log "search for '$search' returned ", $sth->rows, " results ", $context || '';
283 dpavlin 28 } elsif (my $tag = $args->{tag}) {
284     $sth->execute();
285 dpavlin 45 _log "tag '$tag' returned ", $sth->rows, " results ", $context || '';
286 dpavlin 35 } elsif (my $date = $args->{date}) {
287     $sth->execute($date);
288 dpavlin 45 _log "found ", $sth->rows, " messages for date $date ", $context || '';
289 dpavlin 11 } else {
290     $sth->execute();
291     }
292     my $last_row = {
293     date => '',
294     time => '',
295     channel => '',
296     nick => '',
297     };
298    
299     my @rows;
300    
301     while (my $row = $sth->fetchrow_hashref) {
302     unshift @rows, $row;
303     }
304    
305 dpavlin 42 # normalize nick names
306     map {
307     $_->{nick} =~ s/^_*(.*?)_*$/$1/
308     } @rows;
309    
310     return @rows if ($args->{full_rows});
311    
312 dpavlin 16 my @msgs = (
313     "Showing " . ($#rows + 1) . " messages..."
314     );
315 dpavlin 11
316 dpavlin 21 if ($context) {
317     my @ids = @rows;
318     @rows = ();
319    
320     my $last_to = 0;
321    
322     my $sth = $dbh->prepare( $sql_message . qq{ where id >= ? and id < ? } );
323     foreach my $row_id (sort { $a->{id} <=> $b->{id} } @ids) {
324     my $id = $row_id->{id} || die "can't find id in row";
325    
326     my ($from, $to) = ($id - $context, $id + $context);
327     $from = $last_to if ($from < $last_to);
328     $last_to = $to;
329     $sth->execute( $from, $to );
330    
331     #warn "## id: $id from: $from to: $to returned: ", $sth->rows, "\n";
332    
333     while (my $row = $sth->fetchrow_hashref) {
334     push @rows, $row;
335     }
336    
337     }
338     }
339    
340 dpavlin 35 # sprintf which can take coderef as first parametar
341     sub cr_sprintf {
342     my $fmt = shift || return;
343     if (ref($fmt) eq 'CODE') {
344     $fmt->(@_);
345     } else {
346     sprintf($fmt, @_);
347     }
348     }
349    
350 dpavlin 11 foreach my $row (@rows) {
351    
352     $row->{time} =~ s#\.\d+##;
353    
354     my $msg = '';
355    
356 dpavlin 35 $msg = cr_sprintf($args->{fmt}->{date}, $row->{date}) . ' ' if ($last_row->{date} ne $row->{date});
357 dpavlin 26 my $t = $row->{time};
358    
359 dpavlin 13 if ($last_row->{channel} ne $row->{channel}) {
360 dpavlin 35 $msg .= cr_sprintf($args->{fmt}->{time_channel}, $t, $row->{channel});
361 dpavlin 13 } else {
362 dpavlin 35 $msg .= cr_sprintf($args->{fmt}->{time}, $t);
363 dpavlin 13 }
364 dpavlin 11
365 dpavlin 12 my $append = 1;
366 dpavlin 11
367 dpavlin 22 my $nick = $row->{nick};
368 dpavlin 42 # if ($nick =~ s/^_*(.*?)_*$/$1/) {
369     # $row->{nick} = $nick;
370     # }
371 dpavlin 24
372 dpavlin 22 if ($last_row->{nick} ne $nick) {
373 dpavlin 20 # obfu way to find format for me_nick if needed or fallback to default
374     my $fmt = $row->{me} ? ( $args->{fmt}->{me_nick} || $args->{fmt}->{nick} ) : $args->{fmt}->{nick};
375     $fmt ||= '%s';
376    
377     $nick = $args->{filter}->{nick}->($nick) if (ref($args->{filter}->{nick}) eq 'CODE');
378    
379 dpavlin 35 $msg .= cr_sprintf( $fmt, $nick );
380 dpavlin 12 $append = 0;
381     }
382    
383 dpavlin 20 $args->{fmt}->{message} ||= '%s';
384     if (ref($args->{filter}->{message}) eq 'CODE') {
385 dpavlin 35 $msg .= cr_sprintf($args->{fmt}->{message},
386 dpavlin 20 $args->{filter}->{message}->(
387 dpavlin 15 $row->{message}
388     )
389     );
390     } else {
391 dpavlin 35 $msg .= cr_sprintf($args->{fmt}->{message}, $row->{message});
392 dpavlin 15 }
393 dpavlin 11
394 dpavlin 12 if ($append && @msgs) {
395     $msgs[$#msgs] .= " " . $msg;
396     } else {
397     push @msgs, $msg;
398     }
399 dpavlin 11
400     $last_row = $row;
401     }
402    
403     return @msgs;
404     }
405    
406 dpavlin 37 # tags support
407 dpavlin 11
408 dpavlin 37 my $cloud = HTML::TagCloud->new;
409 dpavlin 4
410 dpavlin 37 =head2 add_tag
411 dpavlin 4
412 dpavlin 37 add_tag( id => 42, message => 'irc message' );
413    
414     =cut
415    
416     sub add_tag {
417     my $arg = {@_};
418    
419     return unless ($arg->{id} && $arg->{message});
420    
421     my $m = $arg->{message};
422     from_to('UTF-8', 'iso-8859-2', $m) if (is_utf8($m));
423    
424     while ($m =~ s#$tag_regex##s) {
425     my $tag = $1;
426     next if (! $tag || $tag =~ m/https?:/i);
427     push @{ $tags->{$tag} }, $arg->{id};
428     #warn "+tag $tag: $arg->{id}\n";
429     $cloud->add($tag, "?tag=$tag", scalar @{$tags->{$tag}} + 1);
430     }
431     }
432    
433     =head2 seed_tags
434    
435     Read all tags from database and create in-memory cache for tags
436    
437     =cut
438    
439     sub seed_tags {
440     my $sth = $dbh->prepare(qq{ select id,message from log where message like '%//%' });
441     $sth->execute;
442     while (my $row = $sth->fetchrow_hashref) {
443     add_tag( %$row );
444     }
445    
446     foreach my $tag (keys %$tags) {
447     $cloud->add($tag, "?tag=$tag", scalar @{$tags->{$tag}} + 1);
448     }
449     }
450    
451     seed_tags;
452    
453    
454 dpavlin 36 =head2 save_message
455    
456 dpavlin 37 save_message(
457     channel => '#foobar',
458     me => 0,
459     nick => 'dpavlin',
460     msg => 'test message',
461     time => '2006-06-25 18:57:18',
462     );
463 dpavlin 36
464 dpavlin 37 C<time> is optional, it will use C<< now() >> if it's not available.
465    
466     C<me> if not specified will be C<0> (not C</me> message)
467    
468 dpavlin 36 =cut
469    
470     sub save_message {
471 dpavlin 37 my $a = {@_};
472     $a->{me} ||= 0;
473 dpavlin 38 $a->{time} ||= strftime($TIMESTAMP,localtime());
474 dpavlin 37
475 dpavlin 45 _log
476 dpavlin 37 $a->{channel}, " ",
477     $a->{me} ? "***" . $a->{nick} : "<" . $a->{nick} . ">",
478 dpavlin 45 " " . $a->{msg};
479 dpavlin 37
480     from_to($a->{msg}, 'UTF-8', $ENCODING);
481    
482     $sth->execute($a->{channel}, $a->{me}, $a->{nick}, $a->{msg}, $a->{time});
483 dpavlin 36 add_tag( id => $dbh->last_insert_id(undef,undef,"log",undef),
484 dpavlin 37 message => $a->{msg});
485 dpavlin 36 }
486    
487 dpavlin 50
488 dpavlin 37 if ($import_dircproxy) {
489     open(my $l, $import_dircproxy) || die "can't open $import_dircproxy: $!";
490     warn "importing $import_dircproxy...\n";
491     my $tz_offset = 2 * 60 * 60; # TZ GMT+2
492     while(<$l>) {
493     chomp;
494     if (/^@(\d+)\s(\S+)\s(.+)$/) {
495     my ($time, $nick, $msg) = ($1,$2,$3);
496    
497     my $dt = DateTime->from_epoch( epoch => $time + $tz_offset );
498    
499     my $me = 0;
500     $me = 1 if ($nick =~ m/^\[\S+]/);
501     $nick =~ s/^[\[<]([^!]+).*$/$1/;
502    
503     $msg =~ s/^ACTION\s+// if ($me);
504    
505     save_message(
506     channel => $CHANNEL,
507     me => $me,
508     nick => $nick,
509     msg => $msg,
510     time => $dt->ymd . " " . $dt->hms,
511     ) if ($nick !~ m/^-/);
512    
513     } else {
514 dpavlin 45 _log "can't parse: $_";
515 dpavlin 37 }
516     }
517     close($l);
518     warn "import over\n";
519     exit;
520     }
521    
522    
523     #
524     # POE handing part
525     #
526    
527     my $SKIPPING = 0; # if skipping, how many we've done
528     my $SEND_QUEUE; # cache
529 dpavlin 43 my $ping; # ping stats
530 dpavlin 37
531     POE::Component::IRC->new($IRC_ALIAS);
532    
533 dpavlin 34 POE::Session->create( inline_states =>
534 dpavlin 4 {_start => sub {
535 dpavlin 7 $_[KERNEL]->post($IRC_ALIAS => register => 'all');
536     $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);
537 dpavlin 4 },
538 dpavlin 9 irc_255 => sub { # server is done blabbing
539 dpavlin 7 $_[KERNEL]->post($IRC_ALIAS => join => $CHANNEL);
540     $_[KERNEL]->post($IRC_ALIAS => join => '#logger');
541     $_[KERNEL]->yield("heartbeat"); # start heartbeat
542     # $_[KERNEL]->yield("my_add", $_) for keys %FOLLOWS;
543 dpavlin 11 $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" );
544 dpavlin 4 },
545     irc_public => sub {
546 dpavlin 7 my $kernel = $_[KERNEL];
547     my $nick = (split /!/, $_[ARG0])[0];
548     my $channel = $_[ARG1]->[0];
549     my $msg = $_[ARG2];
550 dpavlin 4
551 dpavlin 37 save_message( channel => $channel, me => 0, nick => $nick, msg => $msg);
552 dpavlin 50 meta( $nick, $channel, 'last-msg', $msg );
553 dpavlin 4 },
554 dpavlin 19 irc_ctcp_action => sub {
555     my $kernel = $_[KERNEL];
556     my $nick = (split /!/, $_[ARG0])[0];
557     my $channel = $_[ARG1]->[0];
558     my $msg = $_[ARG2];
559    
560 dpavlin 37 save_message( channel => $channel, me => 1, nick => $nick, msg => $msg);
561 dpavlin 50
562 dpavlin 54 if ( $use_twitter ) {
563 dpavlin 58 if ( my $twitter = meta( $nick, $NICK, 'twitter' ) ) {
564 dpavlin 54 my ($login,$passwd) = split(/\s+/,$twitter,2);
565     _log("sending twitter for $nick/$login on $channel ");
566     my $bot = Net::Twitter->new( username=>$login, password=>$passwd );
567     $bot->update("<${channel}> $msg");
568     }
569 dpavlin 50 }
570    
571 dpavlin 19 },
572 dpavlin 43 irc_ping => sub {
573     warn "pong ", $_[ARG0], $/;
574 dpavlin 48 $ping->{ $_[ARG0] }++;
575 dpavlin 43 },
576     irc_invite => sub {
577     my $kernel = $_[KERNEL];
578     my $nick = (split /!/, $_[ARG0])[0];
579     my $channel = $_[ARG1];
580    
581     warn "invited to $channel by $nick";
582    
583     $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, "how nice of you to invite me to $channel, I'll be right there..." );
584     $_[KERNEL]->post($IRC_ALIAS => join => $channel);
585    
586     },
587 dpavlin 7 irc_msg => sub {
588     my $kernel = $_[KERNEL];
589     my $nick = (split /!/, $_[ARG0])[0];
590     my $msg = $_[ARG2];
591 dpavlin 50 my $channel = $_[ARG1]->[0];
592 dpavlin 14 from_to($msg, 'UTF-8', $ENCODING);
593 dpavlin 7
594 dpavlin 8 my $res = "unknown command '$msg', try /msg $NICK help!";
595 dpavlin 11 my @out;
596 dpavlin 7
597 dpavlin 45 _log "<< $msg";
598 dpavlin 7
599 dpavlin 8 if ($msg =~ m/^help/i) {
600 dpavlin 7
601 dpavlin 11 $res = "usage: /msg $NICK comand | commands: stat - user/message stat | last - show backtrace | grep foobar - find foobar";
602 dpavlin 8
603 dpavlin 10 } elsif ($msg =~ m/^msg\s+(\S+)\s+(.*)$/i) {
604    
605 dpavlin 45 _log ">> /msg $1 $2";
606 dpavlin 10 $_[KERNEL]->post( $IRC_ALIAS => privmsg => $1, $2 );
607     $res = '';
608    
609 dpavlin 8 } elsif ($msg =~ m/^stat.*?\s*(\d*)/i) {
610    
611 dpavlin 7 my $nr = $1 || 10;
612    
613     my $sth = $dbh->prepare(qq{
614 dpavlin 40 select
615 dpavlin 57 trim(both '_' from nick) as nick,
616 dpavlin 40 count(*) as count,
617     sum(length(message)) as len
618     from log
619 dpavlin 57 group by trim(both '_' from nick)
620 dpavlin 40 order by len desc,count desc
621     limit $nr
622 dpavlin 7 });
623     $sth->execute();
624     $res = "Top $nr users: ";
625 dpavlin 8 my @users;
626 dpavlin 7 while (my $row = $sth->fetchrow_hashref) {
627 dpavlin 40 push @users,$row->{nick} . ': ' . $row->{count} . '/' . $row->{len} . '=' . sprintf("%.2f", $row->{len}/$row->{count});
628 dpavlin 7 }
629 dpavlin 8 $res .= join(" | ", @users);
630     } elsif ($msg =~ m/^last.*?\s*(\d*)/i) {
631    
632 dpavlin 50 my $limit = $1 || meta( $nick, $channel, 'last-size' ) || 10;
633    
634     foreach my $res (get_from_log( limit => $limit )) {
635 dpavlin 45 _log "last: $res";
636 dpavlin 14 from_to($res, $ENCODING, 'UTF-8');
637 dpavlin 11 $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
638 dpavlin 8 }
639    
640 dpavlin 11 $res = '';
641 dpavlin 8
642 dpavlin 21 } elsif ($msg =~ m/^(search|grep)\s+(.*)\s*$/i) {
643 dpavlin 8
644 dpavlin 11 my $what = $2;
645 dpavlin 8
646 dpavlin 21 foreach my $res (get_from_log(
647     limit => 20,
648     search => $what,
649     )) {
650 dpavlin 45 _log "search [$what]: $res";
651 dpavlin 14 from_to($res, $ENCODING, 'UTF-8');
652 dpavlin 8 $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
653     }
654    
655     $res = '';
656 dpavlin 11
657 dpavlin 42 } elsif ($msg =~ m/^(?:count|poll)\s+(.*)(?:\s+(\d+))?\s*$/i) {
658    
659     my ($what,$limit) = ($1,$2);
660     $limit ||= 100;
661    
662     my $stat;
663    
664     foreach my $res (get_from_log(
665     limit => $limit,
666     search => $what,
667     full_rows => 1,
668     )) {
669     while ($res->{message} =~ s/\Q$what\E(\+|\-)//) {
670     $stat->{vote}->{$1}++;
671     $stat->{from}->{ $res->{nick} }++;
672     }
673     }
674    
675     my @nicks;
676 dpavlin 43 foreach my $nick (sort { $stat->{from}->{$a} <=> $stat->{from}->{$b} } keys %{ $stat->{from} }) {
677     push @nicks, $nick . ( $stat->{from}->{$nick} == 1 ? '' :
678     "(" . $stat->{from}->{$nick} . ")"
679     );
680 dpavlin 42 }
681    
682     $res =
683 dpavlin 43 "$what ++ " . ( $stat->{vote}->{'+'} || 0 ) .
684     " : " . ( $stat->{vote}->{'-'} || 0 ) . " --" .
685 dpavlin 42 " from " . ( join(", ", @nicks) || 'nobody' );
686    
687 dpavlin 43 $_[KERNEL]->post( $IRC_ALIAS => notice => $nick, $res );
688    
689     } elsif ($msg =~ m/^ping/) {
690     $res = "ping = " . dump( $ping );
691 dpavlin 51 } elsif ($msg =~ m/^conf(?:ig)*\s*(last-size|twitter)*\s*(.*)/) {
692 dpavlin 50 if ( ! defined( $1 ) ) {
693     my $sth = $dbh->prepare(qq{ select name,value,changed from meta where nick = ? and channel = ? });
694     $sth->execute( $nick, $channel );
695 dpavlin 52 $res = "config for $nick on $channel";
696 dpavlin 50 while ( my ($n,$v) = $sth->fetchrow_array ) {
697 dpavlin 52 $res .= " | $n = $v";
698 dpavlin 50 }
699 dpavlin 51 } elsif ( ! $2 ) {
700 dpavlin 50 my $val = meta( $nick, $channel, $1 );
701     $res = "current $1 = " . ( $val ? $val : 'undefined' );
702 dpavlin 51 } else {
703     my $validate = {
704     'last-size' => qr/^\d+/,
705     'twitter' => qr/^\w+\s+\w+/,
706     };
707    
708     my ( $op, $val ) = ( $1, $2 );
709    
710     if ( my $regex = $validate->{$op} ) {
711     if ( $val =~ $regex ) {
712     meta( $nick, $channel, $op, $val );
713     $res = "saved $op = $val";
714     } else {
715     $res = "config option $op = $val doesn't validate against $regex";
716     }
717     } else {
718     $res = "config option $op doesn't exist";
719     }
720 dpavlin 50 }
721 dpavlin 7 }
722    
723 dpavlin 8 if ($res) {
724 dpavlin 45 _log ">> [$nick] $res";
725 dpavlin 14 from_to($res, $ENCODING, 'UTF-8');
726 dpavlin 8 $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
727     }
728 dpavlin 7
729     },
730 dpavlin 10 irc_477 => sub {
731 dpavlin 45 _log "# irc_477: ",$_[ARG1];
732 dpavlin 10 $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );
733     },
734 dpavlin 7 irc_505 => sub {
735 dpavlin 45 _log "# irc_505: ",$_[ARG1];
736 dpavlin 7 $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );
737 dpavlin 10 # $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set hide email on" );
738     # $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set email dpavlin\@rot13.org" );
739 dpavlin 8 },
740     irc_registered => sub {
741 dpavlin 45 _log "## registrated $NICK";
742 dpavlin 7 $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" );
743 dpavlin 10 },
744 dpavlin 41 irc_disconnected => sub {
745 dpavlin 45 _log "## disconnected, reconnecting again";
746 dpavlin 41 $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);
747     },
748     irc_socketerr => sub {
749 dpavlin 45 _log "## socket error... sleeping for $sleep_on_error seconds and retry";
750 dpavlin 41 sleep($sleep_on_error);
751     $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);
752     },
753 dpavlin 11 # irc_433 => sub {
754     # print "# irc_433: ",$_[ARG1], "\n";
755     # warn "## indetify $NICK\n";
756     # $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" );
757     # },
758 dpavlin 4 _child => sub {},
759     _default => sub {
760 dpavlin 45 _log sprintf "sID:%s %s %s",
761     $_[SESSION]->ID, $_[ARG0],
762 dpavlin 34 ref($_[ARG1]) eq "ARRAY" ? join(",", map { ref($_) eq "ARRAY" ? join(";", @{$_}) : $_ } @{ $_[ARG1] }) :
763     $_[ARG1] ? $_[ARG1] :
764     "";
765 dpavlin 4 0; # false for signals
766     },
767     my_add => sub {
768     my $trailing = $_[ARG0];
769     my $session = $_[SESSION];
770     POE::Session->create
771     (inline_states =>
772     {_start => sub {
773     $_[HEAP]->{wheel} =
774     POE::Wheel::FollowTail->new
775     (
776     Filename => $FOLLOWS{$trailing},
777     InputEvent => 'got_line',
778     );
779     },
780     got_line => sub {
781     $_[KERNEL]->post($session => my_tailed =>
782     time, $trailing, $_[ARG0]);
783     },
784     },
785     );
786    
787     },
788     my_tailed => sub {
789     my ($time, $file, $line) = @_[ARG0..ARG2];
790     ## $time will be undef on a probe, or a time value if a real line
791    
792     ## PoCo::IRC has throttling built in, but no external visibility
793     ## so this is reaching "under the hood"
794     $SEND_QUEUE ||=
795     $_[KERNEL]->alias_resolve($IRC_ALIAS)->get_heap->{send_queue};
796    
797     ## handle "no need to keep skipping" transition
798     if ($SKIPPING and @$SEND_QUEUE < 1) {
799     $_[KERNEL]->post($IRC_ALIAS => privmsg => $CHANNEL =>
800     "[discarded $SKIPPING messages]");
801     $SKIPPING = 0;
802     }
803    
804     ## handle potential message display
805     if ($time) {
806     if ($SKIPPING or @$SEND_QUEUE > 3) { # 3 msgs per 10 seconds
807     $SKIPPING++;
808     } else {
809     my @time = localtime $time;
810     $_[KERNEL]->post($IRC_ALIAS => privmsg => $CHANNEL =>
811     sprintf "%02d:%02d:%02d: %s: %s",
812     ($time[2] + 11) % 12 + 1, $time[1], $time[0],
813     $file, $line);
814     }
815     }
816    
817     ## handle re-probe/flush if skipping
818     if ($SKIPPING) {
819     $_[KERNEL]->delay($_[STATE] => 0.5); # $time will be undef
820     }
821    
822     },
823     my_heartbeat => sub {
824     $_[KERNEL]->yield(my_tailed => time, "heartbeat", "beep");
825     $_[KERNEL]->delay($_[STATE] => 10);
826     }
827     },
828     );
829    
830 dpavlin 13 # http server
831    
832     my $httpd = POE::Component::Server::HTTP->new(
833 dpavlin 14 Port => $NICK =~ m/-dev/ ? 8001 : 8000,
834 dpavlin 13 ContentHandler => { '/' => \&root_handler },
835     Headers => { Server => 'irc-logger' },
836     );
837    
838 dpavlin 18 my %escape = ('<'=>'&lt;', '>'=>'&gt;', '&'=>'&amp;', '"'=>'&quot;');
839     my $escape_re = join '|' => keys %escape;
840    
841 dpavlin 13 my $style = <<'_END_OF_STYLE_';
842 dpavlin 16 p { margin: 0; padding: 0.1em; }
843 dpavlin 13 .time, .channel { color: #808080; font-size: 60%; }
844 dpavlin 28 .date { float: right; background: #e0e0e0; color: #404040; font-size: 120%; padding: 0.25em; border: 1px dashed #808080; }
845 dpavlin 20 .nick { color: #000000; font-size: 80%; padding: 2px; font-family: courier, courier new, monospace ; }
846 dpavlin 13 .message { color: #000000; font-size: 100%; }
847 dpavlin 16 .search { float: right; }
848 dpavlin 60 a:link.tag, a:visited.tag { border: 1px dashed #ccc; backgound: #ccc; text-decoration: none }
849     a:hover.tag { border: 1px solid #eee }
850     hr { border: 1px dashed #ccc; height: 1px; clear: both; }
851     /*
852 dpavlin 20 .col-0 { background: #ffff66 }
853     .col-1 { background: #a0ffff }
854     .col-2 { background: #99ff99 }
855     .col-3 { background: #ff9999 }
856     .col-4 { background: #ff66ff }
857 dpavlin 60 */
858 dpavlin 65 .calendar { border: 1px solid red; width: 100%; }
859     .month { border: 0px; width: 100%; }
860 dpavlin 13 _END_OF_STYLE_
861    
862 dpavlin 20 my $max_color = 4;
863    
864 dpavlin 60 my @cols = qw(
865     #ffcccc #ccffe6 #ccccff #e6ccff #ffccff #ffcce6 #ff9999 #ffcc99 #ffff99
866     #ccff99 #99ff99 #99ffcc #99ccff #9999ff #cc99ff #ff6666 #ffb366 #ffff66
867     #66ff66 #66ffb3 #66b3ff #6666ff #ff3333 #33ff33 #3399ff #3333ff #ff3399
868     #a0a0a0 #ff0000 #ffff00 #80ff00 #0000ff #8000ff #ff00ff #ff0080 #994d00
869     #999900 #009900 #cc0066 #c0c0c0 #ccff99 #99ff33 #808080 #660033 #ffffff
870     );
871    
872     $max_color = 0;
873     foreach my $c (@cols) {
874     $style .= ".col-${max_color} { background: $c }\n";
875     $max_color++;
876     }
877     warn "defined $max_color colors for users...\n";
878    
879 dpavlin 20 my %nick_enumerator;
880    
881 dpavlin 13 sub root_handler {
882     my ($request, $response) = @_;
883     $response->code(RC_OK);
884 dpavlin 14 $response->content_type("text/html; charset=$ENCODING");
885 dpavlin 16
886     my $q;
887    
888     if ( $request->method eq 'POST' ) {
889     $q = new CGI::Simple( $request->content );
890     } elsif ( $request->uri =~ /\?(.+)$/ ) {
891     $q = new CGI::Simple( $1 );
892     } else {
893     $q = new CGI::Simple;
894     }
895    
896     my $search = $q->param('search') || $q->param('grep') || '';
897    
898 dpavlin 35 my $html =
899 dpavlin 28 qq{<html><head><title>$NICK</title><style type="text/css">$style} .
900     $cloud->css .
901     qq{</style></head><body>} .
902     qq{
903 dpavlin 32 <form method="post" class="search" action="/">
904 dpavlin 16 <input type="text" name="search" value="$search" size="10">
905     <input type="submit" value="search">
906     </form>
907     } .
908 dpavlin 31 $cloud->html(500) .
909 dpavlin 35 qq{<p>};
910     if ($request->url =~ m#/history#) {
911     my $sth = $dbh->prepare(qq{
912 dpavlin 65 select date(time) as date,count(*) as nr,sum(length(message)) as len
913 dpavlin 35 from log
914     group by date(time)
915     order by date(time) desc
916     });
917     $sth->execute();
918     my ($l_yyyy,$l_mm) = (0,0);
919 dpavlin 65 $html .= qq{<table class="calendar"><tr>};
920 dpavlin 35 my $cal;
921 dpavlin 65 my $ord = 0;
922 dpavlin 35 while (my $row = $sth->fetchrow_hashref) {
923     # this is probably PostgreSQL specific, expects ISO date
924     my ($yyyy,$mm,$dd) = split(/-/, $row->{date});
925     if ($yyyy != $l_yyyy || $mm != $l_mm) {
926 dpavlin 65 if ( $cal ) {
927     $html .= qq{<td valign="top">} . $cal->as_HTML() . qq{</td>};
928     $ord++;
929     $html .= qq{</tr><tr>} if ( $ord % 3 == 0 );
930     }
931 dpavlin 35 $cal = new HTML::CalendarMonthSimple('month'=>$mm,'year'=>$yyyy);
932 dpavlin 65 $cal->border(1);
933     $cal->width('30%');
934     $cal->cellheight('5em');
935     $cal->tableclass('month');
936     #$cal->cellclass('day');
937     $cal->sunday('SUN');
938     $cal->saturday('SAT');
939     $cal->weekdays('MON','TUE','WED','THU','FRI');
940 dpavlin 35 ($l_yyyy,$l_mm) = ($yyyy,$mm);
941     }
942     $cal->setcontent($dd, qq{
943 dpavlin 65 <a href="/?date=$row->{date}">$row->{nr}</a><br/>$row->{len}
944 dpavlin 35 });
945 dpavlin 65
946 dpavlin 35 }
947 dpavlin 65 $html .= qq{<td valign="top">} . $cal->as_HTML() . qq{</td></tr></table>};
948 dpavlin 35
949     } else {
950     $html .= join("</p><p>",
951 dpavlin 13 get_from_log(
952 dpavlin 35 limit => $q->param('last') || $q->param('date') ? undef : 100,
953 dpavlin 28 search => $search || undef,
954 dpavlin 29 tag => $q->param('tag') || undef,
955 dpavlin 35 date => $q->param('date') || undef,
956 dpavlin 13 fmt => {
957 dpavlin 35 date => sub {
958     my $date = shift || return;
959 dpavlin 37 qq{<hr/><div class="date"><a href="/?date=$date">$date</a></div>};
960 dpavlin 35 },
961 dpavlin 13 time => '<span class="time">%s</span> ',
962     time_channel => '<span class="channel">%s %s</span> ',
963 dpavlin 20 nick => '%s:&nbsp;',
964     me_nick => '***%s&nbsp;',
965 dpavlin 13 message => '<span class="message">%s</span>',
966     },
967 dpavlin 20 filter => {
968     message => sub {
969     my $m = shift || return;
970 dpavlin 61
971     # protect HTML from wiki modifications
972     sub e {
973     my $t = shift;
974     return 'uri_unescape{' . uri_escape($t) . '}';
975     }
976    
977 dpavlin 20 $m =~ s/($escape_re)/$escape{$1}/gs;
978 dpavlin 61 $m =~ s#($RE{URI}{HTTP})#e(qq{<a href="$1">$1</a>})#egs;
979     $m =~ s#$tag_regex#e(qq{<a href="?tag=$1" class="tag">$1</a>})#egs;
980 dpavlin 59 $m =~ s#\*(\w+)\*#<b>$1</b>#gs;
981     $m =~ s#_(\w+)_#<u>$1</u>#gs;
982     $m =~ s#\/(\w+)\/#<i>$1</i>#gs;
983 dpavlin 61
984     $m =~ s#uri_unescape{([^}]+)}#uri_unescape($1)#egs;
985 dpavlin 20 return $m;
986     },
987     nick => sub {
988     my $n = shift || return;
989     if (! $nick_enumerator{$n}) {
990     my $max = scalar keys %nick_enumerator;
991     $nick_enumerator{$n} = $max + 1;
992     }
993     return '<span class="nick col-' .
994     ( $nick_enumerator{$n} % $max_color ) .
995     '">' . $n . '</span>';
996     },
997 dpavlin 15 },
998 dpavlin 13 )
999 dpavlin 35 );
1000     }
1001    
1002     $html .= qq{</p>
1003     <hr/>
1004     <p>See <a href="/history">history</a> of all messages.</p>
1005     </body></html>};
1006    
1007     $response->content( $html );
1008 dpavlin 13 return RC_OK;
1009     }
1010    
1011 dpavlin 4 POE::Kernel->run;

Properties

Name Value
svn:executable *

  ViewVC Help
Powered by ViewVC 1.1.26