icingaweb2/modules/monitoring/library/Monitoring/Backend/AbstractBackend.php

<?php

namespace Icinga\Module\Monitoring\Backend;

use Icinga\Data\DatasourceInterface;
use Icinga\Exception\ProgrammingError;
use Icinga\Application\Benchmark;
use Zend_Config;

class AbstractBackend implements DatasourceInterface
{
    protected $config;

    public function __construct(Zend_Config $config)
    {
        if ($config === null) {
            // $config = new Zend_Config(array()); ???
        }
        $this->config = $config;
        $this->init();
    }

    protected function init()
    {
    }

    /**
     * Backend entry point
     *
     * return self
     */
    public function select()
    {
        return $this;
    }

    /**
     * Create a Query object instance for given virtual table and desired fields
     *
     * Leave fields empty to get all available properties
     *
     * @param string $virtual_table Virtual table name
     * @param array  $fields        Fields
     * @throws \Icinga\Exception\ProgrammingError
     * @return self
     */
    public function from($virtual_table, $fields = array())
    {
        $classname = $this->tableToClassName($virtual_table);
        if (!class_exists($classname)) {
            throw new ProgrammingError(
                sprintf(
                    'Asking for invalid virtual table %s',
                    $classname
                )
            );
        }

        $query = new $classname($this, $fields);
        return $query;
    }

    public function hasView($virtual_table)
    {
        // TODO: This is no longer enough, have to check for Query right now
        return class_exists($this->tableToClassName($virtual_table));
    }

    protected function tableToClassName($virtual_table)
    {
        return '\\Icinga\\Module\\Monitoring\\View\\'
             // . $this->getName()
             // . '\\'
             . ucfirst($virtual_table)
             . 'View';
    }

    public function getName()
    {
        return preg_replace('~^.+\\\(.+?)$~', '$1', get_class($this));
    }

    public function __toString()
    {
        return $this->getName();
    }

    /**
     * UGLY temporary host fetch
     *
     * @param string $host
     * @param bool $fetchAll
     * @return mixed
     */

    public function fetchHost($host, $fetchAll = false)
    {
        $fields = array(
            'host_name',
            'host_address',
            'host_state',
            'host_handled',
            'host_icon_image',
            'host_in_downtime',
            'host_acknowledged',
            'host_check_command',
            'host_last_state_change',
            'host_alias',
            'host_output',
            'host_long_output',
            'host_perfdata',
            'host_notes_url',
            'host_action_url'
        );

        if ($fetchAll === true) {
            $fields = array_merge(
                $fields,
                array(
                    'host_current_check_attempt',
                    'host_max_check_attempts',
                    'host_attempt',
                    'host_last_check',
                    'host_next_check',
                    'host_check_type',
                    'host_last_state_change',
                    'host_last_hard_state_change',
                    'host_last_hard_state',
                    'host_last_time_up',
                    'host_last_time_down',
                    'host_last_time_unreachable',
                    'host_state_type',
                    'host_last_notification',
                    'host_next_notification',
                    'host_no_more_notifications',
                    'host_notifications_enabled',
                    'host_problem_has_been_acknowledged',
                    'host_acknowledgement_type',
                    'host_current_notification_number',
                    'host_passive_checks_enabled',
                    'host_active_checks_enabled',
                    'host_event_handler_enabled',
                    'host_flap_detection_enabled',
                    'host_is_flapping',
                    'host_percent_state_change',
                    'host_check_latency',
                    'host_check_execution_time',
                    'host_scheduled_downtime_depth',
                    'host_failure_prediction_enabled',
                    'host_process_performance_data',
                    'host_obsessing',
                    'host_modified_host_attributes',
                    'host_event_handler',
                    'host_check_command',
                    'host_normal_check_interval',
                    'host_retry_check_interval',
                    'host_check_timeperiod_object_id',
                    'host_status_update_time'
                )
            );
        }

        $select = $this->select()
            ->from('status', $fields)
            ->where('host_name', $host);

        return $select->fetchRow();
    }

    // UGLY temporary service fetch
    public function fetchService($host, $service, $fetchAll = false)
    {
        $fields = array(
            'service_description',
            'host_name',
            'host_address',
            'host_state',
            'host_handled',
            'host_icon_image',
            'service_state',
            'service_handled',
            'service_in_downtime',
            'service_acknowledged',
            'service_check_command',
            'service_last_state_change',
            'service_display_name',
            'service_output',
            'service_long_output',
            'service_perfdata',
            'service_action_url',
            'service_notes_url',
            'service_icon_image'
        );

        if ($fetchAll === true) {
            $fields = array_merge(
                $fields,
                array(
                    'service_current_check_attempt',
                    'service_max_check_attempts',
                    'service_attempt',
                    'service_last_check',
                    'service_next_check',
                    'service_check_type',
                    'service_last_state_change',
                    'service_last_hard_state_change',
                    'service_last_hard_state',
                    'service_last_time_ok',
                    'service_last_time_warning',
                    'service_last_time_unknown',
                    'service_last_time_critical',
                    'service_state_type',
                    'service_last_notification',
                    'service_next_notification',
                    'service_no_more_notifications',
                    'service_notifications_enabled',
                    'service_problem_has_been_acknowledged',
                    'service_acknowledgement_type',
                    'service_current_notification_number',
                    'service_passive_checks_enabled',
                    'service_active_checks_enabled',
                    'service_event_handler_enabled',
                    'service_flap_detection_enabled',
                    'service_is_flapping',
                    'service_percent_state_change',
                    'service_check_latency',
                    'service_check_execution_time',
                    'service_scheduled_downtime_depth',
                    'service_failure_prediction_enabled',
                    'service_process_performance_data',
                    'service_obsessing',
                    'service_modified_service_attributes',
                    'service_event_handler',
                    'service_check_command',
                    'service_normal_check_interval',
                    'service_retry_check_interval',
                    'service_check_timeperiod_object_id',
                    'service_status_update_time'
                )
            );
        }

        $select = $this->select()
            ->from('status', $fields)
            ->where('service_description', $service)
            ->where('host_name', $host);
        return $select->fetchRow();

    }

}