commit

2026-03-02 01:45:57 +01:00
parent c92f6d7673
commit 3102790842
8 changed files with 317 additions and 85 deletions
--- a/src/Repository/KeaHostRepository.php
+++ b/src/Repository/KeaHostRepository.php
@@ -0,0 +1,104 @@
+<?php
+declare(strict_types=1);
+
+namespace App\Repository;
+
+use PDO;
+
+/**
+ * Repository für das KEA DHCP Host-Management.
+ * Interagiert direkt mit der 'hosts' Tabelle in der PostgreSQL-Datenbank.
+ */
+final class KeaHostRepository
+{
+    public function __construct(private PDO $pdo) {}
+
+    /**
+     * Ruft eine Liste aller Host-Reservierungen ab (Geräte-Inventar).
+     */
+    public function findAll(int $limit = 50): array
+    {
+        // 'dhcp_identifier' ist in KEA i.d.R. die MAC-Adresse (bei type=1)
+        $stmt = $this->pdo->prepare(
+            'SELECT host_id, dhcp_identifier, ipv4_address, hostname, user_context
+             FROM hosts
+             ORDER BY host_id DESC
+             LIMIT :limit'
+        );
+        $stmt->bindValue(':limit', $limit, PDO::PARAM_INT);
+        $stmt->execute();
+
+        return $stmt->fetchAll(PDO::FETCH_ASSOC);
+    }
+
+    /**
+     * Sucht einen Host anhand der MAC-Adresse (dhcp_identifier).
+     */
+    public function findByMac(string $mac): ?array
+    {
+        // Hinweis: KEA speichert MACs in PostgreSQL oft als BYTEA.
+        // Je nach Treiber-Konfiguration muss $mac hier ggf. als Hex-String (z.B. '\x...')
+        // formatiert übergeben werden.
+        $stmt = $this->pdo->prepare(
+            'SELECT host_id, dhcp_identifier, ipv4_address, hostname, user_context
+             FROM hosts
+             WHERE dhcp_identifier = :mac
+             LIMIT 1'
+        );
+        $stmt->execute(['mac' => $mac]);
+
+        $row = $stmt->fetch(PDO::FETCH_ASSOC);
+        return $row ?: null;
+    }
+
+    /**
+     * Erstellt eine neue Host-Reservierung inkl. Metadaten.
+     *
+     * @param string $mac MAC-Adresse
+     * @param string $ip IPv4-Adresse
+     * @param int $subnetId Die ID des Subnets (dhcp4_subnet_id), in dem die IP liegt
+     * @param string|null $hostname Optionaler Hostname
+     * @param array $metadata Zusätzliche Infos (Standort, Verantwortlicher etc.) für 'user_context'
+     */
+    public function create(string $mac, string $ip, int $subnetId, ?string $hostname = null, array $metadata = []): int
+    {
+        // Metadaten werden im KEA-Standardfeld 'user_context' als JSON gespeichert
+        $userContextJson = json_encode($metadata, JSON_THROW_ON_ERROR);
+
+        // dhcp_identifier_type 1 = HW_ADDRESS (Ethernet)
+        $stmt = $this->pdo->prepare(
+            'INSERT INTO hosts (dhcp_identifier, dhcp_identifier_type, dhcp4_subnet_id, ipv4_address, hostname, user_context)
+             VALUES (:mac, 1, :subnetId, :ip, :hostname, :user_context)'
+        );
+
+        $stmt->execute([
+            'mac'          => $mac,
+            'subnetId'     => $subnetId,
+            'ip'           => $ip,
+            'hostname'     => $hostname,
+            'user_context' => $userContextJson,
+        ]);
+
+        return $this->lastInsertIdSafe();
+    }
+
+    private function driver(): string
+    {
+        return (string)$this->pdo->getAttribute(PDO::ATTR_DRIVER_NAME);
+    }
+
+    private function lastInsertIdSafe(): int
+    {
+        $driver = $this->driver();
+
+        if ($driver === 'pgsql') {
+            // KEA Standard-Sequenz für die hosts Tabelle
+            $id = $this->pdo->lastInsertId('hosts_host_id_seq');
+            if ($id !== '') {
+                return (int)$id;
+            }
+        }
+
+        return (int)$this->pdo->lastInsertId();
+    }
+}