init branch

apps/voip/asterisk/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 <http://www.gnu.org/licenses>.
+#
+# 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 <mcinquin@merethis.com>
+#
+####################################################################################
+
+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;

apps/voip/asterisk/mode/sip/asterisk_sipshowpeer.pm

@@ -0,0 +1,139 @@
+#!/usr/bin/perl -w
+#
+# Copyright (C) 2005 Rodolphe Quiedeville <rodolphe@quiedeville.org>
+#
+# 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; version 2 dated June,
+# 1991.
+#
+# 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, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+# If you improve this script please send your version to my email address
+# with the copyright notice upgrade with your name.
+#
+#
+# $Log$
+# Revision 1.1  2005/10/22 21:04:01  rodo
+# Created by Rodolphe Quiedeville
+#
+# Revision 1.2  2010/11/04 10:11     Guillaume Bour <gbour@proformatique.com>
+#   Allow channels monitoring per device (IAX/SIP/... account or trunk).
+#   To monitor a particular device, link asterisk_sipshowpeer_tech_identifier to this file, where:
+#     - tech is one of SIP, IAX, DAHDI, ...
+#     - identifier is account name (102, foo, ...)
+#
+#   i.e:
+#     ls -s /path/to/asterisk_sipshowpeer /etc/munin/plugins/asterisk_sipshowpeer_trunk1
+#   will monitor SIP/trunk1 device
+#
+#
+# Parameters mandatory:
+#
+# 	username
+# 	secret
+#
+#%# family=asterisk
+#%# capabilities=autoconf
+
+use strict;
+
+my $ret = undef;
+if (! eval "require Net::Telnet;")
+{
+    $ret = "Net::Telnet not found";
+}
+
+my $DEVICE=`basename $0`;
+if ($DEVICE =~ /^asterisk_sipshowpeer_(.*)$/)
+{ $DEVICE = "$1"; }
+elsif (defined($ARGV[0]))
+{ ($DEVICE) = @ARGV; }
+else
+{ $DEVICE = ''; }
+
+my $command = 'sip show peers';
+
+my $host = exists $ENV{'host'} ? $ENV{'host'} : "10.50.1.65";
+my $port = exists $ENV{'port'} ? $ENV{'port'} : "5038";
+
+#[asterisk_*]
+#env.username xivo_munin_user
+#env.secret jeSwupAd0
+
+#my $username = $ENV{'username'};
+my $username = 'xivo_munin_user';
+#my $secret   = $ENV{'secret'};
+my $secret   = 'jeSwupAd0';
+
+my $pop = new Net::Telnet (Telnetmode => 0);
+$pop->open(Host => $host,
+	   Port => $port);
+
+## Read connection message.
+my $line = $pop->getline;
+die $line unless $line =~ /^Asterisk/;
+
+## Send user name.
+$pop->print("Action: login");
+$pop->print("Username: $username");
+$pop->print("Secret: $secret");
+$pop->print("Events: off");
+$pop->print("");
+
+#Response: Success
+#Message: Authentication accepted
+
+## Request status of messages.
+$pop->print("Action: command");
+$pop->print("Command: ".$command);
+$pop->print("");
+my @result = ('Nothing Monitored');
+my $nb = 0;
+while (($line = $pop->getline) and ($line !~ /END COMMAND/o))
+{
+#    print $line;
+    if ($DEVICE eq '')
+    {
+        $result[$nb] = $line if $line !~ /^Name|Unmonitored/;
+    }
+    else
+    {
+        $result[$nb] = $line if $line =~ /^$DEVICE/;
+    }
+    $nb++;
+}
+$pop->print("Action: logoff");
+$pop->print("");
+while (($line = $pop->getline) and ($line !~ /END COMMAND/o))
+{}
+$pop->close();
+
+my $peername;
+my $status;
+my $splitresult;
+
+foreach (@result)
+{
+    if ((defined($_)) && ($_ =~ /^.*\/.* /))
+    {
+        chomp($_);
+        $peername = $status = $_;
+        $peername =~ /^(\w*)\/\w* .* (OK|Unreachable) (\(.*\))/;
+	$splitresult = $1.": ".$2;
+        if (defined($3))
+        {
+            $splitresult = $splitresult." ".$3;
+        }
+        print $splitresult."\n";
+    }
+}
+
+# vim:syntax=perl

