/[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 5 by dpavlin, Mon Feb 27 12:10:07 2006 UTC revision 10 by dpavlin, Thu Mar 2 00:19:12 2006 UTC
# Line 22  my $NICK = 'irc-logger'; Line 22  my $NICK = 'irc-logger';
22  my $CONNECT =  my $CONNECT =
23    {Server => 'irc.freenode.net',    {Server => 'irc.freenode.net',
24     Nick => $NICK,     Nick => $NICK,
25     Ircname => 'logger: ask dpavlin@rot13.org'     Ircname => "try /msg $NICK help",
26    };    };
27  my $CHANNEL = '#razmjenavjestina';  my $CHANNEL = '#razmjenavjestina';
28  my $IRC_ALIAS = "log";  my $IRC_ALIAS = "log";
# Line 41  my $DSN = 'DBI:Pg:dbname=irc-logger'; Line 41  my $DSN = 'DBI:Pg:dbname=irc-logger';
41    
42  use POE qw(Component::IRC Wheel::FollowTail);  use POE qw(Component::IRC Wheel::FollowTail);
43  use DBI;  use DBI;
44    use Encode qw/from_to/;
45    
46    
47  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 80  POE::Component::IRC->new($IRC_ALIAS); Line 81  POE::Component::IRC->new($IRC_ALIAS);
81  POE::Session->create  POE::Session->create
82    (inline_states =>    (inline_states =>
83     {_start => sub {           {_start => sub {      
84        $_[KERNEL]->post($IRC_ALIAS => register => 'all');                  $_[KERNEL]->post($IRC_ALIAS => register => 'all');
85        $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);                  $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);
86      },      },
87      irc_255 => sub {            # server is done blabbing      irc_255 => sub {    # server is done blabbing
88        $_[KERNEL]->post($IRC_ALIAS => join => $CHANNEL);                  $_[KERNEL]->post($IRC_ALIAS => join => $CHANNEL);
89        $_[KERNEL]->post($IRC_ALIAS => join => '#logger');                  $_[KERNEL]->post($IRC_ALIAS => join => '#logger');
90        $_[KERNEL]->yield("heartbeat"); # start heartbeat                  $_[KERNEL]->yield("heartbeat"); # start heartbeat
91  #      $_[KERNEL]->yield("my_add", $_) for keys %FOLLOWS;  #               $_[KERNEL]->yield("my_add", $_) for keys %FOLLOWS;
92      },      },
93      irc_public => sub {      irc_public => sub {
94            my $kernel = $_[KERNEL];                  my $kernel = $_[KERNEL];
95            my $nick = (split /!/, $_[ARG0])[0];                  my $nick = (split /!/, $_[ARG0])[0];
96            my $channel = $_[ARG1]->[0];                  my $channel = $_[ARG1]->[0];
97            my $msg = $_[ARG2];                  my $msg = $_[ARG2];
98    
99            print "$channel: <$nick> $msg\n";                  from_to($msg, 'UTF-8', 'ISO-8859-2');
100            $sth->execute($channel, $nick, $msg);  
101                    print "$channel: <$nick> $msg\n";
102                    $sth->execute($channel, $nick, $msg);
103      },      },
104            irc_msg => sub {
105                    my $kernel = $_[KERNEL];
106                    my $nick = (split /!/, $_[ARG0])[0];
107                    my $msg = $_[ARG2];
108                    from_to($msg, 'UTF-8', 'ISO-8859-2');
109    
110                    my $res = "unknown command '$msg', try /msg $NICK help!";
111    
112                    print "<< $msg\n";
113    
114                    if ($msg =~ m/^help/i) {
115    
116                            $res = "usage: /msg $NICK stat - shows user statistics | /msg $NICK last - show backtrace of conversations";
117    
118                    } elsif ($msg =~ m/^msg\s+(\S+)\s+(.*)$/i) {
119    
120                            print ">> /msg $1 $2\n";
121                            $_[KERNEL]->post( $IRC_ALIAS => privmsg => $1, $2 );
122                            $res = '';
123    
124                    } elsif ($msg =~ m/^stat.*?\s*(\d*)/i) {
125    
126                            my $nr = $1 || 10;
127    
128                            my $sth = $dbh->prepare(qq{
129                                    select nick,count(*) from log group by nick order by count desc limit $nr
130                            });
131                            $sth->execute();
132                            $res = "Top $nr users: ";
133                            my @users;
134                            while (my $row = $sth->fetchrow_hashref) {
135                                    push @users,$row->{nick} . ': ' . $row->{count};
136                            }
137                            $res .= join(" | ", @users);
138                    } elsif ($msg =~ m/^last.*?\s*(\d*)/i) {
139    
140                            my $nr = $1 || 10;
141    
142                            my $sth = $dbh->prepare(qq{
143                                    select
144                                            time::date as date,
145                                            time::time as time,
146                                            channel,
147                                            nick,
148                                            message
149                                    from log order by log.time desc limit $nr
150                            });
151                            $sth->execute();
152                            $res = "Last $nr messages: ";
153                            my $last_row = {
154                                    date => '',
155                                    time => '',
156                                    channel => '',
157                                    nick => '',
158                            };
159    
160                            my @rows;
161    
162                            while (my $row = $sth->fetchrow_hashref) {
163                                    unshift @rows, $row;
164                            }
165    
166                            my @msgs;
167    
168                            foreach my $row (@rows) {
169    
170                                    $row->{time} =~ s#\.\d+##;
171    
172                                    my $t;
173                                    $t = $row->{date} . ' ' if ($last_row->{date} ne $row->{date});
174                                    $t .= $row->{time};
175    
176                                    my $msg = '';
177    
178                                    $msg .= "($t";
179                                    $msg .= ' ' . $row->{channel} if ($last_row->{channel} ne $row->{channel});
180                                    $msg .= ") ";
181    
182                                    $msg .= $row->{nick} . ': '  if ($last_row->{nick} ne $row->{nick});
183    
184                                    $msg .= $row->{message};
185    
186                                    push @msgs, $msg;
187    
188                                    $last_row = $row;
189                            }
190    
191                            foreach my $res (@msgs) {
192                                    print "last: $res\n";
193                                    from_to($res, 'ISO-8859-2', 'UTF-8');
194                                    $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
195                            }
196    
197                            $res = '';
198                    }
199    
200                    if ($res) {
201                            print ">> [$nick] $res\n";
202                            from_to($res, 'ISO-8859-2', 'UTF-8');
203                            $_[KERNEL]->post( $IRC_ALIAS => privmsg => $nick, $res );
204                    }
205    
206            },
207            irc_477 => sub {
208                    print "# irc_477: ",$_[ARG1], "\n";
209                    $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );
210            },
211            irc_505 => sub {
212                    print "# irc_505: ",$_[ARG1], "\n";
213                    $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "register $NICK" );
214    #               $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set hide email on" );
215    #               $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "set email dpavlin\@rot13.org" );
216            },
217            irc_registered => sub {
218                    warn "## indetify $NICK\n";
219                    $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" );
220            },
221            irc_433 => sub {
222                    print "# irc_433: ",$_[ARG1], "\n";
223                    warn "## indetify $NICK\n";
224                    $_[KERNEL]->post( $IRC_ALIAS => privmsg => 'nickserv', "IDENTIFY $NICK" );
225            },
226            irc_372 => sub {
227                    print "MOTD: ", $_[ARG1], "\n";
228            },
229            irc_snotice => sub {
230                    print "(server notice): ", $_[ARG0], "\n";
231            },
232      (map      (map
233       {       {
234         ;"irc_$_" => sub { }}         ;"irc_$_" => sub { }}
235       qw(join       qw(
         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  
236                  )),                  )),
237    #       join
238    #       ctcp_version
239    #       connected snotice ctcp_action ping notice mode part quit
240    #       001 002 003 004 005
241    #       250 251 252 253 254 265 266
242    #       332 333 353 366 372 375 376
243    #       477
244      _child => sub {},      _child => sub {},
245      _default => sub {      _default => sub {
246        printf "%s: session %s caught an unhandled %s event.\n",        printf "%s: session %s caught an unhandled %s event.\n",
Legend:
Removed from v.5  
changed lines
  Added in v.10
  ViewVC Help
Powered by ViewVC 1.1.26