break(office365/management): mode service-status - use new microsoft api (#3382)

This commit is contained in:
qgarnier 2022-01-06 15:16:44 +01:00 committed by GitHub
parent fbc558f51f
commit b8a551b6ac
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 89 additions and 118 deletions

View File

@ -186,7 +186,7 @@ sub request_api_json {
$self->settings(); $self->settings();
my @results; my $results = [];
my %local_options = %options; my %local_options = %options;
while (1) { while (1) {
@ -208,13 +208,13 @@ sub request_api_json {
$self->{output}->add_option_msg(short_msg => "Graph endpoint API return error code '" . $decoded->{error}->{code} . "' (add --debug option for detailed message)"); $self->{output}->add_option_msg(short_msg => "Graph endpoint API return error code '" . $decoded->{error}->{code} . "' (add --debug option for detailed message)");
$self->{output}->option_exit(); $self->{output}->option_exit();
} }
push @results, @{$decoded->{value}}; push @$results, @{$decoded->{value}};
last if (!defined($decoded->{'@odata.nextLink'})); last if (!defined($decoded->{'@odata.nextLink'}));
$local_options{full_url} = $decoded->{'@odata.nextLink'}; $local_options{full_url} = $decoded->{'@odata.nextLink'};
} }
return @results; return $results;
} }
sub request_api_csv { sub request_api_csv {
@ -451,6 +451,15 @@ sub teams_post_notification {
return $response; return $response;
} }
sub get_services_health {
my ($self, %options) = @_;
my $full_url = $self->{graph_endpoint} . '/v1.0/admin/serviceAnnouncement/healthOverviews';
my $response = $self->request_api_json(method => 'GET', full_url => $full_url, hostname => '', get_param => ['$expand=issues']);
return $response;
}
1; 1;
__END__ __END__

View File

@ -30,11 +30,10 @@ sub new {
my $self = $class->SUPER::new(package => __PACKAGE__, %options); my $self = $class->SUPER::new(package => __PACKAGE__, %options);
bless $self, $class; bless $self, $class;
$options{options}->add_options(arguments => $options{options}->add_options(arguments => {
{ 'filter-name:s' => { name => 'filter_name' }
"filter-name:s" => { name => 'filter_name' }, });
});
return $self; return $self;
} }
@ -46,18 +45,14 @@ sub check_options {
sub manage_selection { sub manage_selection {
my ($self, %options) = @_; my ($self, %options) = @_;
my $results = $options{custom}->office_list_services(); my $results = $options{custom}->get_services_health();
foreach my $service (@$results) {
next if (defined($self->{option_results}->{filter_service_name}) && $self->{option_results}->{filter_service_name} ne '' &&
$service->{service} !~ /$self->{option_results}->{filter_service_name}/);
foreach my $service (@{$results->{value}}) { $self->{services}->{ $service->{id} } = {
if (defined($self->{option_results}->{filter_service_name}) && $self->{option_results}->{filter_service_name} ne '' && service_id => $service->{id},
$service->{WorkloadDisplayName} !~ /$self->{option_results}->{filter_service_name}/) { service_name => $service->{service}
$self->{output}->output_add(long_msg => "skipping '" . $service->{WorkloadDisplayName} . "': no matching filter name.", debug => 1);
next;
}
$self->{services}->{$service->{Id}} = {
service_id => $service->{Id},
service_name => $service->{DisplayName},
} }
} }
} }
@ -67,13 +62,19 @@ sub run {
$self->manage_selection(%options); $self->manage_selection(%options);
foreach my $service (sort keys %{$self->{services}}) { foreach my $service (sort keys %{$self->{services}}) {
$self->{output}->output_add(long_msg => sprintf("[service_id = %s] [service_name = %s]", $self->{output}->output_add(
$self->{services}->{$service}->{service_id}, long_msg => sprintf(
$self->{services}->{$service}->{service_name})); "[service_id: %s] [service_name: %s]",
$self->{services}->{$service}->{service_id},
$self->{services}->{$service}->{service_name}
)
);
} }
$self->{output}->output_add(severity => 'OK', $self->{output}->output_add(
short_msg => 'List services:'); severity => 'OK',
short_msg => 'List services:'
);
$self->{output}->display(nolabel => 1, force_ignore_perfdata => 1, force_long_output => 1); $self->{output}->display(nolabel => 1, force_ignore_perfdata => 1, force_long_output => 1);
$self->{output}->exit(); $self->{output}->exit();
} }
@ -91,7 +92,7 @@ sub disco_show {
foreach my $service (sort keys %{$self->{services}}) { foreach my $service (sort keys %{$self->{services}}) {
$self->{output}->add_disco_entry( $self->{output}->add_disco_entry(
service_id => $self->{services}->{$service}->{service_id}, service_id => $self->{services}->{$service}->{service_id},
service_name => $self->{services}->{$service}->{service_name}, service_name => $self->{services}->{$service}->{service_name}
); );
} }
} }

