удалили компосер лок

.gitignore

@@ -1 +1,3 @@
 vendor
+composer.lock
+!.gitignore

LICENSE

@@ -0,0 +1,11 @@
+DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE
+Version 2, December 2004
+
+Copyright (C) 2004 Sam Hocevar <sam@hocevar.net>
+
+Everyone is permitted to copy and distribute verbatim or modified copies of this license document, and changing it is allowed as long as the name is changed.
+
+DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE
+TERMS AND CONDITIONS FOR COPYING, DISTRIBUTION AND MODIFICATION
+
+  0. You just DO WHAT THE FUCK YOU WANT TO.

README.md

@@ -0,0 +1,3 @@
+# PHP 8.2 Framework for working with ArangoDB
+
+🤟 Very simple and flexible, easy to scale and integrate

composer.json

@@ -1,35 +1,47 @@
-{
+{
-    "name": "mirzaev/arangodb",
+    "name": "mirzaev/arangodb",
-    "description": "Реализация управления хранилищем данных ArangoDB",
+    "description": "Simple PHP-framework for ArangoDB",
-    "keywords": [
+    "readme": "README.md",
-        "ArangoDB"
+    "keywords": [
-    ],
+        "ArangoDB"
-    "type": "library",
+    ],
-    "license": "WTFPL",
+    "type": "library",
-    "homepage": "https://git.hood.su/mirzaev/arangodb",
+    "license": "WTFPL",
-    "authors": [
+    "homepage": "https://git.hood.su/mirzaev/arangodb",
-        {
+    "authors": [
-            "name": "Arsen Mirzaev Tatyano-Muradovich",
+        {
-            "email": "arsen@mirzaev.sexy",
+            "name": "Arsen Mirzaev Tatyano-Muradovich",
-            "homepage": "https://mirzaev.sexy",
+            "email": "arsen@mirzaev.sexy",
-            "role": "Developer"
+            "homepage": "https://mirzaev.sexy",
-        }
+            "role": "Developer"
-    ],
+        }
-    "require": {
+    ],
-        "php": "^8.0.0",
+    "support": {
-        "triagens/arangodb": "~3.2"
+        "email": "arsen@mirzaev.sexy",
-    },
+        "wiki": "https://git.mirzaev.sexy/mirzaev/arangodb/manual",
-    "require-dev": {
+        "issues": "https://git.mirzaev.sexy/mirzaev/arangodb/issues"
-        "phpunit/phpunit": "^9.3.3"
+    },
-    },
+    "funding": [
-    "autoload": {
+        {
-        "psr-4": {
+            "type": "funding",
-            "mirzaev\\arangodb\\": "mirzaev/arangodb/system"
+            "url": "https://fund.mirzaev.sexy"
-        }
+        }
-    },
+    ],
-    "autoload-dev": {
+    "require": {
-        "psr-4": {
+        "php": "^8.2",
-            "mirzaev\\arangodb\\tests\\": "mirzaev/arangodb/tests"
+        "triagens/arangodb": "~3.8"
-        }
+    },
-    }
+    "require-dev": {
-}
+        "phpunit/phpunit": "^9.3.3"
+    },
+    "autoload": {
+        "psr-4": {
+            "mirzaev\\arangodb\\": "mirzaev/arangodb/system"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "mirzaev\\arangodb\\tests\\": "mirzaev/arangodb/tests"
+        }
+    }
+}

mirzaev/arangodb/system/collection.php

