application/models/scheduling_queue.php

   1 <?php defined('SYSPATH') OR die('No direct access allowed.');
   2
   3 /**
   4  * Handle comments for hosts and services
   5  */
   6 class Scheduling_queue_Model extends Model {
   7
   8         private $limit = 1000;
   9         private $offset = 0;
  10
  11         /**
  12          * Sets how many objects show_schduling_queue should return
  13          *
  14          * @param $limit
  15          * @param $offset
  16          */
  17         public function set_range( $limit, $offset ) {
  18                 $this->limit = $limit;
  19                 $this->offset = $offset;
  20         }
  21
  22         /**
  23          * Fetch scheduled events
  24          *
  25          * @param $service_filter string = null
  26          * @param $host_filter string = null
  27          * @return Database result object or false if none if $count is false or unset, otherwise the number of result rows
  28          */
  29         public function show_scheduling_queue($service_filter = null, $host_filter = null)
  30         {
  31                 $result = array();
  32                 $ls = Livestatus::instance();
  33
  34                 $max_objects = $this->limit + $this->offset; /* At most object needed to be fetched */
  35
  36                 $service_options = array(
  37                         'columns' => array(
  38                                 'host_name',
  39                                 'description',
  40                                 'last_check',
  41                                 'next_check',
  42                                 'check_type', // 0 == active, 1 == passive
  43                                 'active_checks_enabled'
  44                         ),
  45                         'filter' => array( 'should_be_scheduled' => 1 ),
  46                         'limit' => $max_objects,
  47                         'order' => array( 'next_check' => 'asc' )
  48                 );
  49
  50                 if($service_filter) {
  51                         $service_options['filter']['description'] = array("~~" => ".*$service_filter.*");
  52                 }
  53                 if($host_filter) {
  54                         $service_options['filter']['host_name'] = array("~~" => ".*$host_filter.*");
  55                 }
  56                 $service_checks = $ls->getServices($service_options);
  57
  58                 $host_options = $service_options;
  59
  60                 $host_options['columns'] = array(
  61                         'name',
  62                         'last_check',
  63                         'next_check',
  64                         'check_type', // 0 == active, 1 == passive
  65                         'active_checks_enabled'
  66                 );
  67                 $host_options['filter'] = array(
  68                         'filter' => array( 'should_be_scheduled' => 1 )
  69                         );
  70
  71                 if($host_filter) {
  72                         $host_options['filter']['host_name'] = array("~~" => ".*$host_filter.*");
  73                 }
  74                 $host_checks = $ls->getHosts($host_options);
  75                 if(!$host_checks && !$service_checks) {
  76                         return array();
  77                 }
  78
  79                 /* Do merge */
  80                 $host_ptr = 0;
  81                 $service_ptr = 0;
  82                 $output = array();
  83                 for( $i=0; $i<$this->limit + $this->offset; $i++ ) {
  84                         $host    = isset($host_checks[$host_ptr]) ? $host_checks[$host_ptr] : false;
  85                         $service = isset($service_checks[$service_ptr]) ? $service_checks[$service_ptr] : false;
  86
  87                         /* No more objects */
  88                         if( $host === false && $service === false ) break;
  89
  90                         if( $host === false || ($service !== false && $host['next_check'] > $service['next_check'] )) {
  91                                 /* Service */
  92                                 if( $i >= $this->offset ) {
  93                                         $output[] = (object)$service;
  94                                 }
  95                                 $service_ptr++;
  96                         } else {
  97                                 /* Host */
  98                                 if( $i >= $this->offset )
  99                                         $output[] = (object)$host;
 100                                 $host_ptr++;
 101                         }
 102                 }
 103
 104                 return $output;
 105         }
 106 }