From c7aff14f15d7ea8d08e554ed9cd0b8f33e17dda6 Mon Sep 17 00:00:00 2001
From: tracer <tracer@24unix.net>
Date: Mon, 31 Jan 2022 21:06:44 +0100
Subject: [PATCH] initial commit

Signed-off-by: tracer <tracer@24unix.net>
---
 src/Repository/NameserverRepository.php | 227 ++++++++++++++++++++++++
 1 file changed, 227 insertions(+)
 create mode 100644 src/Repository/NameserverRepository.php

diff --git a/src/Repository/NameserverRepository.php b/src/Repository/NameserverRepository.php
new file mode 100644
index 0000000..152375a
--- /dev/null
+++ b/src/Repository/NameserverRepository.php
@@ -0,0 +1,227 @@
+<?php
+
+namespace App\Repository;
+
+use App\Controller\DatabaseConnection;
+use App\Entity\Nameserver;
+use PDO;
+use PDOException;
+
+/**
+ *
+ */
+class NameserverRepository
+{
+	public function __construct(private DatabaseConnection $databaseConnection)
+	{}
+	
+	
+	/**
+	 * @return array
+	 */
+	public function findAll(): array
+	{
+		$nameservers = [];
+		$sql = "
+            SELECT id, name, a, aaaa, apikey
+            FROM " . DatabaseConnection::TABLE_NAMESERVERS . "
+            ORDER BY name";
+		
+		try {
+			$statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+			$statement->execute();
+			while ($result = $statement->fetch(mode: PDO::FETCH_ASSOC)) {
+				$nameserver = new Nameserver(name: $result['name'], id: $result['id'], a: $result['a'], aaaa: $result['aaaa'], apikey: $result['apikey']);
+				$nameservers[] = $nameserver;
+			}
+			return $nameservers;
+		} catch (PDOException $e) {
+			exit($e->getMessage());
+		}
+	}
+	
+	
+	/**
+	 * @param int $id
+	 *
+	 * @return \App\Entity\Nameserver
+	 */
+	public function findByID(int $id): Nameserver
+	{
+		$sql = "
+			SELECT id, name, a, aaaa, apikey
+			FROM . " . DatabaseConnection::TABLE_NAMESERVERS . "
+            WHERE id = :id";
+		
+		try {
+			$statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+			$statement->bindParam(param: ':id', var: $id);
+			$statement->execute();
+			$result = $statement->fetch(mode: PDO::FETCH_ASSOC);
+			return new Nameserver(name: $result['name'], a: $result['a'], aaaa: $result['aaaa'], apikey: $result['apikey']);
+		} catch (PDOException $e) {
+			exit($e->getMessage());
+		}
+	}
+	
+	
+	/**
+	 * @param String $name
+	 *
+	 * @return \App\Entity\Nameserver|bool
+	 */
+	public function findByName(string $name): Nameserver|bool
+	{
+		$sql = "
+			SELECT id, name, a, aaaa, apikey
+			FROM " . DatabaseConnection::TABLE_NAMESERVERS . "
+            WHERE name = :name";
+		
+		try {
+			$statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+			$statement->bindParam(param: ':name', var: $name);
+			$statement->execute();
+			if ($result = $statement->fetch(mode: PDO::FETCH_ASSOC)) {
+				return new Nameserver(name: $result['name'], a: $result['a'], aaaa: $result['aaaa']);
+			} else {
+				return false;
+			}
+		} catch (PDOException $e) {
+			exit($e->getMessage());
+		}
+	}
+	
+	
+	/**
+	 * @param String $name
+	 * @param String $a
+	 * @param String $aaaa
+	 * @param String $apikey
+	 *
+	 * @return string|false
+	 */
+	public function insert(string $name, string $a, string $aaaa, String $apikey): bool|string
+	{
+		$sql = "
+            INSERT INTO " . DatabaseConnection::TABLE_NAMESERVERS . " (name, a, aaaa, apikey)
+            VALUES (:name, :a, :aaaa, :apikey)";
+		
+		try {
+			$statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+			$statement->bindParam(param: ':name', var: $name);
+			$statement->bindParam(param: ':a', var: $a);
+			$statement->bindParam(param: ':aaaa', var: $aaaa);
+			$statement->bindParam(param: ':apikey', var: $apikey);
+			$statement->execute();
+			
+			return $this->databaseConnection->getConnection()->lastInsertId();
+		} catch (PDOException $e) {
+			exit($e->getMessage());
+		}
+	}
+	
+	
+	/**
+	 * @param Int    $id
+	 * @param String $name
+	 * @param String $a
+	 * @param String $aaaa
+	 * @param String $apikey
+	 *
+	 * @return false|int
+	 */
+	public function update(int $id, string $name, string $a, string $aaaa, String $apikey): bool|int
+	{
+		$current = $this->findByID(id: $id);
+		
+		/* doesn't work
+		$statement = "
+            INSERT INTO domains(id, name, a, aaaa)
+            VALUES(:id, :name, :a, :aaaa)
+            ON DUPLICATE KEY UPDATE
+            	name=COALESCE(VALUES(name), :name),
+				a=COALESCE(:a, a),
+            	aaaa=COALESCE(:aaaa, aaaa)";
+		*/
+		
+		if (empty($name)) {
+			$name = $current->getName();
+		}
+		if (empty($a)) {
+			$a = $current->getA();
+		}
+		if (empty($aaaa)) {
+			$aaaa = $current->getAaaa();
+		}
+		if (empty($apikey)) {
+			$apikey = $current->getApikey();
+		}
+		
+		$sql = "
+			UPDATE " . DatabaseConnection::TABLE_NAMESERVERS . " SET
+				name = :name,
+				a = :a,
+               	aaaa = :aaaa,
+               	apikey = :apikey
+            WHERE id = :id";
+		
+		try {
+			$statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+			$statement->bindParam(param: 'id', var: $id);
+			$statement->bindParam(param: 'name', var: $name);
+			$statement->bindParam(param: 'a', var: $a);
+			$statement->bindParam(param: 'aaaa', var: $aaaa);
+			$statement->bindParam(param: 'apikey', var: $apikey);
+			$statement->execute();
+			
+			return $statement->rowCount();
+		} catch (PDOException $e) {
+			print($e->getMessage());
+			return false;
+		}
+	}
+	
+	
+	/**
+	 * @param $id
+	 *
+	 * @return int
+	 */
+	public function delete($id): int
+	{
+		$sql = "
+            DELETE FROM " . DatabaseConnection::TABLE_NAMESERVERS . "
+            WHERE id = :id";
+		
+		try {
+			$statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+			$statement->bindParam(param: 'id', var: $id);
+			$statement->execute();
+			
+			return $statement->rowCount();
+		} catch (PDOException $e) {
+			exit($e->getMessage());
+		}
+	}
+	
+	
+	/**
+	 * @param String $field
+	 *
+	 * @return int
+	 */
+	public function getLongestEntry(String $field): int
+	{
+		$sql = "
+            SELECT MAX(LENGTH(" . $field . ")) as length FROM " . DatabaseConnection::TABLE_NAMESERVERS;
+		
+		try {
+			$statement = $this->databaseConnection->getConnection()->prepare(query: $sql);
+			$statement->execute();
+			$result =  $statement->fetch();
+			return $result['length'];
+		} catch (PDOException $e) {
+			exit($e->getMessage());
+		}
+	}
+}
\ No newline at end of file