/[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 12 by dpavlin, Sun Mar 12 13:33:20 2006 UTC revision 14 by dpavlin, Sun Mar 12 14:36:12 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    
43    
44  use POE qw(Component::IRC Wheel::FollowTail);  use POE qw(Component::IRC Wheel::FollowTail Component::Server::HTTP);
45    use HTTP::Status;
46  use DBI;  use DBI;
47  use Encode qw/from_to/;  use Encode qw/from_to/;
48    
# Line 77  values (?,?,?) Line 80  values (?,?,?)
80   my @messages = get_from_log(   my @messages = get_from_log(
81          limit => 42,          limit => 42,
82          search => '%what to stuff in ilike%',          search => '%what to stuff in ilike%',
83            fmt => {
84                    time => '{%s} ',
85                    time_channel => '{%s %s} ',
86                    nick => '%s: ',
87                    message => '%s',
88            },
89   );   );
90    
91  =cut  =cut
# Line 86  sub get_from_log { Line 95  sub get_from_log {
95    
96          $args->{limit} ||= 10;          $args->{limit} ||= 10;
97    
98            $args->{fmt} ||= {
99                    time => '{%s} ',
100                    time_channel => '{%s %s} ',
101                    nick => '%s: ',
102                    message => '%s',
103            };
104    
105          my $sql = qq{          my $sql = qq{
106                  select                  select
107                          time::date as date,                          time::date as date,
# Line 130  sub get_from_log { Line 146  sub get_from_log {
146    
147                  my $msg = '';                  my $msg = '';
148    
149                  $msg .= "{$t";                  if ($last_row->{channel} ne $row->{channel}) {
150                  $msg .= ' ' . $row->{channel} if ($last_row->{channel} ne $row->{channel});                          $msg .= sprintf($args->{fmt}->{time_channel}, $t, $row->{channel});
151                  $msg .= "} ";                  } else {
152                            $msg .= sprintf($args->{fmt}->{time}, $t);
153                    }
154    
155                  my $append = 1;                  my $append = 1;
156    
157                  if ($last_row->{nick} ne $row->{nick}) {                  if ($last_row->{nick} ne $row->{nick}) {
158                          $msg .= $row->{nick} . ': ';                          $msg .= sprintf($args->{fmt}->{nick}, $row->{nick});
159                          $append = 0;                          $append = 0;
160                  }                  }
161    
162                  $msg .= $row->{message};                  $msg .= sprintf($args->{fmt}->{message}, $row->{message});
163    
164                  if ($append && @msgs) {                  if ($append && @msgs) {
165                          $msgs[$#msgs] .= " " . $msg;                          $msgs[$#msgs] .= " " . $msg;
# Line 180  POE::Session->create Line 198  POE::Session->create
198                  my $channel = $_[ARG1]->[0];                  my $channel = $_[ARG1]->[0];
199                  my $msg = $_[ARG2];                  my $msg = $_[ARG2];
200    
201                  from_to($msg, 'UTF-8', 'ISO-8859-2');                  from_to($msg, 'UTF-8', $ENCODING);
202    
203                  print "$channel: <$nick> $msg\n";                  print "$channel: <$nick> $msg\n";
204                  $sth->execute($channel, $nick, $msg);                  $sth->execute($channel, $nick, $msg);
# Line 189  POE::Session->create Line 207  POE::Session->create
207                  my $kernel = $_[KERNEL];                  my $kernel = $_[KERNEL];
208                  my $nick = (split /!/, $_[ARG0])[0];                  my $nick = (split /!/, $_[ARG0])[0];
209                  my $msg = $_[ARG2];                  my $msg = $_[ARG2];
210                  from_to($msg, 'UTF-8', 'ISO-8859-2');                  from_to($msg, 'UTF-8', $ENCODING);
211    
212                  my $res = "unknown command '$msg', try /msg $NICK help!";                  my $res = "unknown command '$msg', try /msg $NICK help!";
213                  my @out;                  my @out;
# Line 224  POE::Session->create Line 242  POE::Session->create
242    
243                          foreach my $res (get_from_log( limit => $1 )) {                          foreach my $res (get_from_log( limit => $1 )) {
244                                  print "last: $res\n";                                  print "last: $res\n";
245                                  from_to($res, 'ISO-8859-2', 'UTF-8');                                  from_to($res, $ENCODING, 'UTF-8');
246                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
247                          }                          }
248    
# Line 236  POE::Session->create Line 254  POE::Session->create
254    
255                          foreach my $res (get_from_log( limit => 20, search => "%${what}%" )) {                          foreach my $res (get_from_log( limit => 20, search => "%${what}%" )) {
256                                  print "search [$what]: $res\n";                                  print "search [$what]: $res\n";
257                                  from_to($res, 'ISO-8859-2', 'UTF-8');                                  from_to($res, $ENCODING, 'UTF-8');
258                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                                  $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
259                          }                          }
260    
# Line 246  POE::Session->create Line 264  POE::Session->create
264    
265                  if ($res) {                  if ($res) {
266                          print ">> [$nick] $res\n";                          print ">> [$nick] $res\n";
267                          from_to($res, 'ISO-8859-2', 'UTF-8');                          from_to($res, $ENCODING, 'UTF-8');
268                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );                          $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
269                  }                  }
270    
# Line 359  POE::Session->create Line 377  POE::Session->create
377     },     },
378    );    );
379    
380    # http server
381    
382    my $httpd = POE::Component::Server::HTTP->new(
383            Port => $NICK =~ m/-dev/ ? 8001 : 8000,
384            ContentHandler => { '/' => \&root_handler },
385            Headers        => { Server => 'irc-logger' },
386    );
387    
388    my $style = <<'_END_OF_STYLE_';
389    .time, .channel { color: #808080; font-size: 60%; }
390    .nick { color: #0000ff; font-size: 80%; }
391    .message { color: #000000; font-size: 100%; }
392    _END_OF_STYLE_
393    
394    sub root_handler {
395            my ($request, $response) = @_;
396            $response->code(RC_OK);
397            $response->content_type("text/html; charset=$ENCODING");
398            $response->content(
399                    qq{<html><head><title>$NICK</title><style type="text/css">$style</style></head><body>} .
400                    "irc-logger url: " . $request->uri . '<br/>' .
401                    join("<br/>",
402                            get_from_log(
403                                    limit => 100,
404                                    fmt => {
405                                            time => '<span class="time">%s</span> ',
406                                            time_channel => '<span class="channel">%s %s</span> ',
407                                            nick => '<span class="nick">%s:</span> ',
408                                            message => '<span class="message">%s</span>',
409                                    },
410                            )
411                    ) .
412                    qq{</body></html>}
413            );
414            return RC_OK;
415    }
416    
417  POE::Kernel->run;  POE::Kernel->run;
Legend:
Removed from v.12  
changed lines
  Added in v.14
  ViewVC Help
Powered by ViewVC 1.1.26