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

.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,6 +1,7 @@
 {
     "name": "mirzaev/arangodb",
-    "description": "Реализация управления хранилищем данных ArangoDB",
+    "description": "Simple PHP-framework for ArangoDB",
+    "readme": "README.md",
     "keywords": [
         "ArangoDB"
     ],
@@ -15,9 +16,20 @@
             "role": "Developer"
         }
     ],
+    "support": {
+        "email": "arsen@mirzaev.sexy",
+        "wiki": "https://git.mirzaev.sexy/mirzaev/arangodb/manual",
+        "issues": "https://git.mirzaev.sexy/mirzaev/arangodb/issues"
+    },
+    "funding": [
+        {
+            "type": "funding",
+            "url": "https://fund.mirzaev.sexy"
+        }
+    ],
     "require": {
-        "php": "^8.0.0",
-        "triagens/arangodb": "~3.2"
+        "php": "^8.2",
+        "triagens/arangodb": "~3.8"
     },
     "require-dev": {
         "phpunit/phpunit": "^9.3.3"

mirzaev/arangodb/system/collection.php

@@ -8,6 +8,8 @@ use mirzaev\arangodb\terminal;
 
 use ArangoDBClient\Connection as _connection;
 use ArangoDBClient\Collection as _collection;
+use ArangoDBClient\Statement as _statement;
+use ArangoDBClient\Document as _document;
 use ArangoDBClient\CollectionHandler as _collection_handler;
 
 /**
@@ -18,66 +20,106 @@ use ArangoDBClient\CollectionHandler as _collection_handler;
  */
 class collection
 {
-    /**
-     * Инициализация
-     *
-     * @param _connection $connection Инстанция соединения
-     * @param string $name Название
-     * @param bool $edge Это ребро? (иначе: вершина)
-     *
-     * @return string|null Идентификатор
-     */
-    public static function init(_connection $connection, string $name, bool $edge = false): ?string
-    {
-        // Инициализация
-        $collections = new _collection_handler($connection);
+	/**
+	 * Инициализация
+	 *
+	 * @param _connection $session Сессия соединения с базой данных
+	 * @param string $name Название
+	 * @param bool $edge Обрабатывать как ребро? (иначе: вершина)
+	 * @param ?terminal $terminal Инстанция терминала
+	 *
+	 * @return string|null Идентификатор коллекции
+	 */
+	public static function init(_connection $session, string $name, bool $edge = false, ?terminal $terminal = null): ?string
+	{
+		// Инициализация
+		$collections = new _collection_handler($session);
 
-        if (!$collections->has($name)) {
-            // Коллекция не найдена
+		if (!$collections->has($name)) {
+			// Не найдана коллекция
 
-            // Запись в вывод
-            terminal::write("Коллекция \"$name\" не найдена");
+			// Запись в вывод
+			if ($terminal instanceof terminal) $terminal::write("Коллекция \"$name\" не найдена");
 
-            // Инициализация
-            $collection = new _collection();
+			// Запись коллекции на сервер и его ответ в буфер возврата
+			$id = $collections->create($name, ['type' => $edge ? _collection::TYPE_EDGE : _collection::TYPE_DOCUMENT]);
 
-            // Настройка
-            $collection->setName($name);
-            $collection->setType($edge ? 'edge' : 'document');
+			if ($collections->has($name)) {
+				// Коллекция найдена (записана)
 
-            // Запись коллекции на сервер и его ответ в буфер возврата
-            $id = $collections->create($name);
+				// Запись в вывод
+				if ($terminal instanceof terminal) $terminal::write("Создана коллекция \"$name\" с типом " . ($edge ? 'ребро' : 'документ'));
 
-            if ($collections->has($name)) {
-                // Коллекция найдена (записана)
+				// Возврат идентификатора коллекции
+				return $id;
+			}
+		} else {
+			// Найдена коллекция
 
-                // Запись в вывод
-                terminal::write("Создана коллекция \"$name\"");
+			// Возврат идентификатора коллекции
+			return $name;
+		}
 
-                // Возврат идентификатора коллекции
-                return $id;
-            }
-        }
-    }
+		return null;
+	}
 
-    /**
-     * Поиск
-     *
-     * @param _connection $connection Соединение
-     * @param string $collection Название
-     * @param array $condition Условия
-     *
-     * @return array|null Коллекция, если найдена
-     */
-    public static function search(_connection $connection, string $name, array $condition): ?array
-    {
-        // Инициализация
-        $collections = new _collection_handler($connection);
+	/**
+	 * Поиск
+	 *
+	 * @param _connection $session Сессия соединения с базой данных
+	 * @param string $query AQL-запрос
+	 * @param array $binds Binds for query [bind => value]
+	 *
+	 * @return _document|array|string|int|null Инстанция документа
+	 */
+	public static function search(_connection $session, string $query, array $binds = []): _document|string|array|int|null
+	{
+		// Statement instance initialization
+		$instance = new _statement(
+			$session,
+			[
+				'query' => $query,
+				"batchSize" => 1000,
+				"sanitize"  => true
+			]
+		);
 
-        if ($collections->has($name)) {
-            // Коллекция найдена
+		// Binds application
+		$instance->bind($binds);
 
-            return $collections->byExample($name, $condition)->getAll();
-        }
-    }
+		// 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,
-            'name' => $this->name = $value,
-            'password' => $this->password = $value,
-            'connection' => $this->connection = $value,
-            'timeout_connect' => $this->timeout_connect = $value,
-            'timeout_request' => $this->timeout_request = $value,
-            'reconnect' => $this->reconnect = $value,
-            'create' => $this->create = $value,
-            'update', 'policy' => $this->update = $value,
+            'auth' => !$value ?: $this->auth = $value,
+            'name' => !$value ?: $this->name = $value,
+            'password' => !$value ?: $this->password = $value,
+            'connection' => !$value ?: $this->connection = $value,
+            'timeout_connect' => !$value ?: $this->timeout_connect = $value,
+            'timeout_request' => !$value ?: $this->timeout_request = $value,
+            'reconnect' => !$value ?: $this->reconnect = $value,
+            'create' => !$value ?: $this->create = $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

@@ -9,7 +9,7 @@ use mirzaev\arangodb\terminal;
 use ArangoDBClient\Connection as _connection;
 use ArangoDBClient\Document as _document;
 use ArangoDBClient\Edge as _edge;
-use ArangoDBClient\CollectionHandler as _collection_handler;
+use ArangoDBClient\DocumentHandler as _document_handler;
 use ArangoDBClient\EdgeHandler as _edge_handler;
 
 /**
@@ -20,63 +20,95 @@ use ArangoDBClient\EdgeHandler as _edge_handler;
  */
 class document
 {
-    /**
-     * Записать
-     *
-     * @param _connection $connection Инстанция соединения
-     * @param string $collection Коллекция
-     * @param array $data Данные
-     *
-     * @return string|null Идентификатор
-     */
-    public static function write(_connection $connection, string $collection, array $data): ?string
-    {
-        // Инициализация коллекции
-        collection::init($connection, $collection, isset($data['_from'], $data['_to']));
+	/**
+	 * Записать
+	 *
+	 * @param _connection $session Сессия соединения с базой данных
+	 * @param string $collection Коллекция
+	 * @param ?array $data Данные
+	 * @param bool $check Проверка на запись в базу данных
+	 * @param ?terminal $terminal Инстанция терминала
+	 *
+	 * @return string|null Идентификатор
+	 */
+	public static function write(_connection $session, string $collection, ?array $data = [], bool $check = false, ?terminal $terminal = null): ?string
+	{
+		// Инициализация коллекции
+		collection::init($session, $collection, isset($data['_from'], $data['_to']));
 
-        if (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

@@ -18,14 +18,6 @@ class terminal
      */
     public static function write(string $text): void
     {
-        echo self::generate_prefix() . ' ' . $text . PHP_EOL;
-    }
-
-    /**
-     * Генерация префикса
-     */
-    public static function generate_prefix(): string
-    {
-        return '[' . self::PREFIX . ']';
+        echo sprintf("[%s] $text\n", self::PREFIX);
     }
 }