mirzaev/vk/arangodb/system/longpoll.php

@@ -32,7 +32,7 @@ class longpoll
         disposition::filename as disposition_filename;
     }
 
-    const COLLECTION_ACCOUNTS = 'account';
+    const COLLECTION_USERS = 'user';
     const COLLECTION_GROUPS = 'group';
     const COLLECTION_CHATS = 'chat';
     const COLLECTION_MESSAGES = 'message';
@@ -69,7 +69,6 @@ class longpoll
                 return true;
             }
         } catch (Exception $e) {
-            // Запись ошибки в буфер вывода
             terminal::write($e->getMessage() . PHP_EOL . $e->getFile() . ':' . $e->getLine());
         }
 
@@ -79,6 +78,8 @@ class longpoll
     /**
      * Событие: "message_new"
      *
+     * Новое сообщение
+     *
      * @param array $data Данные сообщения
      * @param int $group Идентификатор группы
      * @param string $event Идентификатор события
@@ -90,15 +91,17 @@ class longpoll
         if ($this->connection->create) {
             // Запрошено создание коллекций в случае их отсутствия
 
-            // Инициализация коллекций
+            collection::init($this->connection->session, static::COLLECTION_USERS);
-            collection::init($this->connection->session, static::COLLECTION_ACCOUNTS);
             collection::init($this->connection->session, static::COLLECTION_MESSAGES);
         }
 
-        if ($message = document::write($this->connection->session, static::COLLECTION_MESSAGES, static::messages($data, $data['message']['from_id']))) {
+        if ($message = document::write($this->connection->session, static::COLLECTION_MESSAGES, static::messages($data, true))) {
             // Записано сообщение
 
-            // Инициализация субъектов
+            // Инициализация коллекции
+            $collection = static::COLLECTION_MESSAGES;
+
+            // Инициализация аккаунтов
             $from = ('mirzaev\\vk\\arangodb\\vk\\' . static::type($data['message']['from_id']))::init($this->connection->session, $data['message']['from_id']);
             $to = ('mirzaev\\vk\\arangodb\\vk\\' . static::type($data['message']['peer_id']))::init($this->connection->session, $data['message']['peer_id']);
 
@@ -108,15 +111,14 @@ class longpoll
                 if ($this->connection->create) {
                     // Запрошено создание коллекций в случае их отсутствия
 
-                    // Инициализация коллекции
                     collection::init($this->connection->session, static::COLLECTION_ACCESSED, edge: true);
                 }
 
-                if (document::write($this->connection->session, static::COLLECTION_ACCESSED, ['_from' => $from->getId(), '_to' => $message])) {
+                if (document::write($this->connection->session, static::COLLECTION_ACCESSED, [], ['_from' => $from->getId(), '_to' => $message])) {
                     // Записано ребро: АККАУНТ (отправитель) -> СООБЩЕНИЕ
                 }
 
-                if (document::write($this->connection->session, static::COLLECTION_ACCESSED, ['_from' => $message, '_to' => $to->getId()])) {
+                if (document::write($this->connection->session, static::COLLECTION_ACCESSED, [], ['_from' => $message, '_to' => $to->getId()])) {
                     // Записно ребро: СООБЩЕНИЕ -> АККАУНТ (получатель)
                 }
             }
@@ -125,16 +127,12 @@ class longpoll
             if ($this->journal && journal::init($this->connection->session, $message)->write('create', [
                 'account' => $from,
                 'changes' => [
-                    'new' => collection::search($this->connection->session, sprintf(
+                    'new' => collection::search($this->connection->session, <<<AQL
-                        <<<'AQL'
+                        FOR a IN $collection
-                            FOR a IN %s
+                        FILTER a._id == $message
-                            FILTER a._id == "%s"
+                        LIMIT 1
-                            LIMIT 1
+                        RETURN a.data
-                            RETURN a.data
+                    AQL),
-                        AQL,
-                        static::COLLECTION_MESSAGES,
-                        $message
-                    )),
                     'old' => null
                 ]
             ])) {
@@ -152,8 +150,8 @@ class longpoll
      * Обработка сообщений
      *
      * @param array $messages Сообщения или сообщение
-     * @param ?int $id Идентификатор аккаунта которому принадлежат вложения
+     * @param bool $download Активация скачивания файлов на сервер
-     * @param bool $clean Очистить массив от пустых данных?
+     * @param bool $clean Активация очистки массива от пустых данных сообщения
      *
      * @return array Обработанные сообщения (зависит от входных данных)
      *
@@ -165,87 +163,94 @@ class longpoll
      * 5. Переделать $message['vk']['metadata']['conversation']['members']['amount_test'] (или удалить)
      * 6. Разобраться с "Мультидиалогом" для старых версий API и существует ли он в новых
      */