apps/voip/asterisk/mode/sip/showpeers.pm

@@ -0,0 +1,230 @@
+################################################################################
+# 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 <http://www.gnu.org/licenses>.
+#
+# 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 <mcinquin@merethis.com>
+#
+####################################################################################
+
+package apps::voip::asterisk::mode::sip::showpeers;
+
+use base qw(centreon::plugins::mode);
+
+use strict;
+use warnings;
+use centreon::plugins::misc;
+use apps::voip::asterisk::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' },
+                                  "trunkname:s"       => { name => 'trunkname' },
+                                  "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) = @_;
+
+    apps::voip::asterisk::lib::ami::connect($self);
+
+    $self->{command} = 'sip show peers';
+    
+    my @result = apps::voip::asterisk::lib::ami::action($self);
+
+    print "@result";
+
+    apps::voip::asterisk::lib::ami::quit();
+
+
+
+}
+
+
+#    trunkname => $self->{option_results}->{trunkname});
+#    my @lines = split /\n/, $stdout;
+#    # Header not needed
+#    #shift @lines;
+#    foreach my $line (@lines) {
+#        next if ($line !~ /^(.*): (.*) \((.*)\)/);
+#        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;
+#        }
+#        #####
+#        # test
+#        #####
+#        if ($trunkname eq '009900524')
+#        {
+#        $self->{result}->{$trunkname} = {name => $trunkname, status => $trunkstatus, value => $trunkvalue};
+#        }
+#        else
+#        {
+#        $self->{result}->{$trunkname} = {name => $trunkname, status => 'Unknown', value => $trunkvalue};
+#        }
+#    }
+#}
+#
+#sub run {
+#    my ($self, %options) = @_;
+#    my $msg;
+#    $self->{output}->output_add(severity => 'OK',
+#                                short_msg => 'Everything is OK');
+#    $self->manage_selection();
+#
+#    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},
+#                                  #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();
+#}
+#
+#sub disco_format {
+#    my ($self, %options) = @_;
+#
+#    $self->{output}->add_disco_format(elements => ['name']);
+#}
+#
+#sub disco_show {
+#    my ($self, %options) = @_;
+#
+#    $self->manage_selection();
+#    foreach my $name (sort(keys %{$self->{result}})) {
+#        $self->{output}->add_disco_entry(name => $name,
+#                                         );
+#    }
+#}
+
+1;
+
+__END__
+
+=head1 MODE
+
+List partitions.
+
+=over 8
+
+=item B<--remote>
+
+Execute command remotely in 'ssh'.
+
+=item B<--hostname>
+
+Hostname to query (need --remote).
+
+=item B<--ssh-option>
+
+Specify multiple options like the user (example: --ssh-option='-l=centreon-engine' --ssh-option='-p=52').
+
+=item B<--ssh-path>
+
+Specify ssh command path (default: none)
+
+=item B<--ssh-command>
+
+Specify ssh command (default: 'ssh'). Useful to use 'plink'.
+
+=item B<--timeout>
+
+Timeout in seconds for the command (Default: 30).
+
+=item B<--sudo>
+
+Use 'sudo' to execute the command.
+
+=item B<--command>
+
+Command to get information (Default: 'cat').
+Can be changed if you have output in a file.
+
+=item B<--command-path>
+
+Command path (Default: none).
+
+=item B<--command-options>
+
+Command options (Default: '/proc/partitions 2>&1').
+
+=item B<--filter-name>
+
+Filter partition name (regexp can be used).
+
+=back
+
+=cut

apps/voip/asterisk/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 <http://www.gnu.org/licenses>.
+#
+# 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 <mcinquin@merethis.com>
+#
+####################################################################################
+
+package apps::voip::asterisk::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}} = (
+                         'showpeers'    => 'apps::voip::asterisk::mode::sip::showpeers',
+			);
+
+    return $self;
+}
+
+
+1;
+
+__END__
+
+=head1 PLUGIN DESCRIPTION
+
+Check BlueMind through InfluxDB API
+
+=cut