WIP Support trigger chains

Author: BastianLedererIcinga

library/Notifications/Model/IncidentHistory.php

@@ -40,6 +40,7 @@
  * @property ?string $notification_state
  * @property ?DateTime $sent_at
  * @property ?string $event_id
+ * @property ?int $triggered_by_id
  *
  * @property Query<Incident>|Incident $incident
  * @property Query<Contact>|Contact $contact
@@ -49,6 +50,7 @@
  * @property Query<RuleEscalation>|RuleEscalation $rule_escalation
  * @property Query<Channel>|Channel $channel
  * @property Query<NotificationHistory>|Collection<NotificationHistory> $notification_history
+ * @property Query<IncidentHistory>|IncidentHistory $triggered_by
  */
 class IncidentHistory extends Model
 {
@@ -81,7 +83,8 @@ public function getColumns(): array
             'message',
             'notification_state',
             'sent_at',
-            'event_id'
+            'event_id',
+            'triggered_by_id'
         ];
     }
 
@@ -140,6 +143,9 @@ public function createRelations(Relations $relations): void
         $relations->belongsTo('rule_escalation', RuleEscalation::class)->setJoinType('LEFT');
         $relations->belongsTo('channel', Channel::class)->setJoinType('LEFT');
         $relations->hasMany('notification_history', NotificationHistory::class)->setJoinType('LEFT');
+        $relations->belongsTo('triggered_by', self::class)
+            ->setCandidateKey('triggered_by_id')
+            ->setJoinType('LEFT');
     }
 
     /**

library/Notifications/Widget/Detail/NotificationHistoryDetail.php

@@ -11,6 +11,8 @@
 use Icinga\Module\Notifications\Common\IncidentHistoryType;
 use Icinga\Module\Notifications\Model\IncidentHistory;
 use Icinga\Module\Notifications\Model\NotificationHistory;
+use Icinga\Module\Notifications\Model\Rule;
+use Icinga\Module\Notifications\Model\RuleEscalation;
 use Icinga\Module\Notifications\View\IncidentRenderer;
 use Icinga\Module\Notifications\Widget\ItemList\ObjectList;
 use ipl\Html\Attributes;
@@ -120,16 +122,35 @@ protected function createIncident(): array
 
     protected function createReason(): array
     {
+        [$reason, $rule, $ruleEscalation] = $this->resolveTriggerChain();
         $triggerChain = new HtmlElement(
             'div',
             Attributes::create(['class' => 'trigger-chain']),
             new HtmlElement(
                 'span',
                 Attributes::create(['class' => 'item']),
-                Text::create($this->resolveReason()->getLabel())
+                Text::create($reason->getLabel())
             )
         );
 
+        if ($rule !== null) {
+            $triggerChain->addHtml(
+                new HtmlElement(
+                    'span',
+                    Attributes::create(['class' => 'item']),
+                    Text::create(sprintf($this->translate('Rule %s matched'), $rule->name))
+                ),
+                new HtmlElement(
+                    'span',
+                    Attributes::create(['class' => 'item']),
+                    Text::create(sprintf(
+                        $this->translate('Escalation triggered (%s)'),
+                        EscalationConditionDescriber::describe($ruleEscalation?->condition)
+                    ))
+                )
+            );
+        }
+
         $triggerChain->addHtml(
             new HtmlElement(
                 'span',
@@ -193,17 +214,41 @@ protected function createReason(): array
         ];
     }
 
-    protected function resolveReason(): IncidentHistoryType
+    /**
+     * Get the root cause and the matching rule and escalation that triggered the notification
+     *
+     * @return array{IncidentHistoryType, ?Rule, ?RuleEscalation}
+     */
+    protected function resolveTriggerChain(): array
     {
-        /** @var ?IncidentHistory $entry */
-        $entry = IncidentHistory::on(Database::get())
-            ->filter(Filter::all(
-                Filter::equal('incident_id', $this->notificationHistory->incident_id),
-                Filter::equal('event_id', $this->notificationHistory->event_id)
-            ))
-            ->first();
-
-        return $entry?->type ?? $this->notificationHistory->incident_history->type;
+        $reason = $this->notificationHistory->incident_history->type;
+        $rule = null;
+        $ruleEscalation = null;
+
+        $triggeredBy = $this->notificationHistory->incident_history->triggered_by_id;
+        while ($triggeredBy !== null) {
+            $node = IncidentHistory::on(Database::get())
+                ->with(['rule', 'rule_escalation'])
+                ->filter(Filter::equal('id', $triggeredBy))
+                ->first();
+
+            if ($node === null) {
+                break;
+            }
+
+            if ($node->rule_id !== null) {
+                $rule = $node->rule;
+            }
+
+            if ($node->rule_escalation_id !== null) {
+                $ruleEscalation = $node->rule_escalation;
+            }
+
+            $reason = $node->type;
+            $triggeredBy = $node->triggered_by_id;
+        }
+
+        return [$reason, $rule, $ruleEscalation];
     }
 
     protected function assemble(): void