1 files changed, 116 insertions, 0 deletions
diff --git a/library/Director/Web/Table/BranchActivityTable.php b/library/Director/Web/Table/BranchActivityTable.php
new file mode 100644
index 0000000..e7131ef
--- /dev/null
+++ b/library/Director/Web/Table/BranchActivityTable.php
@@ -0,0 +1,116 @@
+<?php
+
+namespace Icinga\Module\Director\Web\Table;
+
+use gipfl\Format\LocalTimeFormat;
+use Icinga\Module\Director\Db;
+use Icinga\Module\Director\Db\Branch\BranchActivity;
+use Icinga\Module\Director\Util;
+use gipfl\IcingaWeb2\Link;
+use gipfl\IcingaWeb2\Table\ZfQueryBasedTable;
+use Ramsey\Uuid\UuidInterface;
+
+class BranchActivityTable extends ZfQueryBasedTable
+{
+    protected $extraParams = [];
+
+    /** @var UuidInterface */
+    protected $branchUuid;
+
+    /** @var ?UuidInterface */
+    protected $objectUuid;
+
+    /** @var LocalTimeFormat */
+    protected $timeFormat;
+
+    protected $linkToObject = true;
+
+    public function __construct(UuidInterface $branchUuid, $db, UuidInterface $objectUuid = null)
+    {
+        $this->branchUuid = $branchUuid;
+        $this->objectUuid = $objectUuid;
+        $this->timeFormat = new LocalTimeFormat();
+        parent::__construct($db);
+    }
+
+    public function assemble()
+    {
+        $this->getAttributes()->add('class', 'activity-log');
+    }
+
+    public function renderRow($row)
+    {
+        $ts = (int) floor(BranchActivity::fixFakeTimestamp($row->timestamp_ns) / 1000000);
+        $this->splitByDay($ts);
+        $activity = BranchActivity::fromDbRow($row);
+        return $this::tr([
+            $this::td($this->makeBranchLink($activity))->setSeparator(' '),
+            $this::td($this->timeFormat->getTime($ts))
+        ])->addAttributes(['class' => ['action-' . $activity->getAction(), 'branched']]);
+    }
+
+    public function disableObjectLink()
+    {
+        $this->linkToObject = false;
+        return $this;
+    }
+
+    protected function linkObject(BranchActivity $activity)
+    {
+        if (! $this->linkToObject) {
+            return $activity->getObjectName();
+        }
+        // $type, UuidInterface $uuid
+        // Later on replacing, service_set -> serviceset
+        $type = preg_replace('/^icinga_/', '', $activity->getObjectTable());
+        return Link::create(
+            $activity->getObjectName(),
+            'director/' . str_replace('_', '', $type),
+            ['uuid' => $activity->getObjectUuid()->toString()],
+            ['title' => $this->translate('Jump to this object')]
+        );
+    }
+
+    protected function makeBranchLink(BranchActivity $activity)
+    {
+        $type = preg_replace('/^icinga_/', '', $activity->getObjectTable());
+
+        if (Util::hasPermission('director/showconfig')) {
+            // Later on replacing, service_set -> serviceset
+            return [
+                '[' . $activity->getAuthor() . ']',
+                Link::create(
+                    $activity->getAction(),
+                    'director/branch/activity',
+                    array_merge(['ts' => $activity->getTimestampNs()], $this->extraParams),
+                    ['title' => $this->translate('Show details related to this change')]
+                ),
+                str_replace('_', ' ', $type),
+                $this->linkObject($activity)
+            ];
+        } else {
+            return sprintf(
+                '[%s] %s %s "%s"',
+                $activity->getAuthor(),
+                $activity->getAction(),
+                $type,
+                $activity->getObjectName()
+            );
+        }
+    }
+
+    public function prepareQuery()
+    {
+        /** @var Db $connection */
+        $connection = $this->connection();
+        $query = $this->db()->select()->from(['ba' => 'director_branch_activity'], 'ba.*')
+            ->join(['b' => 'director_branch'], 'b.uuid = ba.branch_uuid', ['b.owner'])
+            ->where('branch_uuid = ?', $connection->quoteBinary($this->branchUuid->getBytes()))
+            ->order('timestamp_ns DESC');
+        if ($this->objectUuid) {
+            $query->where('ba.object_uuid = ?', $connection->quoteBinary($this->objectUuid->getBytes()));
+        }
+
+        return $query;
+    }
+}