Allow to manage and subscribe incidents

Add a subscribe/unsubscribe option to the `QuickActions`
and manage/unamnage related incidents with the existing
acknowledge

Author: BastianLedererIcinga

application/controllers/HostController.php

@@ -20,6 +20,7 @@
 use Icinga\Module\Icingadb\Model\Host;
 use Icinga\Module\Icingadb\Model\Service;
 use Icinga\Module\Icingadb\Model\ServicestateSummary;
+use Icinga\Module\Icingadb\Notifications\SubscribeIncidents;
 use Icinga\Module\Icingadb\Redis\VolatileStateResults;
 use Icinga\Module\Icingadb\Util\OptimizerHints;
 use Icinga\Module\Icingadb\Web\Control\SearchBar\ObjectSuggestions;
@@ -45,6 +46,7 @@ class HostController extends Controller
 {
     use CommandActions;
     use HookActions;
+    use SubscribeIncidents;
 
     /** @var Host The host object */
     protected $host;
@@ -590,6 +592,16 @@ public function servicesSearchEditorAction(): void
         $this->setTitle($this->translate('Adjust Filter'));
     }
 
+    public function subscribeAction(): void
+    {
+        $this->handleSubscription(true, $this->host, $this->getCommandTargetsUrl());
+    }
+
+    public function unsubscribeAction(): void
+    {
+        $this->handleSubscription(false, $this->host, $this->getCommandTargetsUrl());
+    }
+
     /**
      * Fetch the dependency nodes of the current host
      *

application/controllers/ServiceController.php

@@ -18,6 +18,7 @@
 use Icinga\Module\Icingadb\Model\DependencyNode;
 use Icinga\Module\Icingadb\Model\History;
 use Icinga\Module\Icingadb\Model\Service;
+use Icinga\Module\Icingadb\Notifications\SubscribeIncidents;
 use Icinga\Module\Icingadb\Redis\VolatileStateResults;
 use Icinga\Module\Icingadb\Util\OptimizerHints;
 use Icinga\Module\Icingadb\Web\Control\SearchBar\ObjectSuggestions;
@@ -43,6 +44,7 @@ class ServiceController extends Controller
 {
     use CommandActions;
     use HookActions;
+    use SubscribeIncidents;
 
     /** @var Service The service object */
     protected $service;
@@ -600,6 +602,16 @@ protected function getCommandTargetsUrl(): Url
         return Links::service($this->service, $this->service->host);
     }
 