@@ -1,83 +1,125 @@
-<?php
+<?php
-
+
-declare(strict_types=1);
+declare(strict_types=1);
-
+
-namespace mirzaev\arangodb;
+namespace mirzaev\arangodb;
-
+
-use mirzaev\arangodb\terminal;
+use mirzaev\arangodb\terminal;
-
+
-use ArangoDBClient\Connection as _connection;
+use ArangoDBClient\Connection as _connection;
-use ArangoDBClient\Collection as _collection;
+use ArangoDBClient\Collection as _collection;
-use ArangoDBClient\CollectionHandler as _collection_handler;
+use ArangoDBClient\Statement as _statement;
-
+use ArangoDBClient\Document as _document;
-/**
+use ArangoDBClient\CollectionHandler as _collection_handler;
- * Коллекция
+
- *
+/**
- * @package mirzaev\arangodb
+ * Коллекция
- * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
+ *
- */
+ * @package mirzaev\arangodb
-class collection
+ * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
-{
+ */
-    /**
+class collection
-     * Инициализация
+{
-     *
+	/**
-     * @param _connection $connection Инстанция соединения
+	 * Инициализация
-     * @param string $name Название
+	 *
-     * @param bool $edge Это ребро? (иначе: вершина)
+	 * @param _connection $session Сессия соединения с базой данных
-     *
+	 * @param string $name Название
-     * @return string|null Идентификатор
+	 * @param bool $edge Обрабатывать как ребро? (иначе: вершина)
-     */
+	 * @param ?terminal $terminal Инстанция терминала
-    public static function init(_connection $connection, string $name, bool $edge = false): ?string
+	 *
-    {
+	 * @return string|null Идентификатор коллекции
-        // Инициализация
+	 */
-        $collections = new _collection_handler($connection);
+	public static function init(_connection $session, string $name, bool $edge = false, ?terminal $terminal = null): ?string
-
+	{
-        if (!$collections->has($name)) {
+		// Инициализация
-            // Коллекция не найдена
+		$collections = new _collection_handler($session);
-
+
-            // Запись в вывод
+		if (!$collections->has($name)) {
-            terminal::write("Коллекция \"$name\" не найдена");
+			// Не найдана коллекция
-
+
-            // Инициализация
+			// Запись в вывод
-            $collection = new _collection();
+			if ($terminal instanceof terminal) $terminal::write("Коллекция \"$name\" не найдена");
-
+
-            // Настройка
+			// Запись коллекции на сервер и его ответ в буфер возврата
-            $collection->setName($name);
+			$id = $collections->create($name, ['type' => $edge ? _collection::TYPE_EDGE : _collection::TYPE_DOCUMENT]);
-            $collection->setType($edge ? 'edge' : 'document');
+
-
+			if ($collections->has($name)) {
-            // Запись коллекции на сервер и его ответ в буфер возврата
+				// Коллекция найдена (записана)
-            $id = $collections->create($name);
+
-
+				// Запись в вывод
-            if ($collections->has($name)) {
+				if ($terminal instanceof terminal) $terminal::write("Создана коллекция \"$name\" с типом " . ($edge ? 'ребро' : 'документ'));
-                // Коллекция найдена (записана)
+
-
+				// Возврат идентификатора коллекции
-                // Запись в вывод
+				return $id;
-                terminal::write("Создана коллекция \"$name\"");
+			}
-
+		} else {
-                // Возврат идентификатора коллекции
+			// Найдена коллекция
-                return $id;
+
-            }
+			// Возврат идентификатора коллекции
-        }
+			return $name;
-    }
+		}
-
+
-    /**
+		return null;
-     * Поиск
+	}
-     *
+
-     * @param _connection $connection Соединение
+	/**
-     * @param string $collection Название
+	 * Поиск
-     * @param array $condition Условия
+	 *
-     *
+	 * @param _connection $session Сессия соединения с базой данных
-     * @return array|null Коллекция, если найдена
+	 * @param string $query AQL-запрос
-     */
+	 * @param array $binds Binds for query [bind => value]
-    public static function search(_connection $connection, string $name, array $condition): ?array
+	 *
-    {
+	 * @return _document|array|string|int|null Инстанция документа
-        // Инициализация
+	 */
-        $collections = new _collection_handler($connection);
+	public static function search(_connection $session, string $query, array $binds = []): _document|string|array|int|null
-
+	{
-        if ($collections->has($name)) {
+		// Statement instance initialization
-            // Коллекция найдена
+		$instance = new _statement(
-
+			$session,
-            return $collections->byExample($name, $condition)->getAll();
+			[
-        }
+				'query' => $query,
-    }
+				"batchSize" => 1000,
-}
+				"sanitize"  => true
+			]
+		);
+
+		// Binds application
+		$instance->bind($binds);
+
+		// Sending the request
+		$response = $instance->execute();
+
+		// Инициализация буфера вывода
+		$buffer = [];
+
+		foreach ($response->getAll() as $key => $value) {
+			$buffer[$key] = $value;
+		}
+
+		return is_array($buffer) && count($buffer) > 1 ? $buffer : $buffer[0] ?? null;
+	}
+
+	/**
+	 * Очистка
+	 *
+	 * @param _connection $session Сессия соединения с базой данных
+	 * @param string $name Название
+	 *
+	 * @return bool Статус выполнения
+	 */
+	public static function truncate(_connection $session, string $name): bool
+	{
+		// Инициализация
+		$collections = new _collection_handler($session);
+
+		if ($collections->has($name)) {
+			// Найдена коллекция
+
+			// Очистка
+			return $collections->truncate($name);
+		}
+
+		return false;
+	}
+}

