diff --git a/apps/voip/asterisk/ami/lib/ami.pm b/apps/voip/asterisk/ami/lib/ami.pm new file mode 100644 index 000000000..29f21bc58 --- /dev/null +++ b/apps/voip/asterisk/ami/lib/ami.pm @@ -0,0 +1,119 @@ +############################################################################### +# Copyright 2005-2015 MERETHIS +# Centreon is developped by : Julien Mathis and Romain Le Merlus under +# GPL Licence 2.0. +# +# This program is free software; you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free Software +# Foundation ; either version 2 of the License. +# +# This program is distributed in the hope that it will be useful, but WITHOUT ANY +# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. See the GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along with +# this program; if not, see . +# +# Linking this program statically or dynamically with other modules is making a +# combined work based on this program. Thus, the terms and conditions of the GNU +# General Public License cover the whole combination. +# +# As a special exception, the copyright holders of this program give MERETHIS +# permission to link this program with independent modules to produce an timeelapsedutable, +# regardless of the license terms of these independent modules, and to copy and +# distribute the resulting timeelapsedutable under terms of MERETHIS choice, provided that +# MERETHIS also meet, for each linked independent module, the terms and conditions +# of the license of that module. An independent module is a module which is not +# derived from this program. If you modify this program, you may extend this +# exception to your version of the program, but you are not obliged to do so. If you +# do not wish to do so, delete this exception statement from your version. +# +# For more information : contact@centreon.com +# Author : Mathieu Cinquin +# +#################################################################################### + +package apps::voip::asterisk::lib::ami; + +use strict; +use warnings; +use Net::Telnet; +use Data::Dumper; + +my $ami_handle; +my $line; +my @lines; +my @result; + +sub quit { + $ami_handle->print("Action: logoff"); + $ami_handle->print(""); + $ami_handle->close(); +} + +sub connect { + my ($self, %options) = @_; + + my $connection_exit = defined($options{connection_exit}) ? $options{connection_exit} : 'unknown'; + + $ami_handle = new Net::Telnet (Telnetmode => 0, + Timeout => $self->{option_results}->{timeout}, + Errmode => 'return', + ); + + $ami_handle->open(Host => $self->{option_results}->{hostname}, + Port => $self->{option_results}->{port}, + ); + + if ($ami_handle->errmsg) { + $self->{output}->output_add(severity => $connection_exit, + short_msg => 'Unable to connect to AMI: ' . $ami_handle->errmsg); + $self->{output}->display(); + $self->{output}->exit(); + } + + # Check connection message. + $line = $ami_handle->getline; + if ($line !~ /^Asterisk/) { + $self->{output}->output_add(severity => $connection_exit, + short_msg => 'Unable to connect to AMI: ' . $line); + $self->{output}->display(); + $self->{output}->exit(); + } + + # Authentication. + $ami_handle->print("Action: login"); + $ami_handle->print("Username: $self->{option_results}->{username}"); + $ami_handle->print("Secret: $self->{option_results}->{password}"); + $ami_handle->print("Events: off"); + $ami_handle->print(""); + + # Check authentication message (second message). + $line = $ami_handle->getline; + $line = $ami_handle->getline; + if ($line !~ /^Message: Authentication accepted/) { + $self->{output}->output_add(severity => $connection_exit, + short_msg => 'Unable to connect to AMI: ' . $line); + $self->{output}->display(); + $self->{output}->exit(); + } + +} + +sub action { + my ($self) = @_; + + $ami_handle->print("Action: command"); + $ami_handle->print("Command: $self->{command}"); + $ami_handle->print(""); + + + my @return; + while (my $line = $ami_handle->getline(Timeout => 1)) { + push(@return,$line); + next if ($line !~ /END COMMAND/o); + } + return @return; +} + +1; diff --git a/apps/voip/asterisk/ami/mode/iax/showpeers.pm b/apps/voip/asterisk/ami/mode/iax/showpeers.pm new file mode 100644 index 000000000..5ea0fe5d5 --- /dev/null +++ b/apps/voip/asterisk/ami/mode/iax/showpeers.pm @@ -0,0 +1,169 @@ +################################################################################ +# Copyright 2005-2015 MERETHIS +# Centreon is developped by : Julien Mathis and Romain Le Merlus under +# GPL Licence 2.0. +# +# This program is free software; you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free Software +# Foundation ; either version 2 of the License. +# +# This program is distributed in the hope that it will be useful, but WITHOUT ANY +# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. See the GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along with +# this program; if not, see . +# +# Linking this program statically or dynamically with other modules is making a +# combined work based on this program. Thus, the terms and conditions of the GNU +# General Public License cover the whole combination. +# +# As a special exception, the copyright holders of this program give MERETHIS +# permission to link this program with independent modules to produce an executable, +# regardless of the license terms of these independent modules, and to copy and +# distribute the resulting executable under terms of MERETHIS choice, provided that +# MERETHIS also meet, for each linked independent module, the terms and conditions +# of the license of that module. An independent module is a module which is not +# derived from this program. If you modify this program, you may extend this +# exception to your version of the program, but you are not obliged to do so. If you +# do not wish to do so, delete this exception statement from your version. +# +# For more information : contact@centreon.com +# Authors : Mathieu Cinquin +# +#################################################################################### + +package apps::voip::asterisk::ami::mode::iax::showpeers; + +use base qw(centreon::plugins::mode); + +use strict; +use warnings; +use centreon::plugins::misc; +use apps::voip::asterisk::ami::lib::ami; + +use Data::Dumper; + +sub new { + my ($class, %options) = @_; + my $self = $class->SUPER::new(package => __PACKAGE__, %options); + bless $self, $class; + + $self->{version} = '1.0'; + $options{options}->add_options(arguments => + { + "hostname:s" => { name => 'hostname' }, + "port:s" => { name => 'port', default => 5038 }, + "username:s" => { name => 'username' }, + "password:s" => { name => 'password' }, + "filter-name:s" => { name => 'filter_name', }, + "timeout:s" => { name => 'timeout', default => 20 }, + }); + return $self; +} + +sub check_options { + my ($self, %options) = @_; + $self->SUPER::init(%options); + + if (!defined($self->{option_results}->{hostname})) { + $self->{output}->add_option_msg(short_msg => "Please set the --hostname option"); + $self->{output}->option_exit(); + } + + if (!defined($self->{option_results}->{username})) { + $self->{output}->add_option_msg(short_msg => "Please set the --username option"); + $self->{output}->option_exit(); + } + + if (!defined($self->{option_results}->{password})) { + $self->{output}->add_option_msg(short_msg => "Please set the --password option"); + $self->{output}->option_exit(); + } + +} + + +sub run { + my ($self, %options) = @_; + + # Get data from asterisk + apps::voip::asterisk::lib::ami::connect($self); + $self->{command} = 'iax2 show peers'; + my @result = apps::voip::asterisk::lib::ami::action($self); + apps::voip::asterisk::lib::ami::quit(); + + # Compute data + foreach my $line (@result) { + next if ($line !~ /^(\w*)\/\w* .* (OK|Unreachable) \((.*)\)/); + my ($trunkname, $trunkstatus, $trunkvalue) = ($1, $2, $3); + + if (defined($self->{option_results}->{filter_name}) && $self->{option_results}->{filter_name} ne '' && + $trunkname !~ /$self->{option_results}->{filter_name}/) { + $self->{output}->output_add(long_msg => "Skipping trunk '" . $trunkname . "': no matching filter name"); + next; + } + + $self->{result}->{$trunkname} = {name => $trunkname, status => $trunkstatus, value => $trunkvalue}; + } + + # Send formated data to Centreon + my $msg; + $self->{output}->output_add(severity => 'OK', + short_msg => 'Everything is OK'); + + foreach my $name (sort(keys %{$self->{result}})) { + $msg = sprintf("Trunk: %s %s", $self->{result}->{$name}->{name}, $self->{result}->{$name}->{status}); + $self->{output}->perfdata_add(label => $self->{result}->{$name}->{name}, + value => $self->{result}->{$name}->{value}, + # keep this lines for future upgrade of this plugin + #warning => $self->{perfdata}->get_perfdata_for_output(label => 'warn1'), + #critical => $self->{perfdata}->get_perfdata_for_output(label => 'crit1'), + min => 0); + if (!$self->{output}->is_status(value => $self->{result}->{$name}->{status}, compare => 'ok', litteral => 1)) { + $self->{output}->output_add(severity => $self->{result}->{$name}->{status}, + short_msg => $msg); + } + } + + $self->{output}->display(); + $self->{output}->exit(); +} + +1; + +__END__ + +=head1 MODE + +List partitions. + +=over 8 + +=item B<--hostname> + +Hostname to query. + +=item B<--port> + +port to connect. + +=item B<--username> + +username for conection. + +=item B<--password> + +password for conection. + +=item B<--filter-name> + +Filter on trunkname (regexp can be used). + +=item B<--timeout> + +connection timeout. + +=back + +=cut diff --git a/apps/voip/asterisk/ami/mode/sip/.asterisk_sipshowpeer.pm.swo b/apps/voip/asterisk/ami/mode/sip/.asterisk_sipshowpeer.pm.swo new file mode 100644 index 000000000..45abee12a Binary files /dev/null and b/apps/voip/asterisk/ami/mode/sip/.asterisk_sipshowpeer.pm.swo differ diff --git a/apps/voip/asterisk/ami/mode/sip/.asterisk_sipshowpeer.pm.swp b/apps/voip/asterisk/ami/mode/sip/.asterisk_sipshowpeer.pm.swp new file mode 100644 index 000000000..5296ed9aa Binary files /dev/null and b/apps/voip/asterisk/ami/mode/sip/.asterisk_sipshowpeer.pm.swp differ diff --git a/apps/voip/asterisk/ami/mode/sip/.showpeers.pm.swp b/apps/voip/asterisk/ami/mode/sip/.showpeers.pm.swp new file mode 100644 index 000000000..6c94a68f6 Binary files /dev/null and b/apps/voip/asterisk/ami/mode/sip/.showpeers.pm.swp differ diff --git a/apps/voip/asterisk/ami/mode/sip/showpeers.pm b/apps/voip/asterisk/ami/mode/sip/showpeers.pm new file mode 100644 index 000000000..1185517c2 --- /dev/null +++ b/apps/voip/asterisk/ami/mode/sip/showpeers.pm @@ -0,0 +1,169 @@ +################################################################################ +# Copyright 2005-2015 MERETHIS +# Centreon is developped by : Julien Mathis and Romain Le Merlus under +# GPL Licence 2.0. +# +# This program is free software; you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free Software +# Foundation ; either version 2 of the License. +# +# This program is distributed in the hope that it will be useful, but WITHOUT ANY +# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. See the GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along with +# this program; if not, see . +# +# Linking this program statically or dynamically with other modules is making a +# combined work based on this program. Thus, the terms and conditions of the GNU +# General Public License cover the whole combination. +# +# As a special exception, the copyright holders of this program give MERETHIS +# permission to link this program with independent modules to produce an executable, +# regardless of the license terms of these independent modules, and to copy and +# distribute the resulting executable under terms of MERETHIS choice, provided that +# MERETHIS also meet, for each linked independent module, the terms and conditions +# of the license of that module. An independent module is a module which is not +# derived from this program. If you modify this program, you may extend this +# exception to your version of the program, but you are not obliged to do so. If you +# do not wish to do so, delete this exception statement from your version. +# +# For more information : contact@centreon.com +# Authors : Mathieu Cinquin +# +#################################################################################### + +package apps::voip::asterisk::ami::mode::sip::showpeers; + +use base qw(centreon::plugins::mode); + +use strict; +use warnings; +use centreon::plugins::misc; +use apps::voip::asterisk::ami::lib::ami; + +use Data::Dumper; + +sub new { + my ($class, %options) = @_; + my $self = $class->SUPER::new(package => __PACKAGE__, %options); + bless $self, $class; + + $self->{version} = '1.0'; + $options{options}->add_options(arguments => + { + "hostname:s" => { name => 'hostname' }, + "port:s" => { name => 'port', default => 5038 }, + "username:s" => { name => 'username' }, + "password:s" => { name => 'password' }, + "filter-name:s" => { name => 'filter_name', }, + "timeout:s" => { name => 'timeout', default => 20 }, + }); + return $self; +} + +sub check_options { + my ($self, %options) = @_; + $self->SUPER::init(%options); + + if (!defined($self->{option_results}->{hostname})) { + $self->{output}->add_option_msg(short_msg => "Please set the --hostname option"); + $self->{output}->option_exit(); + } + + if (!defined($self->{option_results}->{username})) { + $self->{output}->add_option_msg(short_msg => "Please set the --username option"); + $self->{output}->option_exit(); + } + + if (!defined($self->{option_results}->{password})) { + $self->{output}->add_option_msg(short_msg => "Please set the --password option"); + $self->{output}->option_exit(); + } + +} + + +sub run { + my ($self, %options) = @_; + + # Get data from asterisk + apps::voip::asterisk::lib::ami::connect($self); + $self->{command} = 'sip show peers'; + my @result = apps::voip::asterisk::lib::ami::action($self); + apps::voip::asterisk::lib::ami::quit(); + + # Compute data + foreach my $line (@result) { + next if ($line !~ /^(\w*)\/\w* .* (OK|Unreachable) \((.*)\)/); + my ($trunkname, $trunkstatus, $trunkvalue) = ($1, $2, $3); + + if (defined($self->{option_results}->{filter_name}) && $self->{option_results}->{filter_name} ne '' && + $trunkname !~ /$self->{option_results}->{filter_name}/) { + $self->{output}->output_add(long_msg => "Skipping trunk '" . $trunkname . "': no matching filter name"); + next; + } + + $self->{result}->{$trunkname} = {name => $trunkname, status => $trunkstatus, value => $trunkvalue}; + } + + # Send formated data to Centreon + my $msg; + $self->{output}->output_add(severity => 'OK', + short_msg => 'Everything is OK'); + + foreach my $name (sort(keys %{$self->{result}})) { + $msg = sprintf("Trunk: %s %s", $self->{result}->{$name}->{name}, $self->{result}->{$name}->{status}); + $self->{output}->perfdata_add(label => $self->{result}->{$name}->{name}, + value => $self->{result}->{$name}->{value}, + # keep this lines for future upgrade of this plugin + #warning => $self->{perfdata}->get_perfdata_for_output(label => 'warn1'), + #critical => $self->{perfdata}->get_perfdata_for_output(label => 'crit1'), + min => 0); + if (!$self->{output}->is_status(value => $self->{result}->{$name}->{status}, compare => 'ok', litteral => 1)) { + $self->{output}->output_add(severity => $self->{result}->{$name}->{status}, + short_msg => $msg); + } + } + + $self->{output}->display(); + $self->{output}->exit(); +} + +1; + +__END__ + +=head1 MODE + +List partitions. + +=over 8 + +=item B<--hostname> + +Hostname to query. + +=item B<--port> + +port to connect. + +=item B<--username> + +username for conection. + +=item B<--password> + +password for conection. + +=item B<--filter-name> + +Filter on trunkname (regexp can be used). + +=item B<--timeout> + +connection timeout. + +=back + +=cut diff --git a/apps/voip/asterisk/ami/plugin.pm b/apps/voip/asterisk/ami/plugin.pm new file mode 100644 index 000000000..ae8c113ca --- /dev/null +++ b/apps/voip/asterisk/ami/plugin.pm @@ -0,0 +1,68 @@ +################################################################################ +# Copyright 2005-2014 MERETHIS +# Centreon is developped by : Julien Mathis and Romain Le Merlus under +# GPL Licence 2.0. +# +# This program is free software; you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free Software +# Foundation ; either version 2 of the License. +# +# This program is distributed in the hope that it will be useful, but WITHOUT ANY +# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. See the GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along with +# this program; if not, see . +# +# Linking this program statically or dynamically with other modules is making a +# combined work based on this program. Thus, the terms and conditions of the GNU +# General Public License cover the whole combination. +# +# As a special exception, the copyright holders of this program give MERETHIS +# permission to link this program with independent modules to produce an executable, +# regardless of the license terms of these independent modules, and to copy and +# distribute the resulting executable under terms of MERETHIS choice, provided that +# MERETHIS also meet, for each linked independent module, the terms and conditions +# of the license of that module. An independent module is a module which is not +# derived from this program. If you modify this program, you may extend this +# exception to your version of the program, but you are not obliged to do so. If you +# do not wish to do so, delete this exception statement from your version. +# +# For more information : contact@centreon.com +# Authors : Mathieu Cinquin +# +#################################################################################### + +package apps::voip::asterisk::ami::plugin; + +use strict; +use warnings; +use base qw(centreon::plugins::script_simple); +#use base qw(centreon::plugins::script_snmp); + +sub new { + my ($class, %options) = @_; + + my $self = $class->SUPER::new(package => __PACKAGE__, %options); + bless $self, $class; + # $options->{options} = options object + + $self->{version} = '0.1'; + %{$self->{modes}} = ( + 'sipshowpeers' => 'apps::voip::asterisk::ami::mode::sip::showpeers', + 'iaxshowpeers' => 'apps::voip::asterisk::ami::mode::iax::showpeers', + ); + + return $self; +} + + +1; + +__END__ + +=head1 PLUGIN DESCRIPTION + +Check BlueMind through InfluxDB API + +=cut diff --git a/apps/voip/asterisk/snmp/mode/activecalls.pm b/apps/voip/asterisk/snmp/mode/activecalls.pm new file mode 100644 index 000000000..1dc4b7dc2 --- /dev/null +++ b/apps/voip/asterisk/snmp/mode/activecalls.pm @@ -0,0 +1,135 @@ +################################################################################ +# Copyright 2005-2014 MERETHIS +# Centreon is developped by : Julien Mathis and Romain Le Merlus under +# GPL Licence 2.0. +# +# This program is free software; you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free Software +# Foundation ; either version 2 of the License. +# +# This program is distributed in the hope that it will be useful, but WITHOUT ANY +# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. See the GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along with +# this program; if not, see . +# +# Linking this program statically or dynamically with other modules is making a +# combined work based on this program. Thus, the terms and conditions of the GNU +# General Public License cover the whole combination. +# +# As a special exception, the copyright holders of this program give MERETHIS +# permission to link this program with independent modules to produce an executable, +# regardless of the license terms of these independent modules, and to copy and +# distribute the resulting executable under terms of MERETHIS choice, provided that +# MERETHIS also meet, for each linked independent module, the terms and conditions +# of the license of that module. An independent module is a module which is not +# derived from this program. If you modify this program, you may extend this +# exception to your version of the program, but you are not obliged to do so. If you +# do not wish to do so, delete this exception statement from your version. +# +# For more information : contact@centreon.com +# Authors : Quentin Garnier +# +#################################################################################### + +package apps::voip::asterisk::snmp::mode::activecalls; + +use base qw(centreon::plugins::mode); + +use strict; +use warnings; +use centreon::plugins::statefile; + +my $oid_astBase = '.1.3.6.1.4.1.22736'; +my $oid_astConfigCallsActive = $oid_astBase.'.1.2.5.0'; +#my $oid_AsteriskConfigCallsProcessed = $oid_AsteriskBase.'.1.2.6.0'; + +sub new { + my ($class, %options) = @_; + my $self = $class->SUPER::new(package => __PACKAGE__, %options); + bless $self, $class; + + $self->{version} = '1.0'; + $options{options}->add_options(arguments => + { + "warning:s" => { name => 'warning', }, + "critical:s" => { name => 'critical', }, + "force-oid:s" => { name => 'force_oid', }, + }); + $self->{statefile_value} = centreon::plugins::statefile->new(%options); + return $self; +} + +sub check_options { + my ($self, %options) = @_; + $self->SUPER::init(%options); + + if (($self->{perfdata}->threshold_validate(label => 'warning', value => $self->{option_results}->{warning})) == 0) { + $self->{output}->add_option_msg(short_msg => "Wrong warning threshold '" . $self->{option_results}->{warning} . "'."); + $self->{output}->option_exit(); + } + if (($self->{perfdata}->threshold_validate(label => 'critical', value => $self->{option_results}->{critical})) == 0) { + $self->{output}->add_option_msg(short_msg => "Wrong critical threshold '" . $self->{option_results}->{critical} . "'."); + $self->{output}->option_exit(); + } + + $self->{statefile_value}->check_options(%options); +} + +sub run { + my ($self, %options) = @_; + # $options{snmp} = snmp object + $self->{snmp} = $options{snmp}; + + my ($result, $value); + + if (defined($self->{option_results}->{force_oid})) { + $result = $self->{snmp}->get_leef(oids => [ $self->{option_results}->{force_oid} ], nothing_quit => 1); + $value = $result->{$self->{option_results}->{force_oid}}; + } else { + $result = $self->{snmp}->get_leef(oids => [ $oid_astConfigCallsActive ], nothing_quit => 1); + $value = $result->{$oid_astConfigCallsActive}; + } + + my $exit_code = $self->{perfdata}->threshold_check(value => $value, + threshold => [ { label => 'critical', 'exit_litteral' => 'critical' }, { label => 'warning', exit_litteral => 'warning' } ]); + $self->{output}->perfdata_add(label => 'Calls', + value => $value, + warning => $self->{perfdata}->get_perfdata_for_output(label => 'warning'), + critical => $self->{perfdata}->get_perfdata_for_output(label => 'critical'), + min => 0); + + $self->{output}->output_add(severity => $exit_code, + short_msg => sprintf("Current active calls: %s", $value) + ); + + $self->{output}->display(); + $self->{output}->exit(); +} + +1; + +__END__ + +=head1 MODE + +Check number of active calls. + +=over 8 + +=item B<--warning> + +Threshold warning. + +=item B<--critical> + +Threshold critical. + +=item B<--force-oid> + +Can choose your oid (numeric format only). + +=back + +=cut \ No newline at end of file diff --git a/apps/voip/asterisk/snmp/mode/externalcalls.pm b/apps/voip/asterisk/snmp/mode/externalcalls.pm new file mode 100644 index 000000000..a07356400 --- /dev/null +++ b/apps/voip/asterisk/snmp/mode/externalcalls.pm @@ -0,0 +1,239 @@ +################################################################################ +# Copyright 2005-2014 MERETHIS +# Centreon is developped by : Julien Mathis and Romain Le Merlus under +# GPL Licence 2.0. +# +# This program is free software; you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free Software +# Foundation ; either version 2 of the License. +# +# This program is distributed in the hope that it will be useful, but WITHOUT ANY +# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. See the GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along with +# this program; if not, see . +# +# Linking this program statically or dynamically with other modules is making a +# combined work based on this program. Thus, the terms and conditions of the GNU +# General Public License cover the whole combination. +# +# As a special exception, the copyright holders of this program give MERETHIS +# permission to link this program with independent modules to produce an executable, +# regardless of the license terms of these independent modules, and to copy and +# distribute the resulting executable under terms of MERETHIS choice, provided that +# MERETHIS also meet, for each linked independent module, the terms and conditions +# of the license of that module. An independent module is a module which is not +# derived from this program. If you modify this program, you may extend this +# exception to your version of the program, but you are not obliged to do so. If you +# do not wish to do so, delete this exception statement from your version. +# +# For more information : contact@centreon.com +# Authors : Quentin Garnier +# +#################################################################################### + +package apps::voip::asterisk::snmp::mode::externalcalls; + +use base qw(centreon::plugins::mode); + +use strict; +use warnings; +use centreon::plugins::statefile; + +my $oid_astBase = '.1.3.6.1.4.1.22736'; +my $oid_astConfigCallsActive = $oid_astBase.'.1.2.5.0'; +my $oid_astChanName = $oid_astBase.'.1.5.2.1.2'; # need an index at the end +my $oid_astChanIndex = $oid_astBase.'.1.5.2.1.1'; # need an index at the end +my $oid_astNumChannels = $oid_astBase.'.1.5.1.0'; + +sub new { + my ($class, %options) = @_; + my $self = $class->SUPER::new(package => __PACKAGE__, %options); + bless $self, $class; + + $self->{version} = '1.0'; + $options{options}->add_options(arguments => + { + "warning:s" => { name => 'warning', }, + "critical:s" => { name => 'critical', }, + "warnontrunk:s" => { name => 'warnontrunk', }, + "critontrunk:s" => { name => 'critontrunk', }, + "force-oid:s" => { name => 'force_oid', }, + "trunkusernamelist:s" => { name => 'trunkusernamelist', }, + "filter-name" => { name => 'filter-name' }, + }); + $self->{statefile_value} = centreon::plugins::statefile->new(%options); + return $self; +} + +sub check_options { + my ($self, %options) = @_; + $self->SUPER::init(%options); + + if (($self->{perfdata}->threshold_validate(label => 'warning', value => $self->{option_results}->{warning})) == 0) { + $self->{output}->add_option_msg(short_msg => "Wrong warning threshold '" . $self->{option_results}->{warning} . "'."); + $self->{output}->option_exit(); + } + if (($self->{perfdata}->threshold_validate(label => 'critical', value => $self->{option_results}->{critical})) == 0) { + $self->{output}->add_option_msg(short_msg => "Wrong critical threshold '" . $self->{option_results}->{critical} . "'."); + $self->{output}->option_exit(); + } + if (($self->{perfdata}->threshold_validate(label => 'warnontrunk', value => $self->{option_results}->{warnontrunk})) == 0) { + $self->{output}->add_option_msg(short_msg => "Wrong warning threshold '" . $self->{option_results}->{warnontrunk} . "'."); + $self->{output}->option_exit(); + } + if (($self->{perfdata}->threshold_validate(label => 'critontrunk', value => $self->{option_results}->{critontrunk})) == 0) { + $self->{output}->add_option_msg(short_msg => "Wrong critical threshold '" . $self->{option_results}->{critontrunk} . "'."); + $self->{output}->option_exit(); + } + + $self->{statefile_value}->check_options(%options); +} + +sub run { + my ($self, %options) = @_; + # $options{snmp} = snmp object + $self->{snmp} = $options{snmp}; + + my ($result, $value); + my (@callsbytrunk, @error_msg, @msg); + + # explode trunk list + my @trunkusernamelist = split(';',$self->{option_results}->{trunkusernamelist}); + foreach my $trunk (@trunkusernamelist) + { + if (defined($self->{option_results}->{filter_name}) && $self->{option_results}->{filter_name} ne '' && + $trunk !~ /$self->{option_results}->{filter_name}/) { + $self->{output}->output_add(long_msg => "Skipping trunk '" . $trunk . "': no matching filter name"); + next; + } + push @callsbytrunk , { trunk => $trunk, num => 0}; + } + # get chanName and sum calls for each + $result = $self->{snmp}->get_leef(oids => [ $oid_astNumChannels ], nothing_quit => 1); + my $astNumChannels = $result->{$oid_astNumChannels}; + my $astConfigCallsActive = 0; + foreach my $i (1..$astNumChannels) { + $result = $self->{snmp}->get_leef(oids => [ $oid_astChanName.'.'.$i ], nothing_quit => 1); + $value = $result->{$oid_astChanName.'.'.$i}; + $value =~ /^(.*)\/(.*)-.*/; + my ($protocol, $trunkname) = ($1, $2); + foreach my $val (@callsbytrunk) + { + if ( $val->{trunk} eq $trunkname ) + { + $val->{num} = $val->{num}+1; + $astConfigCallsActive = $astConfigCallsActive+1; + } + } + } + + #$result = $self->{snmp}->get_leef(oids => [ $oid_astConfigCallsActive ], nothing_quit => 1); + #my $astConfigCallsActive = $result->{$oid_astConfigCallsActive}; + + # compute status based on total number of active calls + my $exit_code = $self->{perfdata}->threshold_check(value => $astConfigCallsActive, + threshold => [ { label => 'critical', exit_litteral => 'critical' }, { label => 'warning', exit_litteral => 'warning' } ]); + push @msg, {msg => sprintf("Current external calls: %s", $astConfigCallsActive)}; + + # Perfdata on all active calls + $self->{output}->perfdata_add(label => 'Total calls', + value => $astConfigCallsActive, + warning => $self->{perfdata}->get_perfdata_for_output(label => 'warning'), + critical => $self->{perfdata}->get_perfdata_for_output(label => 'critical'), + min => 0); + + # Perfdata on number of calls for each trunk + my ($temp_exit, $exit_msg); + my (@trunk_msg, @out_msg); + my $trunk_exit_code = 'ok'; + foreach $value (@callsbytrunk) + { + $temp_exit = $self->{perfdata}->threshold_check(value => $value->{num}, + threshold => [ { label => 'critontrunk', exit_litteral => 'critical' }, { label => 'warnontrunk', exit_litteral => 'warning' } ]); + $self->{output}->perfdata_add(label => $value->{trunk}, + value => $value->{num}, + warning => $self->{perfdata}->get_perfdata_for_output(label => 'warnontrunk'), + critical => $self->{perfdata}->get_perfdata_for_output(label => 'critontrunk'), + min => 0); + $self->{output}->output_add(long_msg => sprintf("%s : %s", $value->{trunk}, $value->{num})); + + $trunk_exit_code = $self->{output}->get_most_critical(status => [ $temp_exit, $trunk_exit_code ]); + # create msg for most critical data .... + if ($self->{output}->is_status(value => $temp_exit, compare => $trunk_exit_code, litteral => 1)) + { + push @trunk_msg, {msg => sprintf("'%s': %s", $value->{trunk}, $value->{num})}; + } + } + if (!$self->{output}->is_status(value => $exit_code, compare => 'ok', litteral => 1) && !$self->{output}->is_status(value => $trunk_exit_code, compare => 'ok', litteral => 1)) + { + unshift @trunk_msg, @msg; + $exit_code = $self->{output}->get_most_critical(status => [ $exit_code, $trunk_exit_code ]); + } + if (!$self->{output}->is_status(value => $trunk_exit_code, compare => 'ok', litteral => 1)) + { + @out_msg=@trunk_msg; + $exit_code = $trunk_exit_code ; + } + else + { + push @out_msg, @msg; + } + + $exit_msg = ''; + my $separator = ''; + foreach my $out (@out_msg) + { + $exit_msg .= $separator.$out->{msg}; + $separator = ', '; + } + $self->{output}->output_add(severity => $exit_code, + short_msg => $exit_msg + ); + + $self->{output}->display(); + $self->{output}->exit(); +} + +1; + +__END__ + +=head1 MODE + +Check number of external calls (total and by trunk) + +=over 8 + +=item B<--warning> + +Threshold warning for total number of external calls. + +=item B<--critical> + +Threshold critical for total number of external calls. + +=item B<--warnontrunk> + +Threshold warning for trunks. + +=item B<--critontrunk> + +Threshold critical for trunks. + +=item B<--force-oid> + +Can choose your oid (numeric format only). + +=item B<--trunkusernamelist> + +List of outgoing trunks' username. + +=item B<--filter-name> + +Filter on trunk's username (regexp can be used). + +=back + +=cut \ No newline at end of file diff --git a/apps/voip/asterisk/snmp/plugin.pm b/apps/voip/asterisk/snmp/plugin.pm new file mode 100644 index 000000000..f23803904 --- /dev/null +++ b/apps/voip/asterisk/snmp/plugin.pm @@ -0,0 +1,67 @@ +################################################################################ +# Copyright 2005-2014 MERETHIS +# Centreon is developped by : Julien Mathis and Romain Le Merlus under +# GPL Licence 2.0. +# +# This program is free software; you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free Software +# Foundation ; either version 2 of the License. +# +# This program is distributed in the hope that it will be useful, but WITHOUT ANY +# WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. See the GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along with +# this program; if not, see . +# +# Linking this program statically or dynamically with other modules is making a +# combined work based on this program. Thus, the terms and conditions of the GNU +# General Public License cover the whole combination. +# +# As a special exception, the copyright holders of this program give MERETHIS +# permission to link this program with independent modules to produce an executable, +# regardless of the license terms of these independent modules, and to copy and +# distribute the resulting executable under terms of MERETHIS choice, provided that +# MERETHIS also meet, for each linked independent module, the terms and conditions +# of the license of that module. An independent module is a module which is not +# derived from this program. If you modify this program, you may extend this +# exception to your version of the program, but you are not obliged to do so. If you +# do not wish to do so, delete this exception statement from your version. +# +# For more information : contact@centreon.com +# Authors : Mathieu Cinquin +# +#################################################################################### + +package apps::voip::asterisk::snmp::plugin; + +use strict; +use warnings; +use base qw(centreon::plugins::script_snmp); + +sub new { + my ($class, %options) = @_; + + my $self = $class->SUPER::new(package => __PACKAGE__, %options); + bless $self, $class; + # $options->{options} = options object + + $self->{version} = '0.1'; + %{$self->{modes}} = ( + 'activecalls' => 'apps::voip::asterisk::snmp::mode::activecalls', + 'externalcalls' => 'apps::voip::asterisk::snmp::mode::externalcalls', + ); + + return $self; +} + + +1; + +__END__ + +=head1 PLUGIN DESCRIPTION + +Check BlueMind through InfluxDB API + +=cut