WIP

Icinga · Feb 8, 2023 · 72287ad · 72287ad
1 parent d14c732
commit 72287ad
Show file tree

Hide file tree

Showing 6 changed files with 418 additions and 23 deletions.
diff --git a/library/Icingadb/Model/Host.php b/library/Icingadb/Model/Host.php
@@ -222,6 +222,11 @@ public function createRelations(Relations $relations)
         $relations->belongsToMany('hostgroup', Hostgroup::class)
             ->through(HostgroupMember::class);
 
+        $relations->hasMany('sla_history_state', SlaHistoryState::class)
+            ->setJoinType('LEFT');
+        $relations->hasMany('sla_history_downtime', SlaHistoryDowntime::class)
+            ->setJoinType('LEFT');
+
         $relations->hasOne('state', HostState::class)->setJoinType('LEFT');
         $relations->hasMany('comment', Comment::class)->setJoinType('LEFT');
         $relations->hasMany('downtime', Downtime::class)->setJoinType('LEFT');

diff --git a/library/Icingadb/Model/HostSlaHistorySummary.php b/library/Icingadb/Model/HostSlaHistorySummary.php
@@ -0,0 +1,108 @@
+<?php
+
+namespace Icinga\Module\Icingadb\Model;
+
+use ipl\Orm\Relations;
+use ipl\Orm\UnionModel;
+use ipl\Sql\Expression;
+
+class HostSlaHistorySummary extends UnionModel
+{
+    public function getTableName()
+    {
+        return 'host';
+    }
+
+    public function getKeyName()
+    {
+        return 'host_id';
+    }
+
+    public function getColumns()
+    {
+        return [
+            'host_id',
+            'display_name',
+            'event_time',
+            'event_type',
+            'event_priority',
+            'hard_state',
+            'previous_hard_state'
+        ];
+    }
+
+    public function getUnions()
+    {
+        return [
+            [
+                Host::class,
+                [
+                    'sla_history_downtime'
+                ],
+                [
+                    'display_name'        => 'host.display_name',
+                    'event_priority'      => new Expression('1'),
+                    'event_time'          => 'sla_history_downtime.downtime_start',
+                    'event_type'          => new Expression('\'downtime_start\''),
+                    'hard_state'          => new Expression('NULL'),
+                    'host_id'             => 'id',
+                    'previous_hard_state' => new Expression('NULL'),
+                ]
+            ],
+            [
+                Host::class,
+                [
+                    'sla_history_downtime'
+                ],
+                [
+                    'display_name'        => 'host.display_name',
+                    'event_priority'      => new Expression('2'),
+                    'event_time'          => 'sla_history_downtime.downtime_end',
+                    'event_type'          => new Expression('\'downtime_end\''),
+                    'hard_state'          => new Expression('NULL'),
+                    'host_id'             => 'id',
+                    'previous_hard_state' => new Expression('NULL'),
+                ]
+            ],
+            [
+                Host::class,
+                [
+                    'sla_history_state'
+                ],
+                [
+                    'display_name'        => 'display_name',
+                    'event_priority'      => new Expression('0'),
+                    'event_time'          => 'sla_history_state.event_time',
+                    'event_type'          => new Expression('\'state_change\''),
+                    'hard_state'          => 'sla_history_state.hard_state',
+                    'host_id'             => 'id',
+                    'previous_hard_state' => 'sla_history_state.previous_hard_state',
+                ]
+            ],
+            // Fake result!!
+            [
+                Host::class,
+                [],
+                [
+                    'display_name'        => 'host.display_name',
+                    'event_priority'      => new Expression('3'),
+                    'event_time'          => new Expression('NULL'),
+                    'event_type'          => new Expression('\'end\''),
+                    'hard_state'          => new Expression('NULL'),
+                    'host_id'             => 'id',
+                    'previous_hard_state' => new Expression('NULL'),
+                ]
+            ]
+        ];
+    }
+
+    public function getDefaultSort()
+    {
+        return ['display_name', 'event_time', 'event_priority'];
+    }
+
+    public function createRelations(Relations $relations)
+    {
+        (new Host())->createRelations($relations);
+    }
+}
diff --git a/library/Icingadb/Model/SlaHistoryDowntime.php b/library/Icingadb/Model/SlaHistoryDowntime.php
@@ -0,0 +1,59 @@
+<?php
+
+namespace Icinga\Module\Icingadb\Model;
+
+use Icinga\Module\Icingadb\Model\Behavior\Timestamp;
+use ipl\Orm\Behavior\Binary;
+use ipl\Orm\Behaviors;
+use ipl\Orm\Model;
+use ipl\Orm\Relations;
+
+class SlaHistoryDowntime extends Model
+{
+    public function getTableName()
+    {
+        return 'sla_history_downtime';
+    }
+
+    public function getKeyName()
+    {
+        return 'id';
+    }
+
+    public function getColumns()
+    {
+        return [
+            'environment_id',
+            'endpoint_id',
+            'host_id',
+            'service_id',
+            'downtime_id',
+            'object_type',
+            'downtime_start',
+            'downtime_end'
+        ];
+    }
+
+    public function createBehaviors(Behaviors $behaviors)
+    {
+        $behaviors->add(new Binary([
+            'id',
+            'environment_id',
+            'endpoint_id',
+            'host_id',
+            'service_id',
+            'downtime_id'
+        ]));
+
+        $behaviors->add(new Timestamp([
+            'downtime_start',
+            'downtime_end'
+        ]));
+    }
+
+    public function createRelations(Relations $relations)
+    {
+        $relations->belongsTo('host', Host::class);
+        $relations->belongsTo('service', Service::class);
+    }
+}
diff --git a/library/Icingadb/Model/SlaHistoryState.php b/library/Icingadb/Model/SlaHistoryState.php
@@ -0,0 +1,60 @@
+<?php
+
+namespace Icinga\Module\Icingadb\Model;
+
+use Icinga\Module\Icingadb\Model\Behavior\Timestamp;
+use ipl\Orm\Behavior\Binary;
+use ipl\Orm\Behaviors;
+use ipl\Orm\Model;
+use ipl\Orm\Relations;
+
+class SlaHistoryState extends Model
+{
+    public function getTableName()
+    {
+        return 'sla_history_state';
+    }
+
+    public function getKeyName()
+    {
+        return 'id';
+    }
+
+    public function getColumns()
+    {
+        return [
+            'environment_id',
+            'endpoint_id',
+            'host_id',
+            'service_id',
+            'object_type',
+            'event_time',
+            'hard_state',
+            'previous_hard_state'
+        ];
+    }
+
+    public function createBehaviors(Behaviors $behaviors)
+    {
+        $behaviors->add(new Binary([
+            'id',
+            'environment_id',
+            'endpoint_id',
+            'host_id',
+            'service_id'
+        ]));
+
+        $behaviors->add(new Timestamp(['event_time']));
+    }
+
+    public function createRelations(Relations $relations)
+    {
+        $relations->belongsTo('host', Host::class);
+        $relations->belongsTo('service', Service::class);
+    }
+
+    public function getDefaultSort()
+    {
+        return ['event_time'];
+    }
+}
diff --git a/library/Icingadb/ProvidedHook/Reporting/HostSlaReport.php b/library/Icingadb/ProvidedHook/Reporting/HostSlaReport.php
@@ -5,11 +5,12 @@
 namespace Icinga\Module\Icingadb\ProvidedHook\Reporting;
 
 use Icinga\Application\Icinga;
