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

revision 13 by dpavlin, Sun Mar 12 14:19:00 2006 UTC revision 15 by dpavlin, Mon Mar 13 12:56:26 2006 UTC
# Line 18  log all conversation on irc channel Line 18  log all conversation on irc channel
18    
19  ## CONFIG  ## CONFIG
20    
21  my $NICK = 'irc-logger-dev';  my $NICK = 'irc-logger';
22  my $CONNECT =  my $CONNECT =
23    {Server => 'irc.freenode.net',    {Server => 'irc.freenode.net',
24     Nick => $NICK,     Nick => $NICK,
# Line 35  my %FOLLOWS = Line 35  my %FOLLOWS =
35    
36  my $DSN = 'DBI:Pg:dbname=irc-logger';  my $DSN = 'DBI:Pg:dbname=irc-logger';
37    
38    my $ENCODING = 'ISO-8859-2';
39    
40  ## END CONFIG  ## END CONFIG
41    
42    
# Line 43  use POE qw(Component::IRC Wheel::FollowT Line 45  use POE qw(Component::IRC Wheel::FollowT
45  use HTTP::Status;  use HTTP::Status;
46  use DBI;  use DBI;
47  use Encode qw/from_to/;  use Encode qw/from_to/;
48    use Regexp::Common qw /URI/;
49    
50    
51  my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr;  my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr;
# Line 84  values (?,?,?) Line 87  values (?,?,?)
87                  nick => '%s: ',                  nick => '%s: ',
88                  message => '%s',                  message => '%s',
89          },          },
90            message_filter => sub {
91                    # modify message content
92                    return shift;
93            }
94   );   );
95    
96  =cut  =cut
# Line 157  sub get_from_log { Line 164  sub get_from_log {
164                          $append = 0;                          $append = 0;
165                  }                  }
166    
167                  $msg .= sprintf($args->{fmt}->{message}, $row->{message});                  if (ref($args->{message_filter}) eq 'CODE') {
168                            $msg .= sprintf($args->{fmt}->{message},
169                                    $args->{message_filter}->(
170                                            $row->{message}
171                                    )
172                            );
173                    } else {
174                            $msg .= sprintf($args->{fmt}->{message}, $row->{message});
175                    }
176    
177                  if ($append && @msgs) {                  if ($append && @msgs) {
178                          $msgs[$#msgs] .= " " . $msg;                          $msgs[$#msgs] .= " " . $msg;
# Line 196  POE::Session->create Line 211  POE::Session->create
211                  my $channel = $_[ARG1]->[0];                  my $channel = $_[ARG1]->[0];
212                  my $msg = $_[ARG2];                  my $msg = $_[ARG2];
213    
214                  from_to($msg, 'UTF-8', 'ISO-8859-2');                  from_to($msg, 'UTF-8', $ENCODING);
215    
216                  print "$channel: <$nick> $msg\n";                  print "$channel: <$nick> $msg\n";
217                  $sth->execute($channel, $nick, $msg);                  $sth->execute($channel, $nick, $msg);
# Line 205  POE::Session->create Line 220  POE::Session->create
220                  my $kernel = $_[KERNEL];                  my $kernel = $_[KERNEL];
221                  my $nick = (split /!/, $_[ARG0])[0];                  my $nick = (split /!/, $_[ARG0])[0];
222                  my $msg = $_[ARG2];                  my $msg = $_[ARG2];
223                  from_to($msg, 'UTF-8', 'ISO-8859-2');                  from_to($msg, 'UTF-8', $ENCODING);
224    
225                  my $res = "unknown command '$msg', try /msg $NICK help!";                  my $res = "unknown command '$msg', try /msg $NICK help!";
226                  my @out;                  my @out;
# Line 240  POE::Session->create Line 255  POE::Session->create
255    
256                          foreach my $res (get_from_log( limit => $1 )) {                          foreach my $res (get_from_log( limit => $1 )) {
257                                  print "last: $res\n";                                  print "last: $res\n";
258                                  from_to($res, 'ISO-8859-2', 'UTF-8');                                  from_to($res, $ENCODING, 'UTF-8');
259                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
260                          }                          }
261    
# Line 252  POE::Session->create Line 267  POE::Session->create
267    
268                          foreach my $res (get_from_log( limit => 20, search => "%${what}%" )) {                          foreach my $res (get_from_log( limit => 20, search => "%${what}%" )) {
269                                  print "search [$what]: $res\n";                                  print "search [$what]: $res\n";
270                                  from_to($res, 'ISO-8859-2', 'UTF-8');                                  from_to($res, $ENCODING, 'UTF-8');
271                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
272                          }                          }
273    
# Line 262  POE::Session->create Line 277  POE::Session->create
277    
278                  if ($res) {                  if ($res) {
279                          print ">> [$nick] $res\n";                          print ">> [$nick] $res\n";
280                          from_to($res, 'ISO-8859-2', 'UTF-8');                          from_to($res, $ENCODING, 'UTF-8');
281                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
282                  }                  }
283    
# Line 378  POE::Session->create Line 393  POE::Session->create
393  # http server  # http server
394    
395  my $httpd = POE::Component::Server::HTTP->new(  my $httpd = POE::Component::Server::HTTP->new(
396          Port => 8000,          Port => $NICK =~ m/-dev/ ? 8001 : 8000,
397          ContentHandler => { '/' => \&root_handler },          ContentHandler => { '/' => \&root_handler },
398          Headers        => { Server => 'irc-logger' },          Headers        => { Server => 'irc-logger' },
399  );  );
# Line 392  _END_OF_STYLE_ Line 407  _END_OF_STYLE_
407  sub root_handler {  sub root_handler {
408          my ($request, $response) = @_;          my ($request, $response) = @_;
409          $response->code(RC_OK);          $response->code(RC_OK);
410          $response->content_type('text/html');          $response->content_type("text/html; charset=$ENCODING");
411          $response->content(          $response->content(
412                  qq{<html><head><title>$NICK</title><style type="text/css">$style</style></head><body>} .                  qq{<html><head><title>$NICK</title><style type="text/css">$style</style></head><body>} .
413                  "irc-logger url: " . $request->uri . '<br/>' .                  "irc-logger url: " . $request->uri . '<br/>' .
# Line 405  sub root_handler { Line 420  sub root_handler {
420                                          nick => '<span class="nick">%s:</span> ',                                          nick => '<span class="nick">%s:</span> ',
421                                          message => '<span class="message">%s</span>',                                          message => '<span class="message">%s</span>',
422                                  },                                  },
423                                    message_filter => sub {
424                                            my $m = shift || return;
425                                            $m =~ s#($RE{URI}{HTTP})#<a href="$1">$1</a>#gs;
426                                            return $m;
427                                    },
428                          )                          )
429                  ) .                  ) .
430                  qq{</body></html>}                  qq{</body></html>}
Legend:
Removed from v.13  
changed lines
  Added in v.15
  ViewVC Help
Powered by ViewVC 1.1.26