diff --git a/centreon/common/cisco/standard/snmp/mode/qosusage.pm b/centreon/common/cisco/standard/snmp/mode/qosusage.pm index 92e8be43d..38f0b7b07 100644 --- a/centreon/common/cisco/standard/snmp/mode/qosusage.pm +++ b/centreon/common/cisco/standard/snmp/mode/qosusage.pm @@ -353,6 +353,12 @@ sub manage_selection { next; } + # Same hash key but only for disco context + if (defined($options{disco})) { + $self->{interface_classmap}->{$policy_index . '.' . $qos_object_index} = $name; + next; + } + my $result = $options{snmp}->map_instance(mapping => $mapping, results => $self->{results}->{$oid_cbQosCMStatsEntry}, instance => $policy_index . '.' . $qos_object_index); my $traffic_usage = (defined($result->{cbQosCMPostPolicyByte64}) && $result->{cbQosCMPostPolicyByte64} =~ /[1-9]/) ? $result->{cbQosCMPostPolicyByte64} : (($result->{cbQosCMPostPolicyByteOverflow} << 32) + $result->{cbQosCMPostPolicyByte}); @@ -380,12 +386,27 @@ sub manage_selection { (defined($self->{option_results}->{filter_source}) ? md5_hex($self->{option_results}->{filter_source}) : md5_hex('all')) . '_' . (defined($self->{option_results}->{filter_counters}) ? md5_hex($self->{option_results}->{filter_counters}) : md5_hex('all')); - if (scalar(keys %{$self->{interface_classmap}}) <= 0) { + if (scalar(keys %{$self->{interface_classmap}}) <= 0 && !defined($options{disco})) { $self->{output}->add_option_msg(short_msg => "Cannot found classmap."); $self->{output}->option_exit(); } } +sub disco_format { + my ($self, %options) = @_; + + $self->{output}->add_disco_format(elements => ['name']); +} + +sub disco_show { + my ($self, %options) = @_; + + $self->manage_selection(disco => 1, %options); + foreach (keys %{$self->{interface_classmap}}) { + $self->{output}->add_disco_entry(name => $self->{interface_classmap}->{$_}); + } +} + 1; __END__ diff --git a/centreon/plugins/templates/counter.pm b/centreon/plugins/templates/counter.pm index 3bda7758b..4dcc182e2 100644 --- a/centreon/plugins/templates/counter.pm +++ b/centreon/plugins/templates/counter.pm @@ -83,6 +83,7 @@ sub new { $options{options}->add_options(arguments => { "filter-counters:s" => { name => 'filter_counters' }, + "list-counters" => { name => 'list_counters' }, }); $self->{statefile_value} = undef; if (defined($options{statefile}) && $options{statefile}) { @@ -98,8 +99,8 @@ sub new { foreach (@{$self->{maps_counters}->{$key}}) { if (!defined($_->{threshold}) || $_->{threshold} != 0) { $options{options}->add_options(arguments => { - 'warning-' . $_->{label} . ':s' => { name => 'warning-' . $_->{label} }, - 'critical-' . $_->{label} . ':s' => { name => 'critical-' . $_->{label} }, + 'warning-' . $_->{label} . ':s' => { name => 'warning-' . $_->{label} }, + 'critical-' . $_->{label} . ':s' => { name => 'critical-' . $_->{label} }, }); } $_->{obj} = centreon::plugins::values->new(statefile => $self->{statefile_value}, @@ -116,6 +117,17 @@ sub check_options { my ($self, %options) = @_; $self->SUPER::init(%options); + if (defined($self->{option_results}->{list_counters})) { + my $list_counter = "Counter list:"; + foreach my $key (keys %{$self->{maps_counters}}) { + foreach (@{$self->{maps_counters}->{$key}}) { + $list_counter .= " " . $_->{label}; + } + } + $self->{output}->output_add(short_msg => $list_counter); + $self->{output}->display(nolabel => 1, force_ignore_perfdata => 1); + $self->{output}->exit(); + } foreach my $key (keys %{$self->{maps_counters}}) { foreach (@{$self->{maps_counters}->{$key}}) { $_->{obj}->init(option_results => $self->{option_results}); diff --git a/network/cisco/prime/restapi/custom/api.pm b/network/cisco/prime/restapi/custom/api.pm new file mode 100644 index 000000000..b2604b23e --- /dev/null +++ b/network/cisco/prime/restapi/custom/api.pm @@ -0,0 +1,248 @@ +# +# Copyright 2016 Centreon (http://www.centreon.com/) +# +# Centreon is a full-fledged industry-strength solution that meets +# the needs in IT infrastructure and application monitoring for +# service performance. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +package network::cisco::prime::restapi::custom::api; + +use strict; +use warnings; +use centreon::plugins::http; +use JSON::XS; + +sub new { + my ($class, %options) = @_; + my $self = {}; + bless $self, $class; + + if (!defined($options{output})) { + print "Class Custom: Need to specify 'output' argument.\n"; + exit 3; + } + if (!defined($options{options})) { + $options{output}->add_option_msg(short_msg => "Class Custom: Need to specify 'options' argument."); + $options{output}->option_exit(); + } + + if (!defined($options{noptions})) { + $options{options}->add_options(arguments => + { + "hostname:s@" => { name => 'hostname' }, + "port:s@" => { name => 'port' }, + "proto:s@" => { name => 'proto' }, + "url-path:s@" => { name => 'url_path' }, + "username:s@" => { name => 'username' }, + "password:s@" => { name => 'password' }, + "proxyurl:s@" => { name => 'proxyurl' }, + "timeout:s@" => { name => 'timeout' }, + }); + } + $options{options}->add_help(package => __PACKAGE__, sections => 'REST API OPTIONS', once => 1); + + $self->{output} = $options{output}; + $self->{mode} = $options{mode}; + $self->{http} = centreon::plugins::http->new(output => $self->{output}); + + return $self; + +} + +# Method to manage multiples +sub set_options { + my ($self, %options) = @_; + # options{options_result} + + $self->{option_results} = $options{option_results}; +} + +# Method to manage multiples +sub set_defaults { + my ($self, %options) = @_; + # options{default} + + # Manage default value + foreach (keys %{$options{default}}) { + if ($_ eq $self->{mode}) { + for (my $i = 0; $i < scalar(@{$options{default}->{$_}}); $i++) { + foreach my $opt (keys %{$options{default}->{$_}[$i]}) { + if (!defined($self->{option_results}->{$opt}[$i])) { + $self->{option_results}->{$opt}[$i] = $options{default}->{$_}[$i]->{$opt}; + } + } + } + } + } +} + +sub check_options { + my ($self, %options) = @_; + # return 1 = ok still hostname + # return 0 = no hostname left + + $self->{hostname} = (defined($self->{option_results}->{hostname})) ? shift(@{$self->{option_results}->{hostname}}) : undef; + $self->{port} = (defined($self->{option_results}->{port})) ? shift(@{$self->{option_results}->{port}}) : 443; + $self->{proto} = (defined($self->{option_results}->{proto})) ? shift(@{$self->{option_results}->{proto}}) : 'https'; + $self->{url_path} = (defined($self->{option_results}->{url_path})) ? shift(@{$self->{option_results}->{url_path}}) : '/webacs/api/v1/data/'; + $self->{username} = (defined($self->{option_results}->{username})) ? shift(@{$self->{option_results}->{username}}) : ''; + $self->{password} = (defined($self->{option_results}->{password})) ? shift(@{$self->{option_results}->{password}}) : ''; + $self->{timeout} = (defined($self->{option_results}->{timeout})) ? shift(@{$self->{option_results}->{timeout}}) : 10; + $self->{proxyurl} = (defined($self->{option_results}->{proxyurl})) ? shift(@{$self->{option_results}->{proxyurl}}) : undef; + + if (!defined($self->{hostname})) { + $self->{output}->add_option_msg(short_msg => "Need to specify hostname option."); + $self->{output}->option_exit(); + } + + if (!defined($self->{hostname}) || + scalar(@{$self->{option_results}->{hostname}}) == 0) { + return 0; + } + return 1; +} + +sub build_options_for_httplib { + my ($self, %options) = @_; + + $self->{option_results}->{hostname} = $self->{hostname}; + $self->{option_results}->{timeout} = $self->{timeout}; + $self->{option_results}->{port} = $self->{port}; + $self->{option_results}->{proto} = $self->{proto}; + $self->{option_results}->{proxyurl} = $self->{proxyurl}; + $self->{option_results}->{credentials} = 1; + $self->{option_results}->{username} = $self->{username}; + $self->{option_results}->{password} = $self->{password}; +} + +sub settings { + my ($self, %options) = @_; + + $self->build_options_for_httplib(); + $self->{http}->set_options(%{$self->{option_results}}); +} + +sub cache_ap { + my ($self, %options) = @_; + + my $has_cache_file = $options{statefile}->read(statefile => 'cache_cisco_prime_' . $self->{hostname} . '_' . $self->{port}); + my $timestamp_cache = $options{statefile}->get(name => 'last_timestamp'); + my $ap = $options{statefile}->get(name => 'ap'); + if ($has_cache_file == 0 || !defined($timestamp_cache) || ((time() - $timestamp_cache) > (($options{reload_cache_time}) * 60))) { + $ap = $self->get(function => 'AccessPoints', object => 'accessPointsDTO', key => 'name', + fields => ['adminStatus', 'clientCount', 'controllerName', 'lwappUpTime', 'status', 'upTime']); + my $datas = { last_timestamp => time(), ap => $ap }; + $options{statefile}->write(data => $datas); + } + + return $ap; +} + +sub get { + my ($self, %options) = @_; + + $self->settings(); + my ($result, $first_result, $max_results) = ({}, 0, 1000); + + while (1) { + my $response = $self->{http}->request(url_path => $self->{url_path} . $options{function} .'.json?.full=true&.sort=' . $options{key} . '&.firstResult=' . $first_result . '&.maxResults=' . $max_results, + critical_status => '', warning_status => ''); + my $content; + eval { + $content = JSON::XS->new->utf8->decode($response); + }; + if ($@) { + $self->{output}->add_option_msg(short_msg => "Cannot decode json response: $@"); + $self->{output}->option_exit(); + } + if (defined($content->{errorDocument})) { + $self->{output}->add_option_msg(short_msg => "Cannot get data: " . $content->{errorDocument}->{message}); + $self->{output}->option_exit(); + } + if (!defined($content->{queryResponse})) { + $self->{output}->add_option_msg(short_msg => "Cannot understand response"); + $self->{output}->option_exit(); + } + + foreach (@{$content->{queryResponse}->{entity}}) { + $result->{$_->{$options{object}}->{$options{key}}} = {}; + foreach my $field (@{$options{fields}}) { + $result->{$_->{$options{object}}->{$options{key}}}->{$field} = $_->{$options{object}}->{$field} + if (defined($_->{$options{object}}->{$field})); + } + } + + $first_result += $max_results; + last if ($max_results > $content->{queryResponse}->{'@count'}); + } + return $result; +} + +1; + +__END__ + +=head1 NAME + +CISCO PRIME REST API + +=head1 SYNOPSIS + +Cisco Prime Rest API custom mode + +=head1 REST API OPTIONS + +=over 8 + +=item B<--hostname> + +Cisco Prime hostname. + +=item B<--port> + +Port used (Default: 443) + +=item B<--proto> + +Specify https if needed (Default: 'https') + +=item B<--url-path> + +Cisco Prime API Path (Default: '/webacs/api/v1/data/'). + +=item B<--username> + +Storeonce username. + +=item B<--password> + +Storeonce password. + +=item B<--proxyurl> + +Proxy URL if any + +=item B<--timeout> + +Set HTTP timeout + +=back + +=head1 DESCRIPTION + +B. + +=cut diff --git a/network/cisco/prime/restapi/mode/apusage.pm b/network/cisco/prime/restapi/mode/apusage.pm new file mode 100644 index 000000000..2871f25bb --- /dev/null +++ b/network/cisco/prime/restapi/mode/apusage.pm @@ -0,0 +1,289 @@ +# +# Copyright 2016 Centreon (http://www.centreon.com/) +# +# Centreon is a full-fledged industry-strength solution that meets +# the needs in IT infrastructure and application monitoring for +# service performance. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +package network::cisco::prime::restapi::mode::apusage; + +use base qw(centreon::plugins::templates::counter); + +use strict; +use warnings; +use centreon::plugins::misc; +use centreon::plugins::statefile; + +my $instance_mode; + +sub custom_status_threshold { + my ($self, %options) = @_; + my $status = 'ok'; + my $message; + + eval { + local $SIG{__WARN__} = sub { $message = $_[0]; }; + local $SIG{__DIE__} = sub { $message = $_[0]; }; + + if (defined($instance_mode->{option_results}->{critical_ap_status}) && $instance_mode->{option_results}->{critical_ap_status} ne '' && + eval "$instance_mode->{option_results}->{critical_ap_status}") { + $status = 'critical'; + } elsif (defined($instance_mode->{option_results}->{warning_ap_status}) && $instance_mode->{option_results}->{warning_ap_status} ne '' && + eval "$instance_mode->{option_results}->{warning_ap_status}") { + $status = 'warning'; + } + }; + if (defined($message)) { + $self->{output}->output_add(long_msg => 'filter status issue: ' . $message); + } + + return $status; +} + +sub custom_status_output { + my ($self, %options) = @_; + my $msg = 'status : ' . $self->{result_values}->{status} . ' (admin: ' . $self->{result_values}->{admin_status} . ')'; + + return $msg; +} + +sub custom_status_calc { + my ($self, %options) = @_; + + $self->{result_values}->{status} = $options{new_datas}->{$self->{instance} . '_status'}; + $self->{result_values}->{name} = $options{new_datas}->{$self->{instance} . '_name'}; + $self->{result_values}->{controller} = $options{new_datas}->{$self->{instance} . '_controller'}; + $self->{result_values}->{admin_status} = $options{new_datas}->{$self->{instance} . '_admin_status'}; + + return 0; +} + +sub custom_uptime_output { + my ($self, %options) = @_; + my $msg = 'uptime started since : ' . centreon::plugins::misc::change_seconds(value => $self->{result_values}->{uptime_absolute}); + + return $msg; +} + +sub custom_lwappuptime_output { + my ($self, %options) = @_; + my $msg = 'lwapp uptime started since : ' . centreon::plugins::misc::change_seconds(value => $self->{result_values}->{lwapp_uptime_absolute}); + + return $msg; +} + +sub set_counters { + my ($self, %options) = @_; + + $self->{maps_counters_type} = [ + { name => 'ctrl', type => 1, cb_prefix_output => 'prefix_controller_output', message_multiple => 'All controllers are ok', , skipped_code => { -11 => 1 } }, + { name => 'ap', type => 1, cb_prefix_output => 'prefix_ap_output', message_multiple => 'All access points are ok', , skipped_code => { -11 => 1 } }, + ]; + + $self->{maps_counters}->{ap} = [ + { label => 'ap-status', threshold => 0, set => { + key_values => [ { name => 'status' }, { name => 'name' }, { name => 'controller' }, { name => 'admin_status' } ], + closure_custom_calc => $self->can('custom_status_calc'), + closure_custom_output => $self->can('custom_status_output'), + closure_custom_perfdata => sub { return 0; }, + closure_custom_threshold_check => $self->can('custom_status_threshold'), + } + }, + { label => 'ap-clients', set => { + key_values => [ { name => 'client_count' }, { name => 'name' } ], + output_template => 'Clients : %s', + perfdatas => [ + { label => 'ap_clients', value => 'client_count_absolute', template => '%s', + min => 0, label_extra_instance => 1, instance_use => 'name_absolute' }, + ], + } + }, + { label => 'ap-uptime', set => { + key_values => [ { name => 'uptime' }, { name => 'name' } ], + closure_custom_output => $self->can('custom_uptime_output'), + perfdatas => [ + { label => 'ap_uptime', value => 'uptime_absolute', template => '%s', + min => 0, unit => 's', label_extra_instance => 1, instance_use => 'name_absolute' }, + ], + } + }, + { label => 'ap-lwappuptime', set => { + key_values => [ { name => 'lwapp_uptime' }, { name => 'name' } ], + closure_custom_output => $self->can('custom_lwappuptime_output'), + perfdatas => [ + { label => 'ap_lwappuptime', value => 'lwapp_uptime_absolute', template => '%s', + min => 0, unit => 's', label_extra_instance => 1, instance_use => 'name_absolute' }, + ], + } + }, + ]; + + $self->{maps_counters}->{ctrl} = [ + { label => 'ctrl-ap-count', set => { + key_values => [ { name => 'ap_count' }, { name => 'name' } ], + output_template => 'Number of access points : %s', + perfdatas => [ + { label => 'ctrl_ap_count', value => 'ap_count_absolute', template => '%s', + min => 0, label_extra_instance => 1, instance_use => 'name_absolute' }, + ], + } + }, + ]; +} + +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 => + { + "filter-controller:s" => { name => 'filter_controller' }, + "filter-ap:s" => { name => 'filter_ap' }, + "warning-ap-status:s" => { name => 'warning_ap_status', default => '%{admin_status} =~ /enable/i && %{status} =~ /minor|warning/i' }, + "critical-ap-status:s" => { name => 'critical_ap_status', default => '%{admin_status} =~ /enable/i && %{status} =~ /major|critical/i' }, + "reload-cache-time:s" => { name => 'reload_cache_time', default => 180 }, + }); + $self->{statefile_cache_ap} = centreon::plugins::statefile->new(%options); + + return $self; +} + +sub check_options { + my ($self, %options) = @_; + $self->SUPER::check_options(%options); + + $self->{statefile_cache_ap}->check_options(%options); + $instance_mode = $self; + $self->change_macros(); +} + +sub prefix_controller_output { + my ($self, %options) = @_; + + return "Controller '" . $options{instance_value}->{name} . "' "; +} + +sub prefix_ap_output { + my ($self, %options) = @_; + + return "Access point '" . $options{instance_value}->{name} . "' "; +} + +sub change_macros { + my ($self, %options) = @_; + + foreach (('warning_ap_status', 'critical_ap_status')) { + if (defined($self->{option_results}->{$_})) { + $self->{option_results}->{$_} =~ s/%\{(.*?)\}/\$self->{result_values}->{$1}/g; + } + } +} + +sub manage_selection { + my ($self, %options) = @_; + + my $access_points = $options{custom}->cache_ap(statefile => $self->{statefile_cache_ap}, + reload_cache_time => $self->{option_results}->{reload_cache_time}); + + ($self->{ap}, $self->{ctrl}) = ({}, {}); + + foreach my $ap_name (keys %{$access_points}) { + if (defined($self->{option_results}->{filter_ap}) && $self->{option_results}->{filter_ap} ne '' && + $ap_name !~ /$self->{option_results}->{filter_ap}/) { + $self->{output}->output_add(long_msg => "skipping '" . $ap_name . "': no matching filter.", debug => 1); + next; + } + if (defined($self->{option_results}->{filter_controller}) && $self->{option_results}->{filter_controller} ne '' && + $access_points->{$ap_name}->{controllerName} !~ /$self->{option_results}->{filter_controller}/) { + $self->{output}->output_add(long_msg => "skipping '" . $access_points->{$ap_name}->{controllerName} . "': no matching filter.", debug => 1); + next; + } + + $access_points->{$ap_name}->{controllerName} = 'NotRegistered' + if (!defined($access_points->{$ap_name}->{controllerName})); + $self->{ap}->{$ap_name} = { + name => $ap_name, controller => $access_points->{$ap_name}->{controllerName}, + status => $access_points->{$ap_name}->{status}, + admin_status => $access_points->{$ap_name}->{adminStatus}, + client_count => $access_points->{$ap_name}->{clientCount}, + lwapp_uptime => $access_points->{$ap_name}->{lwappUpTime}, + uptime => $access_points->{$ap_name}->{upTime}, + }; + $self->{ctrl}->{$access_points->{$ap_name}->{controllerName}} = { name => $access_points->{$ap_name}->{controllerName}, ap_count => 0 } + if (!defined($self->{ctrl}->{$access_points->{$ap_name}->{controllerName}})); + $self->{ctrl}->{$access_points->{$ap_name}->{controllerName}}->{ap_count}++; + } + + if (scalar(keys %{$self->{ap}}) <= 0) { + $self->{output}->add_option_msg(short_msg => "No AP found."); + $self->{output}->option_exit(); + } +} + +1; + +__END__ + +=head1 MODE + +Check AP usages (also the number of access points by controller). + +=over 8 + +=item B<--filter-ap> + +Filter ap name (can be a regexp). + +=item B<--filter-controller> + +Filter controller name (can be a regexp). + +=item B<--filter-counters> + +Only display some counters (regexp can be used). +Example: --filter-counters='^total-error$' + +=item B<--warning-*> + +Threshold warning. +Can be: 'ap-clients', 'ap-uptime', 'ap-lwappuptime', +'ctrl-ap-count'. + +=item B<--critical-*> + +Threshold critical. +Can be: 'ap-clients', 'ap-uptime', 'ap-lwappuptime', +'ctrl-ap-count'. + +=item B<--warning-ap-status> + +Set warning threshold for status (Default: '%{admin_status} =~ /enable/i && %{status} =~ /minor|warning/i') +Can used special variables like: %{name}, %{status}, %{controller}, %{admin_status} + +=item B<--critical-ap-status> + +Set critical threshold for status (Default: '%{admin_status} =~ /enable/i && %{status} =~ /major|critical/i'). +Can used special variables like: %{name}, %{status}, %{controller}, %{admin_status} + +=item B<--reload-cache-time> + +Time in seconds before reloading cache file (default: 180). + +=back + +=cut diff --git a/network/cisco/prime/restapi/plugin.pm b/network/cisco/prime/restapi/plugin.pm new file mode 100644 index 000000000..b0721e19a --- /dev/null +++ b/network/cisco/prime/restapi/plugin.pm @@ -0,0 +1,53 @@ +# +# Copyright 2016 Centreon (http://www.centreon.com/) +# +# Centreon is a full-fledged industry-strength solution that meets +# the needs in IT infrastructure and application monitoring for +# service performance. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +package network::cisco::prime::restapi::plugin; + +use strict; +use warnings; +use base qw(centreon::plugins::script_custom); + +sub new { + my ($class, %options) = @_; + my $self = $class->SUPER::new(package => __PACKAGE__, %options); + bless $self, $class; + + $self->{version} = '1.0'; + %{$self->{modes}} = ( + 'ap-usage' => 'network::cisco::prime::restapi::mode::apusage', + 'wlc-cpu' => 'network::cisco::prime::restapi::mode::wlccpu', + 'wlc-memory' => 'network::cisco::prime::restapi::mode::wlcmemory', + ); + + $self->{custom_modes}{api} = 'network::cisco::prime::restapi::custom::api'; + return $self; +} + +1; + +__END__ + +=head1 PLUGIN DESCRIPTION + +Check Cisco Prime Infrastructure. +Work with API Version 3.1. + + +=cut