mirror of
https://github.com/munin-monitoring/contrib.git
synced 2018-11-08 00:59:34 +01:00
Initial version
This commit is contained in:
Robin H. Johnson
Steve Schnepp
parent
47ca7b643a
commit
06e10a5359
286
plugins/other/irc2
Executable file
286
plugins/other/irc2
Executable file
@ -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;
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user