From 06e10a535932280413817a3a1b600941b2057398 Mon Sep 17 00:00:00 2001 From: "Robin H. Johnson" Date: Sat, 24 Oct 2009 07:20:44 +0200 Subject: [PATCH] Initial version --- plugins/other/irc2 | 286 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 286 insertions(+) create mode 100755 plugins/other/irc2 diff --git a/plugins/other/irc2 b/plugins/other/irc2 new file mode 100755 index 00000000..7c90f54a --- /dev/null +++ b/plugins/other/irc2 @@ -0,0 +1,286 @@ +#!/usr/bin/perl +# -*- perl -*- + +=head1 NAME + +ircstats - Plugin to graph data about an IRC network and a single IRC server + +=head1 CONFIGURATION + +- ENV{SERVER} to point to the server to connect to, defaults to localhost. +- ENV{NICK} nickname to use, defaults to munin-$HASH. + +=head1 USAGE + +This plugin connects to an IRC server. + +=head1 AUTHOR + +Robin H. Johnson + +=head1 LICENSE + +3-clause BSD. + +=head1 MAGIC MARKERS + + #%# family=manual + +=cut +use strict; +use warnings; +use POE qw(Component::IRC); +use Digest::MD5 qw(md5_hex); + +my $nickname = $ENV{NICK} || 'munin-'.md5_hex(rand().time()); +my $ircname = "Munin statistics gathering from $ENV{FQDN}"; +my $server = $ENV{SERVER} || 'localhost'; + +if($ARGV[0] and $ARGV[0] eq "config") { + print "host_name $server\n"; + print "graph_title ircd status - $server\n"; + print "graph_order clients channels servers localclients clientmax localclientmax localservers opers unknownconns\n"; + print "graph_args -l 0\n"; + print "clients.label clients\n"; + print "clients.draw LINE2\n"; + print "channels.label channels\n"; + print "channels.draw LINE2\n"; + print "servers.label servers\n"; + print "servers.draw LINE2\n"; + print "localclients.label localclients\n"; + print "localclients.draw LINE2\n"; + print "clientmax.label clientmax\n"; + print "clientmax.draw LINE2\n"; + print "localclientmax.label localclientmax\n"; + print "localclientmax.draw LINE2\n"; + print "opers.label opers\n"; + print "opers.draw LINE2\n"; + print "localservers.label localservers\n"; + print "localservers.draw LINE2\n"; + print "unknownconns.label unknownconns\n"; + print "unknownconns.draw LINE2\n"; + exit 0; +} + +my %result; + +# We create a new PoCo-IRC object +my $irc = POE::Component::IRC->spawn( + nick => $nickname, + ircname => $ircname, + server => $server, + raw => 0, + useipv6 => 0, +) or die "Oh noooo! $!"; + +POE::Session->create( + package_states => [ + main => [ qw(_start irc_001 irc_251 irc_252 irc_253 irc_254 irc_255 irc_265 irc_266 irc_372 irc_375 irc_376 irc_public irc_disconnected ) ], # _default + ], + heap => { irc => $irc }, +); + +$poe_kernel->run(); + +my $RPL_LUSER_CLIENT = 251; +my $RPL_LUSERCHANNELS = 254; +my $RPL_ENDOFMOTD = 376; + +sub _start { + my ($heap,$kernel,$sender) = @_[HEAP,KERNEL,SENDER]; + + # retrieve our component's object from the heap where we stashed it + my $irc = $heap->{irc}; + + #$irc->yield( register => {("001", "$RPL_LUSER_CLIENT", "$RPL_LUSERCHANNELS", "$RPL_ENDOFMOTD", 'disconnected', 'public', 'all')} ); + $irc->yield( register => qw(001 251 252 253 254 255 265 266 372 375 376 disconnected public all) ); + #$kernel->post( $sender => register => qw(001 251 254 376 disconnected public all)); + #$kernel->post($sender, 'register', qw(001 251 254 376 disconnected public all)); + $irc->yield( connect => { } ); + return; +} + +sub irc_001 { + my $sender = $_[SENDER]; + + # Since this is an irc_* event, we can get the component's object by + # accessing the heap of the sender. Then we register and connect to the + # specified server. + my $irc = $sender->get_heap(); + + #print "Connected to ", $irc->server_name(), "\n"; + + # we join our channels + #$irc->yield( join => $_ ) for @channels; + #sleep 1; + $irc->yield( quit => { }); + return; +} + + +#irc_251: 'moo.us.p2p-network.net' 'There are 155 users and 3397 invisible on 16 servers' [There are 155 users and 3397 invisible on 16 servers] +# luserclient +sub irc_251 { + #print "In 251\n"; + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + my $s = $_[ARG1]; + # Do we have something like an UnrealIRCD? + if($s =~ /There are (\d+) users and (\d+) invisible on (\d+) servers/) { + $result{'clients'} = $1 + $2 - 1; # don't count this script + $result{'servers'} = $3; + } + # Or maybe some freendode hyperion stuff? + elsif($s =~ /There are (\d+) listed and (\d+) unlisted users on (\d+) servers/) { + $result{'clients'} = $1 + $2 - 1; # don't count this script + $result{'servers'} = $3; + } + # Or some recent ircnet ircd? + elsif($s =~ /There are (\d+) users and \d+ services on (\d+) servers/) { + $result{'clients'} = $1 - 1; # don't count this script + $result{'servers'} = $2; + } + # Anything else goes here + elsif($s =~ /There are (\d+) users and (\d+) invisible/) { + $result{'clients'} = $1 + $2 - 1; # don't count this script + } + # And here (if there are no invisible count) + elsif($s =~ /There are (\d+) users/) { + $result{'clients'} = $1 - 1; # don't count this script + } + #printf "251 Got clients=%d servers=%d\n", ($result{'clients'} || -1), ($result{'servers'} || -1); +} + +#irc_252: 'moo.us.p2p-network.net' '18 :operator(s) online' [18, operator(s) online] +# opers +sub irc_252 { + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + my $s = $_[ARG1]; + #print "In 252: $s\n"; + if($s =~ /^(\d+)/) { + $result{'opers'} = $1; + } + #printf "254 Got channels %d\n", ($result{'channels'} || -1); +} + +#irc_253: 'moo.us.p2p-network.net' '1 :unknown connection(s)' [1, unknown connection(s)] +sub irc_253 { + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + my $s = $_[ARG1]; + #print "In 253: $s\n"; + if($s =~ /^(\d+)/) { + $result{'unknownconns'} = $1; + } + #printf "254 Got channels %d\n", ($result{'channels'} || -1); +} + +#irc_254: 'moo.us.p2p-network.net' '1325 :channels formed' [1325, channels formed] +# luserchannels +sub irc_254 { + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + my $s = $_[ARG1]; + #print "In 254: $s\n"; + if($s =~ /^(\d+)/) { + $result{'channels'} = $1; + } + #printf "254 Got channels %d\n", ($result{'channels'} || -1); +} + +#irc_255: 'moo.us.p2p-network.net' 'I have 348 clients and 1 servers' [I have 348 clients and 1 servers] +# local clients/servers +sub irc_255 { + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + my $s = $_[ARG1]; + #print "In 255: $s\n"; + if($s =~ /I have (\d+) clients and (\d+) servers/) { + $result{'localclients'} = $1-1; # don't count this script + $result{'localservers'} = $2; + } +} + +#irc_265: 'moo.us.p2p-network.net' 'Current Local Users: 348 Max: 1900' [Current Local Users: 348 Max: 1900] +sub irc_265 { + #print "In 265\n"; + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + my $s = $_[ARG1]; + #print "In 265: $s\n"; + if($s =~ /Current Local Users: (\d+)\s+Max: (\d+)/) { + $result{'localclients'} = $1-1; # don't count this script + $result{'localclientmax'} = $2; + } +} + +#irc_266: 'moo.us.p2p-network.net' 'Current Global Users: 3552 Max: 8742' [Current Global Users: 3552 Max: 8742] +sub irc_266 { + #print "In 266\n"; + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + my $s = $_[ARG1]; + #print "In 266: $s\n"; + if($s =~ /Current Global Users: (\d+)\s+Max: (\d+)/) { + $result{'clients'} = $1-1; # don't count this script + $result{'clientmax'} = $2; + } +} + +# 372 motdline +sub irc_372 { + return; +} +# 375 startofmotd +sub irc_375 { + return; +} +# 376 endofmotd +sub irc_376 { + my $sender = $_[SENDER]; + my $irc = $sender->get_heap(); + $irc->yield( quit => {} ); +} + +sub munin_print { + my $key = shift; + my $val = shift; + print "${key}.value ".($val || 'U')."\n"; +} + +sub irc_disconnected { + for my $var (qw(clients channels servers localclients clientmax localclientmax localservers opers unknownconns)) { + munin_print($var, $result{$var}); + } + exit 0; +} + +sub irc_public { + my ($sender, $who, $where, $what) = @_[SENDER, ARG0 .. ARG2]; + my $nick = ( split /!/, $who )[0]; + my $channel = $where->[0]; + + if ( my ($rot13) = $what =~ /^rot13 (.+)/ ) { + $rot13 =~ tr[a-zA-Z][n-za-mN-ZA-M]; + $irc->yield( privmsg => $channel => "$nick: $rot13" ); + } + return; +} + +# We registered for all events, this will produce some debug info. +sub _default { + my ($event, $args) = @_[ARG0 .. $#_]; + my @output = ( "$event: " ); + + for my $arg (@$args) { + if ( ref $arg eq 'ARRAY' ) { + push( @output, '[' . join(', ', @$arg ) . ']' ); + } + else { + push ( @output, "'$arg'" ); + } + } + print join ' ', @output, "\n"; + return 0; +}