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

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

Parent Directory Parent Directory | Revision Log Revision Log


Revision 4 - (show annotations)
Mon Feb 27 11:54:38 2006 UTC (18 years, 1 month ago) by dpavlin
Original Path: trunk/irc-logger.pl
File MIME type: text/plain
File size: 3847 byte(s)
IRC bot which replace human memory

1 #!/usr/bin/perl -w
2 use strict;
3 $|++;
4
5 ## CONFIG
6
7 my $NICK = 'irc-logger';
8 my $CONNECT =
9 {Server => 'irc.freenode.net',
10 Nick => $NICK,
11 Ircname => 'logger: ask dpavlin@rot13.org'
12 };
13 my $CHANNEL = '#razmjenavjestina';
14 my $IRC_ALIAS = "log";
15
16 my %FOLLOWS =
17 (
18 ACCESS => "/var/log/apache/access.log",
19 ERROR => "/var/log/apache/error.log",
20 );
21
22 ## END CONFIG
23
24 my $SKIPPING = 0; # if skipping, how many we've done
25 my $SEND_QUEUE; # cache
26
27 use POE qw(Component::IRC Wheel::FollowTail);
28
29 POE::Component::IRC->new($IRC_ALIAS);
30
31 POE::Session->create
32 (inline_states =>
33 {_start => sub {
34 $_[KERNEL]->post($IRC_ALIAS => register => 'all');
35 $_[KERNEL]->post($IRC_ALIAS => connect => $CONNECT);
36 },
37 irc_255 => sub { # server is done blabbing
38 $_[KERNEL]->post($IRC_ALIAS => join => $CHANNEL);
39 $_[KERNEL]->post($IRC_ALIAS => join => '#logger');
40 $_[KERNEL]->yield("heartbeat"); # start heartbeat
41 # $_[KERNEL]->yield("my_add", $_) for keys %FOLLOWS;
42 },
43 irc_public => sub {
44 my $kernel = $_[KERNEL];
45 my $nick = (split /!/, $_[ARG0])[0];
46 my $channel = $_[ARG1]->[0];
47 my $msg = $_[ARG2];
48
49 print "$channel: <$nick> $msg\n";
50 },
51 (map
52 {
53 ;"irc_$_" => sub { }}
54 qw(join
55 ctcp_version
56 connected snotice ctcp_action ping notice mode part quit
57 001 002 003 004 005
58 250 251 252 253 254 265 266
59 332 333 353 366 372 375 376)),
60 _child => sub {},
61 _default => sub {
62 printf "%s: session %s caught an unhandled %s event.\n",
63 scalar localtime(), $_[SESSION]->ID, $_[ARG0];
64 print "The $_[ARG0] event was given these parameters: ",
65 join(" ", map({"ARRAY" eq ref $_ ? "[@$_]" : "$_"} @{$_[ARG1]})), "\n";
66 0; # false for signals
67 },
68 my_add => sub {
69 my $trailing = $_[ARG0];
70 my $session = $_[SESSION];
71 POE::Session->create
72 (inline_states =>
73 {_start => sub {
74 $_[HEAP]->{wheel} =
75 POE::Wheel::FollowTail->new
76 (
77 Filename => $FOLLOWS{$trailing},
78 InputEvent => 'got_line',
79 );
80 },
81 got_line => sub {
82 $_[KERNEL]->post($session => my_tailed =>
83 time, $trailing, $_[ARG0]);
84 },
85 },
86 );
87
88 },
89 my_tailed => sub {
90 my ($time, $file, $line) = @_[ARG0..ARG2];
91 ## $time will be undef on a probe, or a time value if a real line
92
93 ## PoCo::IRC has throttling built in, but no external visibility
94 ## so this is reaching "under the hood"
95 $SEND_QUEUE ||=
96 $_[KERNEL]->alias_resolve($IRC_ALIAS)->get_heap->{send_queue};
97
98 ## handle "no need to keep skipping" transition
99 if ($SKIPPING and @$SEND_QUEUE < 1) {
100 $_[KERNEL]->post($IRC_ALIAS => privmsg => $CHANNEL =>
101 "[discarded $SKIPPING messages]");
102 $SKIPPING = 0;
103 }
104
105 ## handle potential message display
106 if ($time) {
107 if ($SKIPPING or @$SEND_QUEUE > 3) { # 3 msgs per 10 seconds
108 $SKIPPING++;
109 } else {
110 my @time = localtime $time;
111 $_[KERNEL]->post($IRC_ALIAS => privmsg => $CHANNEL =>
112 sprintf "%02d:%02d:%02d: %s: %s",
113 ($time[2] + 11) % 12 + 1, $time[1], $time[0],
114 $file, $line);
115 }
116 }
117
118 ## handle re-probe/flush if skipping
119 if ($SKIPPING) {
120 $_[KERNEL]->delay($_[STATE] => 0.5); # $time will be undef
121 }
122
123 },
124 my_heartbeat => sub {
125 $_[KERNEL]->yield(my_tailed => time, "heartbeat", "beep");
126 $_[KERNEL]->delay($_[STATE] => 10);
127 }
128 },
129 );
130
131 POE::Kernel->run;

Properties

Name Value
svn:executable *

  ViewVC Help
Powered by ViewVC 1.1.26