/[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

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

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

trunk/irc-logger.pl revision 41 by dpavlin, Tue Oct 24 12:51:49 2006 UTC trunk/bin/irc-logger.pl revision 67 by dpavlin, Sat Sep 29 13:13:41 2007 UTC
# Line 18  irc-logger.pl Line 18  irc-logger.pl
18    
19  Import log from C<dircproxy> to C<irc-logger> database  Import log from C<dircproxy> to C<irc-logger> database
20    
21    =item --log=irc-logger.log
22    
23    Name of log file
24    
25    =back
26    
27  =head1 DESCRIPTION  =head1 DESCRIPTION
28    
29  log all conversation on irc channel  log all conversation on irc channel
# Line 67  use POSIX qw/strftime/; Line 73  use POSIX qw/strftime/;
73  use HTML::CalendarMonthSimple;  use HTML::CalendarMonthSimple;
74  use Getopt::Long;  use Getopt::Long;
75  use DateTime;  use DateTime;
76    use URI::Escape;
77    use Data::Dump qw/dump/;
78    use DateTime::Format::ISO8601;
79    
80    my $use_twitter = 1;
81    eval { require Net::Twitter; };
82    $use_twitter = 0 if ($@);
83    
84  my $import_dircproxy;  my $import_dircproxy;
85    my $log_path;
86  GetOptions(  GetOptions(
87          'import-dircproxy:s' => \$import_dircproxy,          'import-dircproxy:s' => \$import_dircproxy,
88            'log:s' => \$log_path,
89  );  );
90    
91  my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr;  open(STDOUT, '>', $log_path) || warn "can't redirect log to $log_path: $!";
92    
93  eval {  sub _log {
94          $dbh->do(qq{ select count(*) from log });          print strftime($TIMESTAMP,localtime()), ' ', join(" ",@_), $/;
95  };  }
96    
97  if ($@) {  my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr;
         warn "creating database table in $DSN\n";  
         $dbh->do(<<'_SQL_SCHEMA_');  
98    
99    my $sql_schema = {
100            log => '
101  create table log (  create table log (
102          id serial,          id serial,
103          time timestamp default now(),          time timestamp default now(),
# Line 96  create table log ( Line 111  create table log (
111  create index log_time on log(time);  create index log_time on log(time);
112  create index log_channel on log(channel);  create index log_channel on log(channel);
113  create index log_nick on log(nick);  create index log_nick on log(nick);
114            ',
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    
127  _SQL_SCHEMA_  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  }  }
138    
139    
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  my $sth = $dbh->prepare(qq{  my $sth = $dbh->prepare(qq{
189  insert into log  insert into log
190          (channel, me, nick, message, time)          (channel, me, nick, message, time)
191  values (?,?,?,?,?)  values (?,?,?,?,?)
192  });  });
193    
194    
195  my $tags;  my $tags;
196  my $tag_regex = '\b([\w-_]+)//';  my $tag_regex = '\b([\w-_]+)//';
197    
# Line 128  my $tag_regex = '\b([\w-_]+)//'; Line 214  my $tag_regex = '\b([\w-_]+)//';
214                  }                  }
215          },          },
216          context => 5,          context => 5,
217            full_rows => 1,
218   );   );
219    
220  Order is important. Fields are first passed through C<filter> (if available) and  Order is important. Fields are first passed through C<filter> (if available) and
# Line 135  then throgh C<< sprintf($fmt->{message}, Line 222  then throgh C<< sprintf($fmt->{message},
222    
223  C<context> defines number of messages around each search hit for display.  C<context> defines number of messages around each search hit for display.
224    
225    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  =cut  =cut
229    
230  sub get_from_log {  sub get_from_log {
# Line 170  sub get_from_log { Line 260  sub get_from_log {
260    
261          my $sql = $context ? $sql_context : $sql_message;          my $sql = $context ? $sql_context : $sql_message;
262    
263            sub check_date {
264                    my $date = shift;
265                    $date = eval { DateTime::Format::ISO8601->parse_datetime( $args->{date} )->ymd; };
266                    if ( $@ ) {
267                            warn "invalid date ", $args->{date}, $/;
268                            $date = DateTime->now->ymd;
269                    }
270                    return $date;
271            }
272    
273          $sql .= " where message ilike ? or nick ilike ? " if ($args->{search});          $sql .= " where message ilike ? or nick ilike ? " if ($args->{search});
274          $sql .= " where id in (" . join(",", @{ $tags->{ $args->{tag} } }) . ") " if ($args->{tag} && $tags->{ $args->{tag} });          $sql .= " where id in (" . join(",", @{ $tags->{ $args->{tag} } }) . ") " if ($args->{tag} && $tags->{ $args->{tag} });
275          $sql .= " where date(time) = ? " if ($args->{date});          if ($args->{date}) {
276                    $sql .= " where date(time) = ? ";
277                    $args->{date} = check_date( $args->{date} );
278            }
279          $sql .= " order by log.time desc";          $sql .= " order by log.time desc";
280          $sql .= " limit " . $args->{limit} if ($args->{limit});          $sql .= " limit " . $args->{limit} if ($args->{limit});
281    
# Line 181  sub get_from_log { Line 284  sub get_from_log {
284                  $search =~ s/^\s+//;                  $search =~ s/^\s+//;
285                  $search =~ s/\s+$//;                  $search =~ s/\s+$//;
286                  $sth->execute( ( '%' . $search . '%' ) x 2 );                  $sth->execute( ( '%' . $search . '%' ) x 2 );
287                  warn "search for '$search' returned ", $sth->rows, " results ", $context || '', "\n";                  _log "search for '$search' returned ", $sth->rows, " results ", $context || '';
288          } elsif (my $tag = $args->{tag}) {          } elsif (my $tag = $args->{tag}) {
289                  $sth->execute();                  $sth->execute();
290                  warn "tag '$tag' returned ", $sth->rows, " results ", $context || '', "\n";                  _log "tag '$tag' returned ", $sth->rows, " results ", $context || '';
291          } elsif (my $date = $args->{date}) {          } elsif (my $date = $args->{date}) {
292                  $sth->execute($date);                  $sth->execute( check_date($date) );
293                  warn "found ", $sth->rows, " messages for date $date ", $context || '', "\n";                  _log "found ", $sth->rows, " messages for date $date ", $context || '';
294          } else {          } else {
295                  $sth->execute();                  $sth->execute();
296          }          }
# Line 204  sub get_from_log { Line 307  sub get_from_log {
307                  unshift @rows, $row;                  unshift @rows, $row;
308          }          }
309    
310            # normalize nick names
311            map {
312                    $_->{nick} =~ s/^_*(.*?)_*$/$1/
313            } @rows;
314    
315            return @rows if ($args->{full_rows});
316    
317          my @msgs = (          my @msgs = (
318                  "Showing " . ($#rows + 1) . " messages..."                  "Showing " . ($#rows + 1) . " messages..."
319          );          );
# Line 260  sub get_from_log { Line 370  sub get_from_log {
370                  my $append = 1;                  my $append = 1;
371    
372                  my $nick = $row->{nick};                  my $nick = $row->{nick};
373                  if ($nick =~ s/^_*(.*?)_*$/$1/) {  #               if ($nick =~ s/^_*(.*?)_*$/$1/) {
374                          $row->{nick} = $nick;  #                       $row->{nick} = $nick;
375                  }  #               }
376    
377                  if ($last_row->{nick} ne $nick) {                  if ($last_row->{nick} ne $nick) {
378                          # obfu way to find format for me_nick if needed or fallback to default                          # obfu way to find format for me_nick if needed or fallback to default
# Line 367  sub save_message { Line 477  sub save_message {
477          $a->{me} ||= 0;          $a->{me} ||= 0;
478          $a->{time} ||= strftime($TIMESTAMP,localtime());          $a->{time} ||= strftime($TIMESTAMP,localtime());
479    
480          print          _log
                 $a->{time}, " ",  
481                  $a->{channel}, " ",                  $a->{channel}, " ",
482                  $a->{me} ? "***" . $a->{nick} : "<" . $a->{nick} . ">",                  $a->{me} ? "***" . $a->{nick} : "<" . $a->{nick} . ">",
483                  " " . $a->{msg} . "\n";                  " " . $a->{msg};
484    
485          from_to($a->{msg}, 'UTF-8', $ENCODING);          from_to($a->{msg}, 'UTF-8', $ENCODING);
486    
# Line 380  sub save_message { Line 489  sub save_message {
489                  message => $a->{msg});                  message => $a->{msg});
490  }  }
491    
492    
493  if ($import_dircproxy) {  if ($import_dircproxy) {
494          open(my $l, $import_dircproxy) || die "can't open $import_dircproxy: $!";          open(my $l, $import_dircproxy) || die "can't open $import_dircproxy: $!";
495          warn "importing $import_dircproxy...\n";          warn "importing $import_dircproxy...\n";
# Line 406  if ($import_dircproxy) { Line 516  if ($import_dircproxy) {
516                          ) if ($nick !~ m/^-/);                          ) if ($nick !~ m/^-/);
517    
518                  } else {                  } else {
519                          warn "can't parse: $_\n";                          _log "can't parse: $_";
520                  }                  }
521          }          }
522          close($l);          close($l);
# Line 421  if ($import_dircproxy) { Line 531  if ($import_dircproxy) {
531    
532  my $SKIPPING = 0;               # if skipping, how many we've done  my $SKIPPING = 0;               # if skipping, how many we've done
533  my $SEND_QUEUE;                 # cache  my $SEND_QUEUE;                 # cache
534    my $ping;                                               # ping stats
535    
536  POE::Component::IRC->new($IRC_ALIAS);  POE::Component::IRC->new($IRC_ALIAS);
537    
# Line 443  POE::Session->create( inline_states => Line 554  POE::Session->create( inline_states =>
554                  my $msg = $_[ARG2];                  my $msg = $_[ARG2];
555    
556                  save_message( channel => $channel, me => 0, nick => $nick, msg => $msg);                  save_message( channel => $channel, me => 0, nick => $nick, msg => $msg);
557                    meta( $nick, $channel, 'last-msg', $msg );
558      },      },
559      irc_ctcp_action => sub {      irc_ctcp_action => sub {
560                  my $kernel = $_[KERNEL];                  my $kernel = $_[KERNEL];
# Line 451  POE::Session->create( inline_states => Line 563  POE::Session->create( inline_states =>
563                  my $msg = $_[ARG2];                  my $msg = $_[ARG2];
564    
565                  save_message( channel => $channel, me => 1, nick => $nick, msg => $msg);                  save_message( channel => $channel, me => 1, nick => $nick, msg => $msg);
566    
567                    if ( $use_twitter ) {
568                            if ( my $twitter = meta( $nick, $NICK, 'twitter' ) ) {
569                                    my ($login,$passwd) = split(/\s+/,$twitter,2);
570                                    _log("sending twitter for $nick/$login on $channel ");
571                                    my $bot = Net::Twitter->new( username=>$login, password=>$passwd );
572                                    $bot->update("<${channel}> $msg");
573                            }
574                    }
575    
576      },      },
577            irc_ping => sub {
578                    warn "pong ", $_[ARG0], $/;
579                    $ping->{ $_[ARG0] }++;
580            },
581            irc_invite => sub {
582                    my $kernel = $_[KERNEL];
583                    my $nick = (split /!/, $_[ARG0])[0];
584                    my $channel = $_[ARG1];
585    
586                    warn "invited to $channel by $nick";
587    
588                    $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, "how nice of you to invite me to $channel, I'll be right there..." );
589                    $_[KERNEL]->post($IRC_ALIAS => join => $channel);
590    
591            },
592          irc_msg => sub {          irc_msg => sub {
593                  my $kernel = $_[KERNEL];                  my $kernel = $_[KERNEL];
594                  my $nick = (split /!/, $_[ARG0])[0];                  my $nick = (split /!/, $_[ARG0])[0];
595                  my $msg = $_[ARG2];                  my $msg = $_[ARG2];
596                    my $channel = $_[ARG1]->[0];
597                  from_to($msg, 'UTF-8', $ENCODING);                  from_to($msg, 'UTF-8', $ENCODING);
598    
599                  my $res = "unknown command '$msg', try /msg $NICK help!";                  my $res = "unknown command '$msg', try /msg $NICK help!";
600                  my @out;                  my @out;
601    
602                  print "<< $msg\n";                  _log "<< $msg";
603    
604                  if ($msg =~ m/^help/i) {                  if ($msg =~ m/^help/i) {
605    
# Line 469  POE::Session->create( inline_states => Line 607  POE::Session->create( inline_states =>
607    
608                  } elsif ($msg =~ m/^msg\s+(\S+)\s+(.*)$/i) {                  } elsif ($msg =~ m/^msg\s+(\S+)\s+(.*)$/i) {
609    
610                          print ">> /msg $1 $2\n";                          _log ">> /msg $1 $2";
611                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $1, $2 );                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $1, $2 );
612                          $res = '';                          $res = '';
613    
# Line 479  POE::Session->create( inline_states => Line 617  POE::Session->create( inline_states =>
617    
618                          my $sth = $dbh->prepare(qq{                          my $sth = $dbh->prepare(qq{
619                                  select                                  select
620                                          nick,                                          trim(both '_' from nick) as nick,
621                                          count(*) as count,                                          count(*) as count,
622                                          sum(length(message)) as len                                          sum(length(message)) as len
623                                  from log                                  from log
624                                  group by nick                                  group by trim(both '_' from nick)
625                                  order by len desc,count desc                                  order by len desc,count desc
626                                  limit $nr                                  limit $nr
627                          });                          });
# Line 496  POE::Session->create( inline_states => Line 634  POE::Session->create( inline_states =>
634                          $res .= join(" | ", @users);                          $res .= join(" | ", @users);
635                  } elsif ($msg =~ m/^last.*?\s*(\d*)/i) {                  } elsif ($msg =~ m/^last.*?\s*(\d*)/i) {
636    
637                          foreach my $res (get_from_log( limit => ($1 || 100) )) {                          my $limit = $1 || meta( $nick, $channel, 'last-size' ) || 10;
638                                  print "last: $res\n";  
639                            foreach my $res (get_from_log( limit => $limit )) {
640                                    _log "last: $res";
641                                  from_to($res, $ENCODING, 'UTF-8');                                  from_to($res, $ENCODING, 'UTF-8');
642                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
643                          }                          }
# Line 512  POE::Session->create( inline_states => Line 652  POE::Session->create( inline_states =>
652                                          limit => 20,                                          limit => 20,
653                                          search => $what,                                          search => $what,
654                                  )) {                                  )) {
655                                  print "search [$what]: $res\n";                                  _log "search [$what]: $res";
656                                  from_to($res, $ENCODING, 'UTF-8');                                  from_to($res, $ENCODING, 'UTF-8');
657                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
658                          }                          }
659    
660                          $res = '';                          $res = '';
661    
662                    } elsif ($msg =~ m/^(?:count|poll)\s+(.*)(?:\s+(\d+))?\s*$/i) {
663    
664                            my ($what,$limit) = ($1,$2);
665                            $limit ||= 100;
666    
667                            my $stat;
668    
669                            foreach my $res (get_from_log(
670                                            limit => $limit,
671                                            search => $what,
672                                            full_rows => 1,
673                                    )) {
674                                    while ($res->{message} =~ s/\Q$what\E(\+|\-)//) {
675                                            $stat->{vote}->{$1}++;
676                                            $stat->{from}->{ $res->{nick} }++;
677                                    }
678                            }
679    
680                            my @nicks;
681                            foreach my $nick (sort { $stat->{from}->{$a} <=> $stat->{from}->{$b} } keys %{ $stat->{from} }) {
682                                    push @nicks, $nick . ( $stat->{from}->{$nick} == 1 ? '' :
683                                            "(" . $stat->{from}->{$nick} . ")"
684                                    );
685                            }
686    
687                            $res =
688                                    "$what ++ " . ( $stat->{vote}->{'+'} || 0 ) .
689                                    " : " . ( $stat->{vote}->{'-'} || 0 ) . " --" .
690                                    " from " . ( join(", ", @nicks) || 'nobody' );
691    
692                            $_[KERNEL]->post( $IRC_ALIAS => notice => $nick, $res );
693    
694                    } elsif ($msg =~ m/^ping/) {
695                            $res = "ping = " . dump( $ping );
696                    } elsif ($msg =~ m/^conf(?:ig)*\s*(last-size|twitter)*\s*(.*)/) {
697                            if ( ! defined( $1 ) ) {
698                                    my $sth = $dbh->prepare(qq{ select name,value,changed from meta where nick = ? and channel = ? });
699                                    $sth->execute( $nick, $channel );
700                                    $res = "config for $nick on $channel";
701                                    while ( my ($n,$v) = $sth->fetchrow_array ) {
702                                            $res .= " | $n = $v";
703                                    }
704                            } elsif ( ! $2 ) {
705                                    my $val = meta( $nick, $channel, $1 );
706                                    $res = "current $1 = " . ( $val ? $val : 'undefined' );
707                            } else {
708                                    my $validate = {
709                                            'last-size' => qr/^\d+/,
710                                            'twitter' => qr/^\w+\s+\w+/,
711                                    };
712    
713                                    my ( $op, $val ) = ( $1, $2 );
714    
715                                    if ( my $regex = $validate->{$op} ) {
716                                            if ( $val =~ $regex ) {
717                                                    meta( $nick, $channel, $op, $val );
718                                                    $res = "saved $op = $val";
719                                            } else {
720                                                    $res = "config option $op = $val doesn't validate against $regex";
721                                            }
722                                    } else {
723                                            $res = "config option $op doesn't exist";
724                                    }
725                            }
726                  }                  }
727    
728                  if ($res) {                  if ($res) {
729                          print ">> [$nick] $res\n";                          _log ">> [$nick] $res";
730                          from_to($res, $ENCODING, 'UTF-8');                          from_to($res, $ENCODING, 'UTF-8');
731                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
732                  }                  }
733    
734          },          },
735          irc_477 => sub {          irc_477 => sub {
736                  print "# irc_477: ",$_[ARG1], "\n";                  _log "# irc_477: ",$_[ARG1];
737                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );
738          },          },
739          irc_505 => sub {          irc_505 => sub {
740                  print "# irc_505: ",$_[ARG1], "\n";                  _log "# irc_505: ",$_[ARG1];
741                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );
742  #               $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set hide email on" );  #               $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set hide email on" );
743  #               $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set email dpavlin\@rot13.org" );  #               $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set email dpavlin\@rot13.org" );
744          },          },
745          irc_registered => sub {          irc_registered => sub {
746                  warn "## indetify $NICK\n";                  _log "## registrated $NICK";
747                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" );                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" );
748          },          },
749          irc_disconnected => sub {          irc_disconnected => sub {
750                  warn "## disconnected, reconnecting again\n";                  _log "## disconnected, reconnecting again";
751                  $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);                  $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);
752          },          },
753          irc_socketerr => sub {          irc_socketerr => sub {
754                  warn "## socket error... sleeping for $sleep_on_error seconds and retry";                  _log "## socket error... sleeping for $sleep_on_error seconds and retry";
755                  sleep($sleep_on_error);                  sleep($sleep_on_error);
756                  $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);                  $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);
757          },          },
# Line 558  POE::Session->create( inline_states => Line 762  POE::Session->create( inline_states =>
762  #       },  #       },
763      _child => sub {},      _child => sub {},
764      _default => sub {      _default => sub {
765                  printf "%s #%s %s %s\n",                  _log sprintf "sID:%s %s %s",
766                          strftime($TIMESTAMP,localtime()), $_[SESSION]->ID, $_[ARG0],                          $_[SESSION]->ID, $_[ARG0],
767                          ref($_[ARG1]) eq "ARRAY"        ?       join(",", map { ref($_) eq "ARRAY" ? join(";", @{$_}) : $_ } @{ $_[ARG1] })     :                          ref($_[ARG1]) eq "ARRAY"        ?       join(",", map { ref($_) eq "ARRAY" ? join(";", @{$_}) : $_ } @{ $_[ARG1] })     :
768                          $_[ARG1]                                        ?       $_[ARG1]                                        :                          $_[ARG1]                                        ?       $_[ARG1]                                        :
769                          "";                          "";
# Line 646  p { margin: 0; padding: 0.1em; } Line 850  p { margin: 0; padding: 0.1em; }
850  .nick { color: #000000; font-size: 80%; padding: 2px; font-family: courier, courier new, monospace ; }  .nick { color: #000000; font-size: 80%; padding: 2px; font-family: courier, courier new, monospace ; }
851  .message { color: #000000; font-size: 100%; }  .message { color: #000000; font-size: 100%; }
852  .search { float: right; }  .search { float: right; }
853    a:link.tag, a:visited.tag { border: 1px dashed #ccc; backgound: #ccc; text-decoration: none }
854    a:hover.tag { border: 1px solid #eee }
855    hr { border: 1px dashed #ccc; height: 1px; clear: both; }
856    /*
857  .col-0 { background: #ffff66 }  .col-0 { background: #ffff66 }
858  .col-1 { background: #a0ffff }  .col-1 { background: #a0ffff }
859  .col-2 { background: #99ff99 }  .col-2 { background: #99ff99 }
860  .col-3 { background: #ff9999 }  .col-3 { background: #ff9999 }
861  .col-4 { background: #ff66ff }  .col-4 { background: #ff66ff }
862  a:link.tag, a:visited.tag { border: 1px dashed #ccc; backgound: #ccc; text-decoration: none }  */
863  a:hover.tag { border: 1px solid #eee }  .calendar { border: 1px solid red; width: 100%; }
864  hr { border: 1px dashed #ccc; height: 1px; clear: both; }  .month { border: 0px; width: 100%; }
865  _END_OF_STYLE_  _END_OF_STYLE_
866    
867  my $max_color = 4;  my $max_color = 4;
868    
869    my @cols = qw(
870            #ffcccc #ccffe6 #ccccff #e6ccff #ffccff #ffcce6 #ff9999 #ffcc99 #ffff99
871            #ccff99 #99ff99 #99ffcc #99ccff #9999ff #cc99ff #ff6666 #ffb366 #ffff66
872            #66ff66 #66ffb3 #66b3ff #6666ff #ff3333 #33ff33 #3399ff #3333ff #ff3399
873            #a0a0a0 #ff0000 #ffff00 #80ff00 #0000ff #8000ff #ff00ff #ff0080 #994d00
874            #999900 #009900 #cc0066 #c0c0c0 #ccff99 #99ff33 #808080 #660033 #ffffff
875    );
876    
877    $max_color = 0;
878    foreach my $c (@cols) {
879            $style .= ".col-${max_color} { background: $c }\n";
880            $max_color++;
881    }
882    warn "defined $max_color colors for users...\n";
883    
884  my %nick_enumerator;  my %nick_enumerator;
885    
886  sub root_handler {  sub root_handler {
# Line 691  sub root_handler { Line 914  sub root_handler {
914                  qq{<p>};                  qq{<p>};
915          if ($request->url =~ m#/history#) {          if ($request->url =~ m#/history#) {
916                  my $sth = $dbh->prepare(qq{                  my $sth = $dbh->prepare(qq{
917                          select date(time) as date,count(*) as nr                          select date(time) as date,count(*) as nr,sum(length(message)) as len
918                                  from log                                  from log
919                                  group by date(time)                                  group by date(time)
920                                  order by date(time) desc                                  order by date(time) desc
921                  });                  });
922                  $sth->execute();                  $sth->execute();
923                  my ($l_yyyy,$l_mm) = (0,0);                  my ($l_yyyy,$l_mm) = (0,0);
924                    $html .= qq{<table class="calendar"><tr>};
925                  my $cal;                  my $cal;
926                    my $ord = 0;
927                  while (my $row = $sth->fetchrow_hashref) {                  while (my $row = $sth->fetchrow_hashref) {
928                          # this is probably PostgreSQL specific, expects ISO date                          # this is probably PostgreSQL specific, expects ISO date
929                          my ($yyyy,$mm,$dd) = split(/-/, $row->{date});                          my ($yyyy,$mm,$dd) = split(/-/, $row->{date});
930                          if ($yyyy != $l_yyyy || $mm != $l_mm) {                          if ($yyyy != $l_yyyy || $mm != $l_mm) {
931                                  $html .= $cal->as_HTML() if ($cal);                                  if ( $cal ) {
932                                            $html .= qq{<td valign="top">} . $cal->as_HTML() . qq{</td>};
933                                            $ord++;
934                                            $html .= qq{</tr><tr>} if ( $ord % 3 == 0 );
935                                    }
936                                  $cal = new HTML::CalendarMonthSimple('month'=>$mm,'year'=>$yyyy);                                  $cal = new HTML::CalendarMonthSimple('month'=>$mm,'year'=>$yyyy);
937                                  $cal->border(2);                                  $cal->border(1);
938                                    $cal->width('30%');
939                                    $cal->cellheight('5em');
940                                    $cal->tableclass('month');
941                                    #$cal->cellclass('day');
942                                    $cal->sunday('SUN');
943                                    $cal->saturday('SAT');
944                                    $cal->weekdays('MON','TUE','WED','THU','FRI');
945                                  ($l_yyyy,$l_mm) = ($yyyy,$mm);                                  ($l_yyyy,$l_mm) = ($yyyy,$mm);
946                          }                          }
947                          $cal->setcontent($dd, qq{                          $cal->setcontent($dd, qq{
948                                  <a href="/?date=$row->{date}">$row->{nr}</a>                                  <a href="/?date=$row->{date}">$row->{nr}</a><br/>$row->{len}
949                          });                          });
950                            
951                  }                  }
952                  $html .= $cal->as_HTML() if ($cal);                  $html .= qq{<td valign="top">} . $cal->as_HTML() . qq{</td></tr></table>};
953    
954          } else {          } else {
955                  $html .= join("</p><p>",                  $html .= join("</p><p>",
# Line 720  sub root_handler { Line 957  sub root_handler {
957                                  limit => $q->param('last') || $q->param('date') ? undef : 100,                                  limit => $q->param('last') || $q->param('date') ? undef : 100,
958                                  search => $search || undef,                                  search => $search || undef,
959                                  tag => $q->param('tag') || undef,                                  tag => $q->param('tag') || undef,
960                                  date => $q->param('date') || undef,                                  date => check_date( $q->param('date') ),
961                                  fmt => {                                  fmt => {
962                                          date => sub {                                          date => sub {
963                                                  my $date = shift || return;                                                  my $date = shift || return;
# Line 735  sub root_handler { Line 972  sub root_handler {
972                                  filter => {                                  filter => {
973                                          message => sub {                                          message => sub {
974                                                  my $m = shift || return;                                                  my $m = shift || return;
975    
976                                                    # protect HTML from wiki modifications
977                                                    sub e {
978                                                            my $t = shift;
979                                                            return 'uri_unescape{' . uri_escape($t) . '}';
980                                                    }
981    
982                                                  $m =~ s/($escape_re)/$escape{$1}/gs;                                                  $m =~ s/($escape_re)/$escape{$1}/gs;
983                                                  $m =~ s#($RE{URI}{HTTP})#<a href="$1">$1</a>#gs;                                                  $m =~ s#($RE{URI}{HTTP})#e(qq{<a href="$1">$1</a>})#egs;
984                                                  $m =~ s#$tag_regex#<a href="?tag=$1" class="tag">$1</a>#g;                                                  $m =~ s#$tag_regex#e(qq{<a href="?tag=$1" class="tag">$1</a>})#egs;
985                                                    $m =~ s#\*(\w+)\*#<b>$1</b>#gs;
986                                                    $m =~ s#_(\w+)_#<u>$1</u>#gs;
987                                                    $m =~ s#\/(\w+)\/#<i>$1</i>#gs;
988    
989                                                    $m =~ s#uri_unescape{([^}]+)}#uri_unescape($1)#egs;
990                                                  return $m;                                                  return $m;
991                                          },                                          },
992                                          nick => sub {                                          nick => sub {
Legend:
Removed from v.41  
changed lines
  Added in v.67
  ViewVC Help
Powered by ViewVC 1.1.26