-    public static function messages(array $messages, ?int $id = null, bool $clean = true): array
+    public static function messages(array $messages, bool $download = false, bool $clean = true): array
     {
-        // Универсализация входных данных - передано одно сообщение
+        if (isset($messages['message'])) {
-        if (isset($messages['message'])) $buffer[] = &$messages;
+            // Передано одно сообщение
+
+            // Инициализация
+            $buffer[] = &$messages;
+        }
 
         foreach ($buffer ?? $messages as &$message) {
             // Перебор сообщений
 
-            // Инициализация сообщения
             $message = [
-                'id' => [
+                'data' => [
-                    'global' => $message['message']['id'],
+                    'id' => [
-                    'local' => $message['message']['conversation_message_id']
+                        'global' => $message['message']['id'],
-                ],
+                        'local' => $message['message']['conversation_message_id']
-                'text' => $message['message']['text'] ?? $message['message']['body'],
-                'forward' => static::messages($message['message']['fwd_messages']),
-                'reply' => static::messages($message['message']['fwd_messages']),
-                'attachments' => static::attachments($message['message']['attachments'], $id, $clean),
-                'date' => [
-                    'create' => $message['message']['date'] ?? null,
-                    'update' => $message['message']['update_time'] ?? null
-                ],
-                'action' => [
-                    'type' => $message['message']['action'] ?? null,
-                    'target' => [
-                        'id' => $message['message']['action']['member_id'] ?? null
                     ],
-                    'text' => $message['message']['action']['text'] ?? null,
+                    'text' => $message['message']['text'] ?? $message['message']['body'],
-                    'email ' => $message['message']['action']['email'] ?? null,
+                    'forward' => static::messages($message['message']['fwd_messages']),
-                    'cover ' => $message['message']['action']['photo'] ?? null
+                    'reply' => static::messages($message['message']['fwd_messages']),
+                    'attachments' => static::attachments($message['message']['attachments'], $download, $clean)
                 ],
-                'hash' => $message['message']['random_id'] ?? null,
+                'metadata' => [
-                'type' => $message['message']['out'] ?? null,
+                    'date' => [
-                'admin' => [
+                        'create' => $message['message']['date'] ?? null,
-                    'id' => $message['message']['admin_author_id'] ?? null
+                        'update' => $message['message']['update_time'] ?? null
-                ],
+                    ],
-                'pinned' => [
+                    'action' => [
-                    'date' => $message['message']['pinned_at'] ?? null
+                        'type' => $message['message']['action'] ?? null,
-                ],
+                        'target' => [
-                'emoji' => $message['message']['emoji'] ?? null,
+                            'id' => $message['message']['action']['member_id'] ?? null
-                'readed' => $message['message']['read_state'] ?? null,
+                        ],
-                'listened' => $message['message']['was_listened'] ?? null,
+                        'text' => $message['message']['action']['text'] ?? null,
-                'hidden' => $message['message']['is_hidden'] ?? null,
+                        'email ' => $message['message']['action']['email'] ?? null,
-                'cropped' => $message['message']['is_cropped'] ?? null,
+                        'cover ' => $message['message']['action']['photo'] ?? null
-                'deleted' => $message['message']['deleted'] ?? null,
+                    ],
-                'conversation' =>
+                    'hash' => $message['message']['random_id'] ?? null,
-                [
+                    'type' => $message['message']['out'] ?? null,
-                    'id' => $message['message']['chat_id'] ?? null,
                     'admin' => [
-                        'id' => $message['message']['admin_id'] ?? null
+                        'id' => $message['message']['admin_author_id'] ?? null
                     ],
-                    'title' => $message['message']['title'] ?? null,
+                    'pinned' => [
-                    'members' => [
+                        'date' => $message['message']['pinned_at'] ?? null
-                        'amount' => $message['message']['members_count'] ?? null,
-                        'amount_test' => $message['message']['users_count'] ?? null
                     ],
-                    'active' => $message['message']['chat_active'] ?? null,
+                    'emoji' => $message['message']['emoji'] ?? null,
-                    'settings' => [
+                    'readed' => $message['message']['read_state'] ?? null,
-                        'push' => $message['message']['push_settings'] ?? null
+                    'listened' => $message['message']['was_listened'] ?? null,
-                    ]
+                    'hidden' => $message['message']['is_hidden'] ?? null,
-                ],
+                    'cropped' => $message['message']['is_cropped'] ?? null,
-                'important' => $message['message']['important'] ?? null,
+                    'deleted' => $message['message']['deleted'] ?? null,
-                'source' => [
+                    'conversation' =>
-                    'from' => $message['message']['ref'] ?? null,
+                    [
-                    'data' => $message['message']['ref_source'] ?? null
+                        'id' => $message['message']['chat_id'] ?? null,
-                ],
+                        'admin' => [
-                'payload' => $message['message']['payload'] ?? null,
+                            'id' => $message['message']['admin_id'] ?? null
-                'geo' => [
+                        ],
-                    $message['message']['geo'] ?? null
+                        'title' => $message['message']['title'] ?? null,
-                ],
+                        'members' => [
-                'keyboard' => [
+                            'amount' => $message['message']['members_count'] ?? null,
-                    'block' => $message['client_info']['keyboard'] ?? null,
+                            'amount_test' => $message['message']['users_count'] ?? null
-                    'inline' => $message['client_info']['inline_keyboard'] ?? null,
+                        ],
-                    'buttons' => $message['client_info']['button_actions'] ?? null,
+                        'active' => $message['message']['chat_active'] ?? null,
-                ],
+                        'settings' => [
-                'carousel' => $message['client_info']['carousel'] ?? null,
+                            'push' => $message['message']['push_settings'] ?? null
-                'language' => $message['client_info']['lang_id'] ?? null,
+                        ]
+                    ],
+                    'important' => $message['message']['important'] ?? null,
+                    'source' => [
+                        'from' => $message['message']['ref'] ?? null,
+                        'data' => $message['message']['ref_source'] ?? null
+                    ],
+                    'payload' => $message['message']['payload'] ?? null,
+                    'geo' => [
+                        $message['message']['geo'] ?? null
+                    ],
+                    'keyboard' => [
+                        'block' => $message['client_info']['keyboard'] ?? null,
+                        'inline' => $message['client_info']['inline_keyboard'] ?? null,
+                        'buttons' => $message['client_info']['button_actions'] ?? null,
+                    ],
+                    'carousel' => $message['client_info']['carousel'] ?? null,
+                    'language' => $message['client_info']['lang_id'] ?? null,
+                ]
             ];
         }
 
-        // Очистка массива
+        // Очистка массива, если активировано
         $clean and static::cleaner($messages);
 
         return $messages;
@@ -255,12 +260,12 @@ class longpoll
      * Обработка вложений
      *
      * @param array $attachments Вложения
-     * @param ?int $id Идентификатор аккаунта которому принадлежат изображения
+     * @param bool $download Активация скачивания файлов на сервер
-     * @param bool $clean Очистить массив от пустых данных?
+     * @param bool $clean Активация очистки массива от пустых данных сообщения
      *
      * @return array Обработанные вложения
      */
-    public static function attachments(array $attachments, ?int $id = null, bool $clean = true): array
+    public static function attachments(array $attachments, bool $download = false, bool $clean = false): array
     {
         foreach ($attachments as &$attachment) {
             // Перебор вложений
@@ -284,7 +289,7 @@ class longpoll
                             'key' => $attachment['photo']['access_key'] ?? null
                         ],
                         'text' => $attachment['photo']['text'] ?? null,
-                        'storage' => static::sizes($attachment['photo']['sizes'], $id) ?? null
+                        'storage' => static::sizes($attachment['photo']['sizes'], $download) ?? null
                     ],
                     'metadata' => [
                         'type' => $attachment['type'] ?? null
@@ -293,35 +298,36 @@ class longpoll
             }
         }
 
-        // Очистка массива
+        // Очистка массива, если активировано
         $clean and static::cleaner($attachments);
 
         return $attachments;
     }
 
     /**
-     * Сортировка размеров изображения из вложения
+     * Сортировка размеров файла из вложения
      *
-     * @see https://vk.com/dev/photo_sizes
+     * @param array $sizes Размеры файла согласно спецификации в API
-     *
+     * @param bool $download Активация скачивания файлов на сервер
-     * @param array $sizes Размеры изображения согласно спецификации в API
+     * @param int|null $id Идентификатор аккаунта кому принадлежат изображения
-     * @param ?int $id Идентификатор аккаунта которому принадлежат изображения
      *
      * @return array Обработанные размеры
+     *
+     * @see https://vk.com/dev/photo_sizes
      */
-    public static function sizes(array $sizes, ?int $id = null): array
+    public static function sizes(array $sizes, bool $download = false, int|null $id = null): array
     {
         foreach ($sizes as &$size) {
             // Перебор размеров
 
-            if (isset($id)) {
+            if ($download) {
-                // Запрошена запись файлов на сервер
+                // Запрошено сохранение на сервер
 
                 // Инициализация
                 $browser = new Guzzle();
 
                 // Инициализация директории
-                if (!file_exists($path = static::$path_storage . static::$path_storage_accounts . PHP_EOL . $id . static::$path_storage_accounts_images . PHP_EOL . date('Y_m_d', time())))
+                if (!file_exists($path = static::$path_storage . (isset($id) ? static::$path_storage_accounts . PHP_EOL . $id : static::$path_storage_vk) . static::$path_storage_accounts_images . PHP_EOL . date('Y_m_d', time())))
                     if (!mkdir($path, 0755, true))
                         throw new Exception('Не удалось инициализировать директорию: ' . $path);
 
@@ -365,13 +371,8 @@ class longpoll
         return $sizes;
     }
 
-    /**
+
-     * Очистить массив от пустых значений
+    // Инициализация
-     *
-     * @param array $target Обрабатываемый массив
-     *
-     * @return bool Массив был изменён?
-     */
     public static function cleaner(array &$target): bool
     {
         // Инициализация
@@ -399,16 +400,9 @@ class longpoll
         return $changes;
     }
 
-    /**
+    public function truncate()
-     * Очистить базу данных
-     *
-     * Предполагается использование для автоматизации тестирования
-     *
-     * @return void
-     */
-    public function truncate(): void
     {
-        collection::truncate($this->connection->session, static::COLLECTION_ACCOUNTS);
+        collection::truncate($this->connection->session, static::COLLECTION_USERS);
         collection::truncate($this->connection->session, static::COLLECTION_GROUPS);
         collection::truncate($this->connection->session, static::COLLECTION_CHATS);
         collection::truncate($this->connection->session, static::COLLECTION_MESSAGES);
@@ -417,11 +411,11 @@ class longpoll
     }
 
     /**
-     * Определить тип субъекта
+     * Определить тип аккаунта
      *
      * @param int $id Идентификатор
      *
-     * @return string Возвращает static::COLLECTION_ACCOUNTS, если не прошли другие проверки
+     * @return string Возвращает 'user', если не прошли другие проверки
      */
     public static function type(int $id): string
     {
@@ -429,9 +423,8 @@ class longpoll
         if ($id - 2000000000 >= 0) return static::COLLECTION_CHATS;
 
         // Группа
-        if ($id < 0) return static::COLLECTION_GROUPS;
+        if (((string) $id)[0] === '-') return static::COLLECTION_GROUPS;
 
-        // Аккаунт
+        return static::COLLECTION_USERS;
-        return static::COLLECTION_ACCOUNTS;
     }
 }

mirzaev/vk/arangodb/system/vk/account.php

@@ -1,90 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace mirzaev\vk\arangodb\vk;
-
-// Модуль ArangoDB для фреймворка ВКонтакте
-use mirzaev\vk\arangodb\longpoll,
-    mirzaev\vk\arangodb\journal;
-
-// Фреймворк ArangoDB
-use mirzaev\arangodb\collection,
-    mirzaev\arangodb\document;
-
-// Библиотека для работы с API ArabgoDB
-use ArangoDBClient\Document as _document,
-    ArangoDBClient\Connection as _connection;
-
-/**
- * Аккаунт ВКонтакте
- *
- * @package mirzaev\vk\arangodb\vk
- * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
- */
-class account
-{
-    /**
-     * Инициализировать
-     *
-     * @param _connection $session Сессия соединения с базой данных
-     * @param int $id Идентификатор ВКонтакте
-     * @param bool $journal Записывать в журнал?
-     * @param bool $create Создавать коллекции при их отсутствии?
-     *
-     * @return ?_document Инстанция документа
-     */
-    public static function init(_connection $session, int $id, bool $journal = true, bool $create = true): ?_document
-    {
-        if ($create) {
-            // Запрошено создание коллекций в случае их отсутствия
-
-            // Инициализация коллекции
-            collection::init($session, longpoll::COLLECTION_ACCOUNTS);
-        }
-
-        // Поиск
-        if ($account = static::search($session, $id));
-        else if ($account = document::write($session, longpoll::COLLECTION_ACCOUNTS, ['id' => $id]) and $journal)
-            journal::init($session, $account)->write('create', [
-                'changes' => [
-                    'new' => collection::search($session, sprintf(
-                        <<<'AQL'
-                            FOR x IN %s
-                            FILTER x._id == "%s"
-                            LIMIT 1
-                            RETURN x
-                        AQL,
-                        longpoll::COLLECTION_ACCOUNTS,
-                        $account
-                    )),
-                    'old' => null
-                ]
-            ]);
-
-        // Поиск
-        return static::search($session, $id);
-    }
-
-    /**
-     * Найти
-     *
-     * @param _connection $session Сессия соединения с базой данных
-     * @param int $id Идентификатор ВКонтакте
-     *
-     * @return ?_document Инстанция документа
-     */
-    public static function search(_connection $session, int $id): ?_document
-    {
-        return collection::search($session, sprintf(
-            <<<'AQL'
-                FOR x IN %s
-                FILTER x.id == %u
-                LIMIT 1
-                RETURN x
-            AQL,
-            longpoll::COLLECTION_ACCOUNTS,
-            $id
-        ));
-    }
-}

mirzaev/vk/arangodb/system/vk/chat.php

@@ -4,24 +4,14 @@ declare(strict_types=1);
 
 namespace mirzaev\vk\arangodb\vk;
 
-// Модуль ArangoDB для фреймворка ВКонтакте
+use mirzaev\vk\arangodb\longpoll;
-use mirzaev\vk\arangodb\longpoll,
+use mirzaev\vk\arangodb\journal;
-    mirzaev\vk\arangodb\journal;
+use mirzaev\arangodb\collection;
+use mirzaev\arangodb\document;
+use ArangoDBClient\Document as _document;
 
-// Фреймворк ArangoDB
+use ArangoDBClient\Connection as _connection;
-use mirzaev\arangodb\collection,
-    mirzaev\arangodb\document;
 
-// Библиотека для работы с API ArabgoDB
-use ArangoDBClient\Document as _document,
-    ArangoDBClient\Connection as _connection;
-
-/**
- * Чат ВКонтакте
- *
- * @package mirzaev\vk\arangodb\vk
- * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
- */
 class chat
 {
     /**
@@ -29,62 +19,64 @@ class chat
      *
      * @param _connection $session Сессия соединения с базой данных
      * @param int $id Идентификатор ВКонтакте
-     * @param bool $journal Записывать в журнал?
+     * @param bool $journal Записывать в журнал
-     * @param bool $create Создавать коллекции при их отсутствии?
+     * @param bool $create Создавать коллекции при их отсутствии
      *
      * @return ?_document Инстанция документа
      */
     public static function init(_connection $session, int $id, bool $journal = true, bool $create = true): ?_document
     {
+        // Инициализация коллекции
+        $collection = longpoll::COLLECTION_CHATS;
+
         if ($create) {
             // Запрошено создание коллекций в случае их отсутствия
 
             // Создание коллекции
-            collection::init($session, longpoll::COLLECTION_CHATS);
+            collection::init($session, $collection);
         }
 
-        // Поиск
+        if ($account = collection::search($session, <<<AQL
-        if ($chat = static::search($session, $id));
+                FOR x IN $collection
-        else if ($chat = document::write($session, longpoll::COLLECTION_CHATS, ['id' => $id]) and $journal)
+                FILTER x.data.data.id == $id
-            journal::init($session, $chat)->write('create', [
+                LIMIT 1
+                RETURN x.data
+            AQL)) {
+            // Найден аккаунт
+
+            return $account;
+        }
+
+        if ($account = document::write($session, $collection, ['data' => ['id' => $id]])) {
+            // Аккаунт записан
+
+            // Журналирование
+            if ($journal && journal::init($session, $account)->write('create', [
                 'changes' => [
-                    'new' => collection::search($session, sprintf(
+                    'new' => collection::search($session, <<<AQL
-                        <<<'AQL'
+                            FOR a IN $collection
-                            FOR x IN %s
+                            FILTER a._id == $account
-                            FILTER x._id == "%s"
                             LIMIT 1
-                            RETURN x
+                            RETURN a.data
-                        AQL,
+                        AQL),
-                        longpoll::COLLECTION_CHATS,
-                        $chat
-                    )),
                     'old' => null
                 ]
-            ]);
+            ])) {
+                // Записаны данные в журнал
+            }
 
-        // Поиск
+            if ($account = collection::search($session, <<<AQL
-        return static::search($session, $id);
+                    FOR x IN $collection
-    }
+                    FILTER x.data.data.id == $id
+                    LIMIT 1
+                    RETURN x
+                AQL)) {
+                // Найден аккаунт
 
-    /**
+                return $account;
-     * Найти в базе данных
+            }
-     *
+        }
-     * @param _connection $session Сессия соединения с базой данных
+
-     * @param int $id Идентификатор ВКонтакте
+        return null;
-     *
-     * @return ?_document Инстанция документа
-     */
-    public static function search(_connection $session, int $id): ?_document
-    {
-        return collection::search($session, sprintf(
-            <<<'AQL'
-                FOR x IN %s
-                FILTER x.id == %u
-                LIMIT 1
-                RETURN x
-            AQL,
-            longpoll::COLLECTION_CHATS,
-            $id
-        ));
     }
 }

mirzaev/vk/arangodb/system/vk/group.php

@@ -19,63 +19,64 @@ class group
      *
      * @param _connection $session Сессия соединения с базой данных
      * @param int $id Идентификатор ВКонтакте
-     * @param bool $journal Записывать в журнал?
+     * @param bool $journal Записывать в журнал
-     * @param bool $create Создавать коллекции при их отсутствии?
+     * @param bool $create Создавать коллекции при их отсутствии
      *
      * @return ?_document Инстанция документа
      */
     public static function init(_connection $session, int $id, bool $journal = true, bool $create = true): ?_document
     {
+        // Инициализация коллекции
+        $collection = longpoll::COLLECTION_GROUPS;
+
         if ($create) {
             // Запрошено создание коллекций в случае их отсутствия
 
             // Создание коллекции
-            collection::init($session, longpoll::COLLECTION_GROUPS);
+            collection::init($session, $collection);
         }
 
-        // Поиск
+        if ($account = collection::search($session, <<<AQL
-        if ($group = static::search($session, $id));
+                FOR x IN $collection
-        else if ($group = document::write($session, longpoll::COLLECTION_GROUPS, ['id' => $id]) and $journal)
+                FILTER x.data.data.id == $id
-            journal::init($session, $group)->write('create', [
+                LIMIT 1
+                RETURN x.data
+            AQL)) {
+            // Найден аккаунт
+
+            return $account;
+        }
+
+        if ($account = document::write($session, $collection, ['data' => ['id' => $id]])) {
+            // Аккаунт записан
+
+            // Журналирование
+            if ($journal && journal::init($session, $account)->write('create', [
                 'changes' => [
-                    'new' => collection::search($session, sprintf(
+                    'new' => collection::search($session, <<<AQL
-                        <<<'AQL'
+                            FOR a IN $collection
-                            FOR x IN %s
+                            FILTER a._id == $account
-                            FILTER x._id == "%s"
                             LIMIT 1
-                            RETURN x
+                            RETURN a.data
-                        AQL,
+                        AQL),
-                        longpoll::COLLECTION_GROUPS,
-                        $group
-                    )),
                     'old' => null
                 ]
-            ]);
+            ])) {
+                // Записаны данные в журнал
+            }
 
+            if ($account = collection::search($session, <<<AQL
+                    FOR x IN $collection
+                    FILTER x.data.data.id == $id
+                    LIMIT 1
+                    RETURN x
+                AQL)) {
+                // Найден аккаунт
 
-        // Поиск
+                return $account;
-        return static::search($session, $id);
+            }
-    }
+        }
 
-    /**
+        return null;
-     * Найти в базе данных
-     *
-     * @param _connection $session Сессия соединения с базой данных
-     * @param int $id Идентификатор ВКонтакте
-     *
-     * @return ?_document Инстанция документа
-     */
-    public static function search(_connection $session, int $id): ?_document
-    {
-        return collection::search($session, sprintf(
-            <<<'AQL'
-                FOR x IN %s
-                FILTER x.id == %d
-                LIMIT 1
-                RETURN x
-            AQL,
-            longpoll::COLLECTION_GROUPS,
-            $id
-        ));
     }
 }

mirzaev/vk/arangodb/system/vk/user.php

@@ -0,0 +1,82 @@
+<?php
+
+declare(strict_types=1);
+
+namespace mirzaev\vk\arangodb\vk;
+
+use mirzaev\vk\arangodb\longpoll;
+use mirzaev\vk\arangodb\journal;
+use mirzaev\arangodb\collection;
+use mirzaev\arangodb\document;
+use ArangoDBClient\Document as _document;
+
+use ArangoDBClient\Connection as _connection;
+
+class user
+{
+    /**
+     * Инициализация
+     *
+     * @param _connection $session Сессия соединения с базой данных
+     * @param int $id Идентификатор ВКонтакте
+     * @param bool $journal Записывать в журнал
+     * @param bool $create Создавать коллекции при их отсутствии
+     *
+     * @return ?_document Инстанция документа
+     */
+    public static function init(_connection $session, int $id, bool $journal = true, bool $create = true): ?_document
+    {
+        // Инициализация коллекции
+        $collection = longpoll::COLLECTION_USERS;
+
+        if ($create) {
+            // Запрошено создание коллекций в случае их отсутствия
+
+            // Создание коллекции
+            collection::init($session, $collection);
+        }
+
+        if ($account = collection::search($session, <<<AQL
+                FOR x IN $collection
+                FILTER x.id == $id
+                LIMIT 1
+                RETURN x
+            AQL)) {
+            // Найден аккаунт
+
+            return $account;
+        }
+
+        if ($account = document::write($session, $collection, ['id' => $id])) {
+            // Аккаунт записан
+
+            // Журналирование
+            if ($journal && journal::init($session, $account)->write('create', [
+                'changes' => [
+                    'new' => collection::search($session, <<<AQL
+                            FOR a IN $collection
+                            FILTER a._id == $account
+                            LIMIT 1
+                            RETURN a.data
+                        AQL),
+                    'old' => null
+                ]
+            ])) {
+                // Записаны данные в журнал
+            }
+
+            if ($account = collection::search($session, <<<AQL
+                    FOR x IN $collection
+                    FILTER x.data.data.id == $id
+                    LIMIT 1
+                    RETURN x
+                AQL)) {
+                // Найден аккаунт
+
+                return $account;
+            }
+        }
+
+        return null;
+    }
+}