View File

@ -24,74 +24,52 @@ use base qw(centreon::plugins::templates::counter);
use strict; use strict;
use warnings; use warnings;
use centreon::plugins::templates::catalog_functions qw(catalog_status_threshold); use centreon::plugins::templates::catalog_functions qw(catalog_status_threshold_ng);
sub custom_status_threshold {
my ($self, %options) = @_;
my $status = catalog_status_threshold_ng($self, %options);
$self->{instance_mode}->{last_status} = $status;
return $status;
}
sub custom_status_output { sub custom_status_output {
my ($self, %options) = @_; my ($self, %options) = @_;
my $msg = "Status is '" . $self->{result_values}->{status} . "'"; my $msg = "status is '" . $self->{result_values}->{status} . "'";
if (!$self->{output}->is_status(value => $self->{instance_mode}->{last_status}, compare => 'ok', litteral => 1)) {
$msg .= sprintf(
' [issue: %s %s]',
$self->{result_values}->{issue_startDateTime},
$self->{result_values}->{issue_title}
);
}
return $msg; return $msg;
} }
sub custom_status_calc {
my ($self, %options) = @_;
$self->{result_values}->{status} = $options{new_datas}->{$self->{instance} . '_status'};
$self->{result_values}->{service_name} = $options{new_datas}->{$self->{instance} . '_service_name'};
$self->{result_values}->{feature_name} = ($options{new_datas}->{$self->{instance} . '_feature_name'}) ? $options{new_datas}->{$self->{instance} . '_feature_name'} : '';
return 0;
}
sub prefix_service_output { sub prefix_service_output {
my ($self, %options) = @_; my ($self, %options) = @_;
return "Service '" . $options{instance_value}->{display} . "' "; return "Service '" . $options{instance_value}->{service_name} . "' ";
}
sub prefix_feature_output {
my ($self, %options) = @_;
return "Feature '" . $options{instance_value}->{feature_name} . "' ";
}
sub long_output {
my ($self, %options) = @_;
return "Checking service '" . $options{instance_value}->{display} . "'";
} }
sub set_counters { sub set_counters {
my ($self, %options) = @_; my ($self, %options) = @_;
$self->{maps_counters_type} = [ $self->{maps_counters_type} = [
{ name => 'services', type => 3, cb_prefix_output => 'prefix_service_output', cb_long_output => 'long_output', { name => 'services', type => 1, cb_prefix_output => 'prefix_service_output', message_multiple => 'All services are ok' }
message_multiple => 'All services status are ok', indent_long_output => ' ',
group => [
{ name => 'global', type => 0, skipped_code => { -10 => 1 } },
{ name => 'features', display_long => 1, cb_prefix_output => 'prefix_feature_output',
message_multiple => 'All features status are ok', type => 1, skipped_code => { -10 => 1 } },
]
}
]; ];
$self->{maps_counters}->{global} = [ $self->{maps_counters}->{services} = [
{ label => 'status', set => { { label => 'status', type => 2, critical_default => '%{status} !~ /serviceOperational|serviceRestored/i', set => {
key_values => [ { name => 'status' }, { name => 'service_name' } ], key_values => [
closure_custom_calc => $self->can('custom_status_calc'), { name => 'status' }, { name => 'service_name' },
{ name => 'issue_startDateTime' }, { name => 'issue_title' }
],
closure_custom_output => $self->can('custom_status_output'), closure_custom_output => $self->can('custom_status_output'),
closure_custom_perfdata => sub { return 0; }, closure_custom_perfdata => sub { return 0; },
closure_custom_threshold_check => \&catalog_status_threshold closure_custom_threshold_check => $self->can('custom_status_threshold'),
}
}
];
$self->{maps_counters}->{features} = [
{ label => 'status', set => {
key_values => [ { name => 'status' }, { name => 'service_name' }, { name => 'feature_name' } ],
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 => \&catalog_status_threshold
} }
} }
]; ];
@ -103,47 +81,32 @@ sub new {
bless $self, $class; bless $self, $class;
$options{options}->add_options(arguments => { $options{options}->add_options(arguments => {
"filter-service-name:s" => { name => 'filter_service_name' }, 'filter-service-name:s' => { name => 'filter_service_name' }
"filter-feature-name:s" => { name => 'filter_feature_name' },
"warning-status:s" => { name => 'warning_status' },
"critical-status:s" => { name => 'critical_status', default => '%{status} !~ /Normal|Service Restored/i' },
}); });
return $self; return $self;
} }
sub check_options {
my ($self, %options) = @_;
$self->SUPER::check_options(%options);
$self->change_macros(macros => ['warning_status', 'critical_status']);
}
sub manage_selection { sub manage_selection {
my ($self, %options) = @_; my ($self, %options) = @_;
$self->{services} = {}; my $results = $options{custom}->get_services_health();
my $results = $options{custom}->office_get_services_status(); $self->{services} = {};
foreach my $service (@$results) {
foreach my $service (@{$results->{value}}) {
if (defined($self->{option_results}->{filter_service_name}) && $self->{option_results}->{filter_service_name} ne '' && if (defined($self->{option_results}->{filter_service_name}) && $self->{option_results}->{filter_service_name} ne '' &&
$service->{WorkloadDisplayName} !~ /$self->{option_results}->{filter_service_name}/) { $service->{service} !~ /$self->{option_results}->{filter_service_name}/) {
$self->{output}->output_add(long_msg => "skipping '" . $service->{WorkloadDisplayName} . "': no matching filter name.", debug => 1); $self->{output}->output_add(long_msg => "skipping '" . $service->{service} . "': no matching filter name.", debug => 1);
next; next;
} }
$self->{services}->{$service->{Id}}->{display} = $service->{WorkloadDisplayName}; $self->{services}->{ $service->{id} }->{service_name} = $service->{service};
$self->{services}->{$service->{Id}}->{global}->{service_name} = $service->{WorkloadDisplayName}; $self->{services}->{ $service->{id} }->{status} = $service->{status};
$self->{services}->{$service->{Id}}->{global}->{status} = $service->{StatusDisplayName}; $self->{services}->{ $service->{id} }->{issue_startDateTime} = '-';
foreach my $feature (@{$service->{FeatureStatus}}) { $self->{services}->{ $service->{id} }->{issue_title} = '-';
if (defined($self->{option_results}->{filter_feature_name}) && $self->{option_results}->{filter_feature_name} ne '' && if (defined($service->{issues}) && scalar(@{$service->{issues}}) > 0) {
$feature->{FeatureDisplayName} !~ /$self->{option_results}->{filter_feature_name}/) { my $issue = pop @{$service->{issues}};
$self->{output}->output_add(long_msg => "skipping '" . $feature->{FeatureDisplayName} . "': no matching filter name.", debug => 1); $self->{services}->{ $service->{id} }->{issue_startDateTime} = $issue->{startDateTime};
next; $self->{services}->{ $service->{id} }->{issue_title} = $issue->{title};
}
$self->{services}->{$service->{Id}}->{features}->{$feature->{FeatureName}}->{service_name} = $service->{StatusDisplayName};
$self->{services}->{$service->{Id}}->{features}->{$feature->{FeatureName}}->{feature_name} = $feature->{FeatureDisplayName};
$self->{services}->{$service->{Id}}->{features}->{$feature->{FeatureName}}->{status} = $feature->{FeatureServiceStatusDisplayName};
} }
} }
@ -159,24 +122,23 @@ __END__
=head1 MODE =head1 MODE
Check services and features status. Check services status.
=over 8 =over 8
=item B<--filter-*> =item B<--filter-service-name>
Filter services and/or features. Filter services (can be a regexp).
Can be: 'service-name', 'feature-name' (can be a regexp).
=item B<--warning-status> =item B<--warning-status>
Set warning threshold for status (Default: ''). Set warning threshold for status.
Can used special variables like: %{service_name}, %{feature_name}, %{status} Can used special variables like: %{service_name}, %{status}
=item B<--critical-status> =item B<--critical-status>
Set critical threshold for status (Default: '%{status} !~ /Normal|Service Restored/i'). Set critical threshold for status (Default: '%{status} !~ /serviceOperational|serviceRestored/i').
Can used special variables like: %{service_name}, %{feature_name}, %{status} Can used special variables like: %{service_name}, %{status}
=back =back

View File

@ -25,17 +25,16 @@ use warnings;
use base qw(centreon::plugins::script_custom); use base qw(centreon::plugins::script_custom);
sub new { sub new {
my ( $class, %options ) = @_; my ($class, %options) = @_;
my $self = $class->SUPER::new( package => __PACKAGE__, %options ); my $self = $class->SUPER::new(package => __PACKAGE__, %options);
bless $self, $class; bless $self, $class;
$self->{version} = '0.1'; $self->{modes} = {
%{ $self->{modes} } = ( 'list-services' => 'cloud::microsoft::office365::management::mode::listservices',
'list-services' => 'cloud::microsoft::office365::management::mode::listservices', 'service-status' => 'cloud::microsoft::office365::management::mode::servicestatus'
'service-status' => 'cloud::microsoft::office365::management::mode::servicestatus', };
);
$self->{custom_modes}{managementapi} = 'cloud::microsoft::office365::custom::managementapi'; $self->{custom_modes}->{graphapi} = 'cloud::microsoft::office365::custom::graphapi';
return $self; return $self;
} }