cool patch

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.1",
+    "support": {
-        "triagens/arangodb": "~3.8"
+        "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.1",
-            "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,117 +1,118 @@
-<?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\Statement as _statement;
+use ArangoDBClient\Statement as _statement;
-use ArangoDBClient\Document as _document;
+use ArangoDBClient\Document as _document;
-use ArangoDBClient\CollectionHandler as _collection_handler;
+use ArangoDBClient\CollectionHandler as _collection_handler;
-
+
-/**
+/**
- * Коллекция
+ * Коллекция
- *
+ *
- * @package mirzaev\arangodb
+ * @package mirzaev\arangodb
- * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
+ * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
- */
+ */
-class collection
+class collection
-{
+{
-    /**
+    /**
-     * Инициализация
+     * Инициализация
-     *
+     *
-     * @param _connection $session Сессия соединения с базой данных
+     * @param _connection $session Сессия соединения с базой данных
-     * @param string $name Название
+     * @param string $name Название
-     * @param bool $edge Это ребро? (иначе: вершина)
+     * @param bool $edge Обрабатывать как ребро? (иначе: вершина)
-     *
+     * @param ?terminal $terminal Инстанция терминала
-     * @return string|null Идентификатор коллекции
+     *
-     */
+     * @return string|null Идентификатор коллекции
-    public static function init(_connection $session, string $name, bool $edge = false): ?string
+     */
-    {
+    public static function init(_connection $session, string $name, bool $edge = false, ?terminal $terminal = null): ?string
-        // Инициализация
+    {
-        $collections = new _collection_handler($session);
+        // Инициализация
-
+        $collections = new _collection_handler($session);
-        if (!$collections->has($name)) {
+
-            // Не найдана коллекция
+        if (!$collections->has($name)) {
-
+            // Не найдана коллекция
-            // Запись в вывод
+
-            terminal::write("Коллекция \"$name\" не найдена");
+            // Запись в вывод
-
+            if ($terminal instanceof terminal) $terminal::write("Коллекция \"$name\" не найдена");
-            // Запись коллекции на сервер и его ответ в буфер возврата
+
-            $id = $collections->create($name, ['type' => $edge ? _collection::TYPE_EDGE : _collection::TYPE_DOCUMENT]);
+            // Запись коллекции на сервер и его ответ в буфер возврата
-
+            $id = $collections->create($name, ['type' => $edge ? _collection::TYPE_EDGE : _collection::TYPE_DOCUMENT]);
-            if ($collections->has($name)) {
+
-                // Коллекция найдена (записана)
+            if ($collections->has($name)) {
-
+                // Коллекция найдена (записана)
-                // Запись в вывод
+
-                terminal::write("Создана коллекция \"$name\" с типом " . ($edge ? 'ребро' : 'документ'));
+                // Запись в вывод
-
+                if ($terminal instanceof terminal) $terminal::write("Создана коллекция \"$name\" с типом " . ($edge ? 'ребро' : 'документ'));
-                // Возврат идентификатора коллекции
+
-                return $id;
+                // Возврат идентификатора коллекции
-            }
+                return $id;
-        } else {
+            }
-            // Найдена коллекция
+        } else {
-
+            // Найдена коллекция
-            // Возврат идентификатора коллекции
+
-            return $name;
+            // Возврат идентификатора коллекции
-        }
+            return $name;
-
+        }
-        return null;
+
-    }
+        return null;
-
+    }
-    /**
+
-     * Поиск
+    /**
-     *
+     * Поиск
-     * @param _connection $session Сессия соединения с базой данных
+     *
-     * @param string $query AQL-запрос
+     * @param _connection $session Сессия соединения с базой данных
-     *
+     * @param string $query AQL-запрос
-     * @return _document|null Инстанция документа
+     *
-     */
+     * @return _document|array|string|int|null Инстанция документа
-    public static function search(_connection $session, string $query): ?_document
+     */
-    {
+    public static function search(_connection $session, string $query): _document|string|array|int|null
-        // Поиск журнала
+    {
-        $journal = (new _statement(
+        // Поиск журнала
-            $session,
+        $journal = (new _statement(
-            [
+            $session,
-                'query' => $query,
+            [
-                "batchSize" => 1000,
+                'query' => $query,
-                "sanitize"  => true
+                "batchSize" => 1000,
-            ]
+                "sanitize"  => true
-        ))->execute();
+            ]
-
+        ))->execute();
-        // Инициализация буфера вывода
+
-        $buffer = [];
+        // Инициализация буфера вывода
-
+        $buffer = [];
-        foreach ($journal as $key => $value) {
+
-            $buffer[$key] = $value;
+        foreach ($journal as $key => $value) {
-        }
+            $buffer[$key] = $value;
-
+        }
-        return $buffer[0] ?? null;
+
-    }
+        return is_array($buffer) && count($buffer) > 1 ? $buffer : $buffer[0] ?? null;
-
+    }
-    /**
+
-     * Очистка
+    /**
-     *
+     * Очистка
-     * @param _connection $session Сессия соединения с базой данных
+     *
-     * @param string $name Название
+     * @param _connection $session Сессия соединения с базой данных
-     *
+     * @param string $name Название
-     * @return bool Статус выполнения
+     *
-     */
+     * @return bool Статус выполнения
-    public static function truncate(_connection $session, string $name): bool
+     */
-    {
+    public static function truncate(_connection $session, string $name): bool
-        // Инициализация
+    {
-        $collections = new _collection_handler($session);
+        // Инициализация
-
+        $collections = new _collection_handler($session);
-        if ($collections->has($name)) {
+
-            // Найдена коллекция
+        if ($collections->has($name)) {
-
+            // Найдена коллекция
-            // Очистка
+
-            return $collections->truncate($name);
+            // Очистка
-        }
+            return $collections->truncate($name);
-
+        }
-        return false;
+
-    }
+        return false;
-}
+    }
+}

mirzaev/arangodb/system/document.php

@@ -1,100 +1,108 @@
-<?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\DocumentHandler as _document_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 $session Сессия соединения с базой данных
+     * @param _connection $session Сессия соединения с базой данных
-     * @param string $collection Коллекция
+     * @param string $collection Коллекция
-     * @param ?array $data Данные
+     * @param ?array $data Данные
-     * @param ?array $metadata Метаданные
+     * @param bool $check Проверка на запись в базу данных
-     * @param bool $check Проверка на запись в базу данных
+     * @param ?terminal $terminal Инстанция терминала
-     *
+     *
-     * @return string|null Идентификатор
+     * @return string|null Идентификатор
-     */
+     */
-    public static function write(_connection $session, string $collection, ?array $data = null, ?array $metadata = null, bool $check = true): ?string
+    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']));
+        collection::init($session, $collection, isset($data['_from'], $data['_to']));
-
+
-        if (isset($metadata['_from'], $metadata['_to'])) {
+        if (isset($data['_from'], $data['_to'])) {
-            // Ребро
+            // Ребро
-
+
-            // Инициализация обработчика рёбер
+            // Инициализация обработчика рёбер
-            $documents = new _edge_handler($session);
+            $documents = new _edge_handler($session);
-
+
-            // Инициализация ребра
+            // Инициализация ребра
-            $document = new _edge();
+            $document = new _edge();
-
+
-            // Инициализация вершин
+            // Инициализация вершин
-            $_from = $metadata['_from'];
+            $_from = $data['_from'];
-            $_to = $metadata['_to'];
+            $_to = $data['_to'];
-
+
-            // Деинициализация из входных данных
+            // Деинициализация из входных данных
-            unset($metadata['_from'], $metadata['_to']);
+            unset($data['_from'], $data['_to']);
-        } else {
+        } else {
-            // Вершина
+            // Вершина
-
+
-            // Инициализация обработчика вершин
+            // Инициализация обработчика вершин
-            $documents = new _document_handler($session);
+            $documents = new _document_handler($session);
-
+
-            // Инициализация вершины
+            // Инициализация вершины
-            $document = new _document();
+            $document = new _document();
-        }
+        }
-
+
-        foreach (['data' => $data, 'metadata' => ($metadata ?? []) + ['created' => time()]] as $key => $value) {
+        foreach (['created' => time()] + $data as $key => $value) {
-            // Перебор параметров
+            // Перебор параметров
-
+
-            // Запись в инстанцию документа
+            // Запись в инстанцию документа
-            $document->set($key, $value);
+            $document->set($key, $value);
-        }
+        }
-
+
-        // Запись на сервер и его ответ в буфер возврата
+        // Запись на сервер и его ответ в буфер возврата
-        $id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->insert($collection, $document);
+        $id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->insert($collection, $document);
-
+
-        if ($check && $documents->has($collection, $id)) {
+        if ($check && $documents->has($collection, $id)) {
-            // Документ записан
+            // Найден записанный документ
-
+
-            // Запись в вывод
+            // Запись в вывод
-            terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
+            if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
-        }
+        } else if ($check) {
-
+            // Не найден записанный документ
-        // Возврат идентификатора коллекции
+
-        return $id;
+            // Запись в вывод
-    }
+            if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" не удалось найти созданный или создать документ");
-
+
-    /**
+            return null;
-     * Обновить
+        }
-     *
+
-     * @param _connection $session Сессия соединения с базой данных
+        // Возврат идентификатора коллекции
-     * @param _document $document Инстанция документа вершины
+        return $id;
-     *
+    }
-     * @return bool Статус обработки
+
-     */
+    /**
-    public static function update(_connection $session, _document $document): bool {
+     * Обновить
-        // Инициализация обработчика вершин
+     *
-        $documents = new _document_handler($session);
+     * @param _connection $session Сессия соединения с базой данных
-
+     * @param _document $document Инстанция документа вершины
-        // Запись в базу данных
+     *
-        return $documents->update($document);
+     * @return bool Статус обработки
-    }
+     */
-}
+    public static function update(_connection $session, _document $document): bool
+    {
+        // Инициализация обработчика вершин
+        $documents = new _document_handler($session);
+
+        // Запись в базу данных
+        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 . ']';
-    }
-}