-use Icinga\Module\Icingadb\Model\Host;
+use Icinga\Module\Icingadb\Model\HostSlaHistorySummary;
 use Icinga\Module\Reporting\ReportData;
 use Icinga\Module\Reporting\ReportRow;
 use Icinga\Module\Reporting\Timerange;
 use ipl\Sql\Expression;
+use ipl\Stdlib\Filter;
 use ipl\Stdlib\Filter\Rule;
 
 use function ipl\I18n\t;
@@ -46,23 +47,56 @@ protected function createReportRow($row)
 
     protected function fetchSla(Timerange $timerange, Rule $filter = null)
     {
-        $sla = Host::on($this->getDb())
-            ->columns([
-                'display_name',
-                'sla' => new Expression(sprintf(
-                    "get_sla_ok_percent(%s, NULL, '%s', '%s')",
-                    'host.id',
-                    $timerange->getStart()->format('Uv'),
-                    $timerange->getEnd()->format('Uv')
-                ))
-            ]);
-
-        $this->applyRestrictions($sla);
-
-        if ($filter !== null) {
-            $sla->filter($filter);
+        $start = (int) $timerange->getStart()->format('U');
+        $end = (int) $timerange->getEnd()->format('U');
+
+        $query = HostSlaHistorySummary::on($this->getDb());
+
+        $index = 0;
+        foreach ($query->getUnions() as $union) {
+            $filterAll = Filter::all();
+            if ($index >= 2) {
+                if ($index < 3) {
+                    $filterAll
+                        ->add(Filter::unlike('sla_history_state.service_id', '*'))
+                        ->add(Filter::greaterThan('sla_history_state.event_time', $start))
+                        ->add(Filter::lessThan('sla_history_state.event_time', $end));
+                } else {
+                    $union->columns(array_merge($union->getColumns(), ['event_time' => new Expression($end * 1000)]));
+                }
+            } else {
+                $filterAll
+                    ->add(Filter::unlike('sla_history_downtime.service_id', '*'))
+                    ->add(Filter::lessThan('sla_history_downtime.downtime_start', $end))
+                    ->add(Filter::greaterThanOrEqual('sla_history_downtime.downtime_end', $start));
+
+                if ($index === 1) {
+                    $filterAll->add(Filter::lessThan('sla_history_downtime.downtime_end', $end));
+                } else {
+                    $union->columns(
+                        array_merge(
+                            $union->getColumns(),
+                            [
+                                'event_time' => new Expression(
+                                    sprintf('GREATEST(host_sla_history_downtime.downtime_start, %s)', $start * 1000)
+                                )
+                            ]
+                        )
+                    );
+                }
+            }
+
+            ++$index;
+
+            $union->filter($filterAll);
+
+            if ($filter !== null) {
+                $union->filter($filter);
+            }
         }
 
-        return $sla;
+        $this->applyRestrictions($query);
+
+        return $query;
     }
 }