+    public function subscribeAction(): void
+    {
+        $this->handleSubscription(true, $this->service, $this->getCommandTargetsUrl());
+    }
+
+    public function unsubscribeAction(): void
+    {
+        $this->handleSubscription(false, $this->service, $this->getCommandTargetsUrl());
+    }
+
     protected function getDefaultTabControls(): array
     {
         return [new ObjectHeader($this->service)];

application/forms/Command/Object/AcknowledgeProblemForm.php

@@ -12,6 +12,7 @@
 use Icinga\Module\Icingadb\Command\Object\AcknowledgeProblemCommand;
 use Icinga\Module\Icingadb\Forms\Command\CommandForm;
 use Icinga\Module\Icingadb\Model\Host;
+use Icinga\Module\Icingadb\Notifications\ManagesIncidents;
 use Icinga\Web\Notification;
 use ipl\Html\Attributes;
 use ipl\Html\HtmlElement;
@@ -27,13 +28,16 @@
 
 class AcknowledgeProblemForm extends CommandForm
 {
+    use ManagesIncidents;
+
     public function __construct()
     {
         $this->on(self::ON_SUCCESS, function () {
             if ($this->errorOccurred) {
                 return;
             }
 
+            $this->manageIncidents(true);
             $countObjects = count($this->getObjects());
             if (iterable_value_first($this->getObjects()) instanceof Host) {
                 $message = sprintf(tp(

application/forms/Command/Object/RemoveAcknowledgementForm.php

@@ -9,6 +9,7 @@
 use Icinga\Module\Icingadb\Command\Object\RemoveAcknowledgementCommand;
 use Icinga\Module\Icingadb\Forms\Command\CommandForm;
 use Icinga\Module\Icingadb\Model\Host;
+use Icinga\Module\Icingadb\Notifications\ManagesIncidents;
 use Icinga\Web\Notification;
 use ipl\Orm\Model;
 use ipl\Web\Widget\Icon;
@@ -19,13 +20,16 @@
 
 class RemoveAcknowledgementForm extends CommandForm
 {
+    use ManagesIncidents;
+
     public function __construct()
     {
         $this->on(self::ON_SUCCESS, function () {
             if ($this->errorOccurred) {
                 return;
             }
 
+            $this->manageIncidents(false);
             $countObjects = count($this->getObjects());
             if (iterable_value_first($this->getObjects()) instanceof Host) {
                 $message = sprintf(tp(

configuration.php

@@ -100,6 +100,10 @@
         'icingadb/command/send-custom-notification',
         $this->translate('Allow to send custom notifications for hosts and services')
     );
+    $this->providePermission(
+        'icingadb/notifications/subscribe',
+        $this->translate('Allow to subscribe and manage incidents related to hosts and services')
+    );
 
     $this->providePermission(
         'icingadb/object/show-source',

library/Icingadb/Common/HostLinks.php

@@ -74,4 +74,14 @@ public static function services(Host $host): Url
     {
         return Url::fromPath('icingadb/host/services', ['name' => $host->name]);
     }
+
+    public static function subscribe(Host $host): Url
+    {
+        return Url::fromPath('icingadb/host/subscribe', ['name' => $host->name]);
+    }
+
+    public static function unsubscribe(Host $host): Url
+    {
+        return Url::fromPath('icingadb/host/unsubscribe', ['name' => $host->name]);
+    }
 }

library/Icingadb/Common/ServiceLinks.php

@@ -106,4 +106,14 @@ public static function toggleFeatures(Service $service, Host $host): Url
             ['name' => $service->name, 'host.name' => $host->name]
         );
     }
+
+    public static function subscribe(Service $service, Host $host): Url
+    {
+        return Url::fromPath('icingadb/service/subscribe', ['name' => $service->name, 'host.name' => $host->name]);
+    }
+
+    public static function unsubscribe(Service $service, Host $host): Url
+    {
+        return Url::fromPath('icingadb/service/unsubscribe', ['name' => $service->name, 'host.name' => $host->name]);
+    }
 }

library/Icingadb/Notifications/IncidentFinder.php

@@ -0,0 +1,49 @@
+<?php
+
+// SPDX-FileCopyrightText: 2026 Icinga GmbH <https://icinga.com>
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+namespace Icinga\Module\Icingadb\Notifications;
+
+use Icinga\Module\Icingadb\Model\Host;
+use Icinga\Module\Icingadb\Model\Service;
+use Icinga\Module\Notifications\Integrations\Incidents;
+
+class IncidentFinder
+{
+    /**
+     * Find the open incidents related to the given object
+     *
+     * @param Host|Service $object
+     *
+     * @return Incidents
+     */
+    public static function forObject(Host|Service $object): Incidents
+    {
+        return Incidents::find(self::buildTags($object));
+    }
+
+    /**
+     * Build the tags to match the given host/service
+     *
+     * @param Host|Service $object
+     *
+     * @return array<string, ?string>
+     */
+    private static function buildTags(Host|Service $object): array
+    {
+        if ($object instanceof Host) {
+            return [
+                'host' => $object->name,
+                'service' => null,
+                'environment' => bin2hex($object->environment_id)
+            ];
+        }
+
+        return [
+            'host' => $object->host->name,
+            'service' => $object->name,
+            'environment' => bin2hex($object->environment_id)
+        ];
+    }
+}

library/Icingadb/Notifications/ManagesIncidents.php

@@ -0,0 +1,50 @@
+<?php
+
+// SPDX-FileCopyrightText: 2026 Icinga GmbH <https://icinga.com>
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+namespace Icinga\Module\Icingadb\Notifications;
+
+use Icinga\Application\Icinga;
+use Icinga\Module\Icingadb\Forms\Command\CommandForm;
+use Icinga\Web\Notification;
+use InvalidArgumentException;
+
+/**
+ * @phpstan-require-extends CommandForm
+ */
+trait ManagesIncidents
+{
+    /**
+     * Add or remove the current user as manager of all incidents related to the form's objects
+     *
+     * @param bool $manage
+     *
+     * @return void
+     */
+    protected function manageIncidents(bool $manage): void
+    {
+        if (! Icinga::app()->getModuleManager()->hasEnabled('notifications')) {
+            return;
+        }
+
+        $username = $this->getAuth()->getUser()->getUsername();
+        try {
+            foreach ($this->getObjects() as $object) {
+                foreach (IncidentFinder::forObject($object) as $incident) {
+                    if ($manage) {
+                        $incident->addManager($username);
+                    } else {
+                        $incident->removeManager($username);
+                    }
+                }
+            }
+        } catch (InvalidArgumentException) {
+            if ($manage) {
+                Notification::warning(
+                    t('Cannot manage matching incident, no notification contact configured for your account.')
+                );
+            }
+        }
+    }
+}

library/Icingadb/Notifications/SubscribeIncidents.php

@@ -0,0 +1,46 @@
+<?php
+
+// SPDX-FileCopyrightText: 2026 Icinga GmbH <https://icinga.com>
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+namespace Icinga\Module\Icingadb\Notifications;
+
+use Icinga\Application\Icinga;
+use Icinga\Module\Icingadb\Model\Host;
+use Icinga\Module\Icingadb\Model\Service;
+use Icinga\Module\Icingadb\Web\Controller;
+use ipl\Html\Form;
+use ipl\Web\Url;
+
+/**
+ * @phpstan-require-extends Controller
+ */
+trait SubscribeIncidents
+{
+    /**
+     * Subscribe or unsubscribe all incidents matching the given tags
+     *
+     * @param bool $subscribe
+     * @param Host|Service $object
+     * @param Url $redirectUrl The URL to redirect to after the form has been handled
+     * @return void
+     */
+    protected function handleSubscription(bool $subscribe, Host|Service $object, Url $redirectUrl): void
+    {
+        if (
+            Icinga::app()->getModuleManager()->hasEnabled('notifications')
+            && $this->isGrantedOn('icingadb/notifications/subscribe', $object)
+        ) {
+            $form = (new SubscriptionForm($subscribe, $object))
+                ->setAction((string) Url::fromRequest())
+                ->on(Form::ON_SUBMIT, function () use ($redirectUrl) {
+                    $this->getResponse()->setAutoRefreshInterval(1);
+                    $this->redirectNow($redirectUrl);
+                });
+
+            $form->handleRequest($this->getServerRequest());
+
+            $this->addContent($form);
+        }
+    }
+}