301 lines
10 KiB
PHP
301 lines
10 KiB
PHP
<?php
|
|
// {{{ICINGA_LICENSE_HEADER}}}
|
|
/**
|
|
* This file is part of Icinga Web 2.
|
|
*
|
|
* Icinga Web 2 - Head for multiple monitoring backends.
|
|
* Copyright (C) 2013 Icinga Development Team
|
|
*
|
|
* 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, or (at your option) any later version.
|
|
*
|
|
* 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
*
|
|
* @copyright 2013 Icinga Development Team <info@icinga.org>
|
|
* @license http://www.gnu.org/licenses/gpl-2.0.txt GPL, version 2
|
|
* @author Icinga Development Team <info@icinga.org>
|
|
*
|
|
*/
|
|
// {{{ICINGA_LICENSE_HEADER}}}
|
|
|
|
use \Icinga\Web\Form;
|
|
use \Icinga\Web\Controller\ActionController;
|
|
use \Icinga\Web\Widget\Tabextension\OutputFormat;
|
|
use \Icinga\Module\Monitoring\Backend;
|
|
use \Icinga\Module\Monitoring\Object\Host;
|
|
use \Icinga\Module\Monitoring\Object\Service;
|
|
use \Icinga\Module\Monitoring\Form\Command\MultiCommandFlagForm;
|
|
use \Icinga\Module\Monitoring\DataView\HostStatus as HostStatusView;
|
|
use \Icinga\Module\Monitoring\DataView\ServiceStatus as ServiceStatusView;
|
|
use \Icinga\Module\Monitoring\DataView\Comment as CommentView;
|
|
|
|
/**
|
|
* Displays aggregations collections of multiple objects.
|
|
*/
|
|
class Monitoring_MultiController extends ActionController
|
|
{
|
|
public function init()
|
|
{
|
|
$this->view->queries = $this->getDetailQueries();
|
|
$this->backend = Backend::createBackend($this->_getParam('backend'));
|
|
$this->createTabs();
|
|
}
|
|
|
|
public function hostAction()
|
|
{
|
|
$filters = $this->view->queries;
|
|
$errors = array();
|
|
|
|
// Hosts
|
|
$backendQuery = HostStatusView::fromRequest(
|
|
$this->_request,
|
|
array(
|
|
'host_name',
|
|
'host_in_downtime',
|
|
'host_unhandled_service_count',
|
|
'host_passive_checks_enabled',
|
|
'host_obsessing',
|
|
'host_notifications_enabled',
|
|
'host_event_handler_enabled',
|
|
'host_flap_detection_enabled',
|
|
'host_active_checks_enabled'
|
|
)
|
|
)->getQuery();
|
|
if ($this->_getParam('host') !== '*') {
|
|
$this->applyQueryFilter($backendQuery, $filters);
|
|
}
|
|
$hosts = $backendQuery->fetchAll();
|
|
|
|
// Comments
|
|
$commentQuery = CommentView::fromRequest($this->_request)->getQuery();
|
|
$this->applyQueryFilter($commentQuery, $filters);
|
|
$comments = array_keys($this->getUniqueValues($commentQuery->fetchAll(), 'comment_id'));
|
|
|
|
$this->view->objects = $this->view->hosts = $hosts;
|
|
$this->view->problems = $this->getProblems($hosts);
|
|
$this->view->comments = isset($comments) ? $comments : $this->getComments($hosts);
|
|
$this->view->hostnames = $this->getProperties($hosts, 'host_name');
|
|
$this->view->downtimes = $this->getDowntimes($hosts);
|
|
$this->view->errors = $errors;
|
|
|
|
$this->handleConfigurationForm(array(
|
|
'host_passive_checks_enabled' => 'Passive Checks',
|
|
'host_active_checks_enabled' => 'Active Checks',
|
|
'host_obsessing' => 'Obsessing',
|
|
'host_notifications_enabled' => 'Notifications',
|
|
'host_event_handler_enabled' => 'Event Handler',
|
|
'host_flap_detection_enabled' => 'Flap Detection'
|
|
));
|
|
$this->view->form->setAction('/icinga2-web/monitoring/multi/host');
|
|
}
|
|
|
|
/**
|
|
* @param $backendQuery BaseQuery The query to apply the filter to
|
|
* @param $filter array Containing the filter expressions from the request
|
|
*/
|
|
private function applyQueryFilter($backendQuery, $filter)
|
|
{
|
|
// fetch specified hosts
|
|
foreach ($filter as $index => $expr) {
|
|
if (!array_key_exists('host', $expr)) {
|
|
$errors[] = 'Query ' . $index . ' misses property host.';
|
|
continue;
|
|
}
|
|
// apply filter expressions from query
|
|
$backendQuery->orWhere('host_name', $expr['host']);
|
|
if (array_key_exists('service', $expr)) {
|
|
$backendQuery->andWhere('service_description', $expr['service']);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Create an array with all unique values as keys.
|
|
*
|
|
* @param array $values The array containing the objects
|
|
* @param $key The key to access
|
|
*
|
|
* @return array
|
|
*/
|
|
private function getUniqueValues($values, $key)
|
|
{
|
|
$unique = array();
|
|
foreach ($values as $value)
|
|
{
|
|
if (is_array($value)) {
|
|
$unique[$value[$key]] = $value[$key];
|
|
} else {
|
|
$unique[$value->{$key}] = $value->{$key};
|
|
}
|
|
}
|
|
return $unique;
|
|
}
|
|
|
|
/**
|
|
* Get the numbers of problems in the given objects
|
|
*
|
|
* @param $object array The hosts or services
|
|
*/
|
|
private function getProblems($objects)
|
|
{
|
|
$problems = 0;
|
|
foreach ($objects as $object) {
|
|
if (property_exists($object, 'host_unhandled_service_count')) {
|
|
$problems += $object->{'host_unhandled_service_count'};
|
|
} else if (
|
|
property_exists($object, 'service_handled') &&
|
|
!$object->service_handled &&
|
|
$object->service_state > 0
|
|
) {
|
|
$problems++;
|
|
}
|
|
}
|
|
return $problems;
|
|
}
|
|
|
|
private function getComments($objects)
|
|
{
|
|
$unique = array();
|
|
foreach ($objects as $object) {
|
|
$unique = array_merge($unique, $this->getUniqueValues($object->comments, 'comment_internal_id'));
|
|
}
|
|
return array_keys($unique);
|
|
}
|
|
|
|
private function getProperties($objects, $property)
|
|
{
|
|
$objectnames = array();
|
|
foreach ($objects as $object) {
|
|
$objectnames[] = $object->{$property};
|
|
}
|
|
return $objectnames;
|
|
}
|
|
|
|
private function getDowntimes($objects)
|
|
{
|
|
$downtimes = array();
|
|
foreach ($objects as $object)
|
|
{
|
|
if (
|
|
(property_exists($object, 'host_in_downtime') && $object->host_in_downtime) ||
|
|
(property_exists($object, 'service_in_downtime') && $object->service_in_downtime)
|
|
) {
|
|
$downtimes[] = true;
|
|
}
|
|
}
|
|
return $downtimes;
|
|
}
|
|
|
|
public function serviceAction()
|
|
{
|
|
$filters = $this->view->queries;
|
|
$errors = array();
|
|
|
|
$backendQuery = ServiceStatusView::fromRequest(
|
|
$this->_request,
|
|
array(
|
|
'host_name',
|
|
'service_description',
|
|
'service_handled',
|
|
'service_state',
|
|
'service_in_downtime',
|
|
|
|
'service_passive_checks_enabled',
|
|
'service_notifications_enabled',
|
|
'service_event_handler_enabled',
|
|
'service_flap_detection_enabled',
|
|
'service_active_checks_enabled'
|
|
)
|
|
)->getQuery();
|
|
if ($this->_getParam('service') !== '*' && $this->_getParam('host') !== '*') {
|
|
$this->applyQueryFilter($backendQuery, $filters);
|
|
}
|
|
$services = $backendQuery->fetchAll();
|
|
|
|
// Comments
|
|
$commentQuery = CommentView::fromRequest($this->_request)->getQuery();
|
|
$this->applyQueryFilter($commentQuery, $filters);
|
|
$comments = array_keys($this->getUniqueValues($commentQuery->fetchAll(), 'comment_id'));
|
|
|
|
$this->view->objects = $this->view->services = $services;
|
|
$this->view->problems = $this->getProblems($services);
|
|
$this->view->comments = isset($comments) ? $comments : $this->getComments($services);
|
|
$this->view->hostnames = $this->getProperties($services, 'host_name');
|
|
$this->view->servicenames = $this->getProperties($services, 'service_description');
|
|
$this->view->downtimes = $this->getDowntimes($services);
|
|
$this->view->errors = $errors;
|
|
|
|
$this->handleConfigurationForm(array(
|
|
'service_passive_checks_enabled' => 'Passive Checks',
|
|
'service_active_checks_enabled' => 'Active Checks',
|
|
'service_notifications_enabled' => 'Notifications',
|
|
'service_event_handler_enabled' => 'Event Handler',
|
|
'service_flap_detection_enabled' => 'Flap Detection'
|
|
));
|
|
$this->view->form->setAction('/icinga2-web/monitoring/multi/service');
|
|
}
|
|
|
|
/**
|
|
* Handle the form to edit configuration flags.
|
|
*
|
|
* @param $flags array The used flags.
|
|
*/
|
|
private function handleConfigurationForm(array $flags)
|
|
{
|
|
$this->view->form = $form = new MultiCommandFlagForm($flags);
|
|
$form->setRequest($this->_request);
|
|
if ($form->isSubmittedAndValid()) {
|
|
// TODO: Handle commands
|
|
$changed = $form->getChangedValues();
|
|
}
|
|
if ($this->_request->isPost() === false) {
|
|
$this->view->form->initFromItems($this->view->objects);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Fetch all requests from the 'detail' parameter.
|
|
*
|
|
* @return array An array of request that contain
|
|
* the filter arguments as properties.
|
|
*/
|
|
private function getDetailQueries()
|
|
{
|
|
$details = $this->_getAllParams();
|
|
$objects = array();
|
|
|
|
foreach ($details as $property => $values) {
|
|
if (!is_array($values)) {
|
|
continue;
|
|
}
|
|
foreach ($values as $index => $value) {
|
|
if (!array_key_exists($index, $objects)) {
|
|
$objects[$index] = array();
|
|
}
|
|
$objects[$index][$property] = $value;
|
|
}
|
|
}
|
|
return $objects;
|
|
}
|
|
|
|
/**
|
|
* Return all tabs for this controller
|
|
*
|
|
* @return Tabs
|
|
*/
|
|
private function createTabs()
|
|
{
|
|
$tabs = $this->getTabs();
|
|
$tabs->extend(new OutputFormat());
|
|
}
|
|
}
|