mirzaev/arangodb/system/connection.php

@@ -138,15 +138,16 @@ final class connection
         match ($name) {
             'adress', 'endpoint' => $this->adress = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
             'storage', 'database', 'db' => $this->storage = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
-            'auth' => $this->auth = $value,
+            'auth' => !$value ?: $this->auth = $value,
-            'name' => $this->name = $value,
+            'name' => !$value ?: $this->name = $value,
-            'password' => $this->password = $value,
+            'password' => !$value ?: $this->password = $value,
-            'connection' => $this->connection = $value,
+            'connection' => !$value ?: $this->connection = $value,
-            'timeout_connect' => $this->timeout_connect = $value,
+            'timeout_connect' => !$value ?: $this->timeout_connect = $value,
-            'timeout_request' => $this->timeout_request = $value,
+            'timeout_request' => !$value ?: $this->timeout_request = $value,
-            'reconnect' => $this->reconnect = $value,
+            'reconnect' => !$value ?: $this->reconnect = $value,
-            'create' => $this->create = $value,
+            'create' => !$value ?: $this->create = $value,
-            'update', 'policy' => $this->update = $value,
+            'update', 'policy' => !$value ?: $this->update = $value,
+            'journal' => !$value ?: $this->journal = $value,
             default => throw new exception("Свойство \"$name\" не найдено", 404)
         };
     }
@@ -171,6 +172,7 @@ final class connection
             'create' => $this->create,
             'update', 'policy' => $this->update,
             'session' => $this->session,
+            'journal' => $this->journal,
             default => throw new exception("Свойство \"$name\" не найдено", 404)
         };
     }
@@ -195,6 +197,7 @@ final class connection
             'create' => isset($this->create),
             'update', 'policy' => isset($this->update),
             'session' => isset($this->session),
+            'journal' => isset($this->journal),
             default => throw new exception("Свойство \"$name\" не найдено", 404)
         };
     }

mirzaev/arangodb/system/document.php

