Adding upstream version 1.0.2.upstream/1.0.2upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 239 insertions, 0 deletions

diff --git a/application/controllers/ServiceController.php b/application/controllers/ServiceController.php
new file mode 100644
index 0000000..2933d93
--- /dev/null
+++ b/application/controllers/ServiceController.php
@@ -0,0 +1,239 @@
+<?php
+
+/* Icinga DB Web | (c) 2020 Icinga GmbH | GPLv2 */
+
+namespace Icinga\Module\Icingadb\Controllers;
+
+use Icinga\Exception\NotFoundError;
+use Icinga\Module\Icingadb\Command\Object\GetObjectCommand;
+use Icinga\Module\Icingadb\Command\Transport\CommandTransport;
+use Icinga\Module\Icingadb\Common\CommandActions;
+use Icinga\Module\Icingadb\Common\Links;
+use Icinga\Module\Icingadb\Common\ServiceLinks;
+use Icinga\Module\Icingadb\Hook\TabHook\HookActions;
+use Icinga\Module\Icingadb\Model\History;
+use Icinga\Module\Icingadb\Model\Service;
+use Icinga\Module\Icingadb\Redis\VolatileStateResults;
+use Icinga\Module\Icingadb\Web\Controller;
+use Icinga\Module\Icingadb\Widget\Detail\QuickActions;
+use Icinga\Module\Icingadb\Widget\Detail\ServiceDetail;
+use Icinga\Module\Icingadb\Widget\Detail\ServiceInspectionDetail;
+use Icinga\Module\Icingadb\Widget\Detail\ServiceMetaInfo;
+use Icinga\Module\Icingadb\Widget\ItemList\HistoryList;
+use Icinga\Module\Icingadb\Widget\ItemList\ServiceList;
+use ipl\Stdlib\Filter;
+use ipl\Web\Url;
+
+class ServiceController extends Controller
+{
+    use CommandActions;
+    use HookActions;
+
+    /** @var Service The service object */
+    protected $service;
+
+    public function init()
+    {
+        $name = $this->params->getRequired('name');
+        $hostName = $this->params->getRequired('host.name');
+
+        $query = Service::on($this->getDb())->with([
+            'state',
+            'icon_image',
+            'host',
+            'host.state'
+        ]);
+        $query
+            ->setResultSetClass(VolatileStateResults::class)
+            ->filter(Filter::all(
+                Filter::equal('service.name', $name),
+                Filter::equal('host.name', $hostName)
+            ));
+
+        $this->applyRestrictions($query);
+
+        /** @var Service $service */
+        $service = $query->first();
+        if ($service === null) {
+            throw new NotFoundError(t('Service not found'));
+        }
+
+        $this->service = $service;
+        $this->loadTabsForObject($service);
+
+        $this->setTitleTab($this->getRequest()->getActionName());
+        $this->setTitle(
+            t('%s on %s', '<service> on <host>'),
+            $service->display_name,
+            $service->host->display_name
+        );
+    }
+
+    public function indexAction()
+    {
+        if ($this->service->state->is_overdue) {
+            $this->controls->addAttributes(['class' => 'overdue']);
+        }
+
+        $this->addControl((new ServiceList([$this->service]))
+            ->setViewMode('objectHeader')
+            ->setDetailActionsDisabled()
+            ->setNoSubjectLink());
+        $this->addControl(new ServiceMetaInfo($this->service));
+        $this->addControl(new QuickActions($this->service));
+
+        $this->addContent(new ServiceDetail($this->service));
+
+        $this->setAutorefreshInterval(10);
+    }
+
+    public function sourceAction()
+    {
+        $this->assertPermission('icingadb/object/show-source');
+        $apiResult = (new CommandTransport())->send((new GetObjectCommand())->setObject($this->service));
+
+        if ($this->service->state->is_overdue) {
+            $this->controls->addAttributes(['class' => 'overdue']);
+        }
+
+        $this->addControl((new ServiceList([$this->service]))
+            ->setViewMode('objectHeader')
+            ->setDetailActionsDisabled()
+            ->setNoSubjectLink());
+        $this->addContent(new ServiceInspectionDetail(
+            $this->service,
+            reset($apiResult)
+        ));
+    }
+
+    public function historyAction()
+    {
+        $compact = $this->view->compact; // TODO: Find a less-legacy way..
+
+        if ($this->service->state->is_overdue) {
+            $this->controls->addAttributes(['class' => 'overdue']);
+        }
+
+        $db = $this->getDb();
+
+        $history = History::on($db)->with([
+            'host',
+            'host.state',
+            'service',
+            'service.state',
+            'comment',
+            'downtime',
+            'flapping',
+            'notification',
+            'acknowledgement',
+            'state'
+        ]);
+        $history->filter(Filter::all(
+            Filter::equal('history.host_id', $this->service->host_id),
+            Filter::equal('history.service_id', $this->service->id)
+        ));
+
+        $before = $this->params->shift('before', time());
+        $url = Url::fromRequest()->setParams(clone $this->params);
+
+        $limitControl = $this->createLimitControl();
+        $paginationControl = $this->createPaginationControl($history);
+        $sortControl = $this->createSortControl(
+            $history,
+            [
+                'history.event_time desc' => t('Event Time')
+            ]
+        );
+        $viewModeSwitcher = $this->createViewModeSwitcher($paginationControl, $limitControl, true);
+
+        $history->peekAhead();
+
+        $page = $paginationControl->getCurrentPageNumber();
+
+        if ($page > 1 && ! $compact) {
+            $history->limit($page * $limitControl->getLimit());
+        }
+
+        $history->filter(Filter::lessThanOrEqual('event_time', $before));
+
+        yield $this->export($history);
+
+        $this->addControl((new ServiceList([$this->service]))
+            ->setViewMode('objectHeader')
+            ->setDetailActionsDisabled()
+            ->setNoSubjectLink());
+        $this->addControl($sortControl);
+        $this->addControl($limitControl);
+        $this->addControl($viewModeSwitcher);
+
+        $historyList = (new HistoryList($history->execute()))
+            ->setViewMode($viewModeSwitcher->getViewMode())
+            ->setPageSize($limitControl->getLimit())
+            ->setLoadMoreUrl($url->setParam('before', $before));
+
+        if ($compact) {
+            $historyList->setPageNumber($page);
+        }
+
+        if ($compact && $page > 1) {
+            $this->document->addFrom($historyList);
+        } else {
+            $this->addContent($historyList);
+        }
+    }
+
+    protected function createTabs()
+    {
+        $tabs = $this->getTabs()
+            ->add('index', [
+                'label'  => t('Service'),
+                'url'    => Links::service($this->service, $this->service->host)
+            ])
+            ->add('history', [
+                'label'  => t('History'),
+                'url'    => ServiceLinks::history($this->service, $this->service->host)
+            ]);
+
+        if ($this->hasPermission('icingadb/object/show-source')) {
+            $tabs->add('source', [
+                'label' => t('Source'),
+                'url'   => Links::serviceSource($this->service, $this->service->host)
+            ]);
+        }
+
+        foreach ($this->loadAdditionalTabs() as $name => $tab) {
+            $tabs->add($name, $tab + ['urlParams' => [
+                'name'      => $this->service->name,
+                'host.name' => $this->service->host->name
+            ]]);
+        }
+
+        return $tabs;
+    }
+
+    protected function setTitleTab(string $name)
+    {
+        $tab = $this->createTabs()->get($name);
+
+        if ($tab !== null) {
+            $tab->setActive();
+
+            $this->setTitle($tab->getLabel());
+        }
+    }
+
+    protected function fetchCommandTargets(): array
+    {
+        return [$this->service];
+    }
+
+    protected function getCommandTargetsUrl(): Url
+    {
+        return Links::service($this->service, $this->service->host);
+    }
+
+    protected function getDefaultTabControls(): array
+    {
+        return [(new ServiceList([$this->service]))->setDetailActionsDisabled()->setNoSubjectLink()];
+    }
+}