@@ -1,82 +1,114 @@
-<?php
+<?php
-
+
-declare(strict_types=1);
+declare(strict_types=1);
-
+
-namespace mirzaev\arangodb;
+namespace mirzaev\arangodb;
-
+
-use mirzaev\arangodb\terminal;
+use mirzaev\arangodb\terminal;
-
+
-use ArangoDBClient\Connection as _connection;
+use ArangoDBClient\Connection as _connection;
-use ArangoDBClient\Document as _document;
+use ArangoDBClient\Document as _document;
-use ArangoDBClient\Edge as _edge;
+use ArangoDBClient\Edge as _edge;
-use ArangoDBClient\CollectionHandler as _collection_handler;
+use ArangoDBClient\DocumentHandler as _document_handler;
-use ArangoDBClient\EdgeHandler as _edge_handler;
+use ArangoDBClient\EdgeHandler as _edge_handler;
-
+
-/**
+/**
- * Документ
+ * Документ
- *
+ *
- * @package mirzaev\arangodb
+ * @package mirzaev\arangodb
- * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
+ * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
- */
+ */
-class document
+class document
-{
+{
-    /**
+	/**
-     * Записать
+	 * Записать
-     *
+	 *
-     * @param _connection $connection Инстанция соединения
+	 * @param _connection $session Сессия соединения с базой данных
-     * @param string $collection Коллекция
+	 * @param string $collection Коллекция
-     * @param array $data Данные
+	 * @param ?array $data Данные
-     *
+	 * @param bool $check Проверка на запись в базу данных
-     * @return string|null Идентификатор
+	 * @param ?terminal $terminal Инстанция терминала
-     */
+	 *
-    public static function write(_connection $connection, string $collection, array $data): ?string
+	 * @return string|null Идентификатор
-    {
+	 */
-        // Инициализация коллекции
+	public static function write(_connection $session, string $collection, ?array $data = [], bool $check = false, ?terminal $terminal = null): ?string
-        collection::init($connection, $collection, isset($data['_from'], $data['_to']));
+	{
-
+		// Инициализация коллекции
-        if (isset($data['_from'], $data['_to'])) {
+		collection::init($session, $collection, isset($data['_from'], $data['_to']));
-            // Ребро
+
-
+		if (isset($data['_from'], $data['_to'])) {
-            // Инициализация обработчика рёбер
+			// Ребро
-            $documents = new _edge_handler($connection);
+
-
+			// Инициализация обработчика рёбер
-            // Инициализация ребра
+			$documents = new _edge_handler($session);
-            $document = new _edge();
+
-
+			// Инициализация ребра
-            // Инициализация вершин
+			$document = new _edge();
-            $_from = $data['_from'];
+
-            $_to = $data['_to'];
+			// Инициализация вершин
-
+			$_from = $data['_from'];
-            // Деинициализация из входных данных
+			$_to = $data['_to'];
-            unset($data['_from'], $data['_to']);
+
-        } else {
+			// Деинициализация из входных данных
-            // Вершина
+			unset($data['_from'], $data['_to']);
-
+		} else {
-            // Инициализация обработчика вершин
+			// Вершина
-            $documents = new _collection_handler($connection);
+
-
+			// Инициализация обработчика вершин
-            // Инициализация вершины
+			$documents = new _document_handler($session);
-            $document = new _document();
+
-        }
+			// Инициализация вершины
-
+			$document = new _document();
-        // Настройка
+		}
-        foreach ($data as $key => $value) {
+
-            // Перебор параметров
+		// Инициализация даты создания
-
+		$created = time();
-            $document->set($key, $value);
+
-        }
+		foreach (['created' => $created, 'updated' => $created] + $data as $key => $value) {
-
+			// Перебор параметров
-        // Запись на сервер и его ответ в буфер возврата
+
-        $id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->save($collection, $document);
+			// Запись в инстанцию документа
-
+			$document->set($key, $value);
-        if ($documents->has($collection, $id)) {
+		}
-            // Документ записан
+
-
+		// Запись на сервер и его ответ в буфер возврата
-            // Запись в вывод
+		$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->insert($collection, $document);
-            terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
+
-
+		if ($check && $documents->has($collection, $id)) {
-            // Возврат идентификатора коллекции
+			// Найден записанный документ
-            return $id;
+
-        }
+			// Запись в вывод
-    }
+			if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
-}
+		} else if ($check) {
+			// Не найден записанный документ
+
+			// Запись в вывод
+			if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" не удалось найти созданный или создать документ");
+
+			return null;
+		}
+
+		// Возврат идентификатора коллекции
+		return $id;
+	}
+
+	/**
+	 * Обновить
+	 *
+	 * @param _connection $session Сессия соединения с базой данных
+	 * @param _document $document Инстанция документа вершины
+	 *
+	 * @return bool Статус обработки
+	 */
+	public static function update(_connection $session, _document $document): bool
+	{
+		// Инициализация обработчика вершин
+		$documents = new _document_handler($session);
+
+		// Запись даты обновления в инстанцию документа
+		$document->set('updated', time());
+
+		// Запись в базу данных
+		return $documents->update($document);
+	}
+}

mirzaev/arangodb/system/terminal.php

@@ -1,31 +1,23 @@
-<?php
+<?php
-
+
-declare(strict_types=1);
+declare(strict_types=1);
-
+
-namespace mirzaev\arangodb;
+namespace mirzaev\arangodb;
-
+
-class terminal
+class terminal
-{
+{
-    /**
+    /**
-     * Префикс
+     * Префикс
-     */
+     */
-    protected const PREFIX = 'arangodb';
+    protected const PREFIX = 'arangodb';
-
+
-    /**
+    /**
-     * Запись в вывод
+     * Запись в вывод
-     *
+     *
-     * @param string $text Текст сообщения
+     * @param string $text Текст сообщения
-     */
+     */
-    public static function write(string $text): void
+    public static function write(string $text): void
-    {
+    {
-        echo self::generate_prefix() . ' ' . $text . PHP_EOL;
+        echo sprintf("[%s] $text\n", self::PREFIX);
-    }
+    }
-
+}
-    /**
-     * Генерация префикса
-     */
-    public static function generate_prefix(): string
-    {
-        return '[' . self::PREFIX . ']';
-    }
-}