Compare commits
No commits in common. "stable" and "1.0.x" have entirely different histories.
|
|
@ -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_ACCOUNTS);
|
||||
collection::init($this->connection->session, static::COLLECTION_USERS);
|
||||
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(
|
||||
<<<'AQL'
|
||||
FOR a IN %s
|
||||
FILTER a._id == "%s"
|
||||
'new' => collection::search($this->connection->session, <<<AQL
|
||||
FOR a IN $collection
|
||||
FILTER a._id == $message
|
||||
LIMIT 1
|
||||
RETURN a.data
|
||||
AQL,
|
||||
static::COLLECTION_MESSAGES,
|
||||
$message
|
||||
)),
|
||||
AQL),
|
||||
'old' => null
|
||||
]
|
||||
])) {
|
||||
|
|
@ -152,8 +150,8 @@ class longpoll
|
|||
* Обработка сообщений
|
||||
*
|
||||
* @param array $messages Сообщения или сообщение
|
||||
* @param ?int $id Идентификатор аккаунта которому принадлежат вложения
|
||||
* @param bool $clean Очистить массив от пустых данных?
|
||||
* @param bool $download Активация скачивания файлов на сервер
|
||||
* @param bool $clean Активация очистки массива от пустых данных сообщения
|
||||
*
|
||||
* @return array Обработанные сообщения (зависит от входных данных)
|
||||
*
|
||||
|
|
@ -165,16 +163,20 @@ 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'])) $buffer[] = &$messages;
|
||||
if (isset($messages['message'])) {
|
||||
// Передано одно сообщение
|
||||
|
||||
// Инициализация
|
||||
$buffer[] = &$messages;
|
||||
}
|
||||
|
||||
foreach ($buffer ?? $messages as &$message) {
|
||||
// Перебор сообщений
|
||||
|
||||
// Инициализация сообщения
|
||||
$message = [
|
||||
'data' => [
|
||||
'id' => [
|
||||
'global' => $message['message']['id'],
|
||||
'local' => $message['message']['conversation_message_id']
|
||||
|
|
@ -182,7 +184,9 @@ class longpoll
|
|||
'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),
|
||||
'attachments' => static::attachments($message['message']['attachments'], $download, $clean)
|
||||
],
|
||||
'metadata' => [
|
||||
'date' => [
|
||||
'create' => $message['message']['date'] ?? null,
|
||||
'update' => $message['message']['update_time'] ?? null
|
||||
|
|
@ -242,10 +246,11 @@ class longpoll
|
|||
],
|
||||
'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 $clean Очистить массив от пустых данных?
|
||||
* @param bool $download Активация скачивания файлов на сервер
|
||||
* @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 ?int $id Идентификатор аккаунта которому принадлежат изображения
|
||||
* @param array $sizes Размеры файла согласно спецификации в API
|
||||
* @param bool $download Активация скачивания файлов на сервер
|
||||
* @param int|null $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;
|
||||
}
|
||||
|
||||
/**
|
||||
* Очистить базу данных
|
||||
*
|
||||
* Предполагается использование для автоматизации тестирования
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function truncate(): void
|
||||
public function truncate()
|
||||
{
|
||||
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_ACCOUNTS;
|
||||
return static::COLLECTION_USERS;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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
|
||||
));
|
||||
}
|
||||
}
|
||||
|
|
@ -4,24 +4,14 @@ declare(strict_types=1);
|
|||
|
||||
namespace mirzaev\vk\arangodb\vk;
|
||||
|
||||
// Модуль ArangoDB для фреймворка ВКонтакте
|
||||
use mirzaev\vk\arangodb\longpoll,
|
||||
mirzaev\vk\arangodb\journal;
|
||||
use mirzaev\vk\arangodb\longpoll;
|
||||
use mirzaev\vk\arangodb\journal;
|
||||
use mirzaev\arangodb\collection;
|
||||
use mirzaev\arangodb\document;
|
||||
use ArangoDBClient\Document as _document;
|
||||
|
||||
// Фреймворк ArangoDB
|
||||
use mirzaev\arangodb\collection,
|
||||
mirzaev\arangodb\document;
|
||||
use ArangoDBClient\Connection as _connection;
|
||||
|
||||
// Библиотека для работы с 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 $create Создавать коллекции при их отсутствии?
|
||||
* @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_CHATS;
|
||||
|
||||
if ($create) {
|
||||
// Запрошено создание коллекций в случае их отсутствия
|
||||
|
||||
// Создание коллекции
|
||||
collection::init($session, longpoll::COLLECTION_CHATS);
|
||||
collection::init($session, $collection);
|
||||
}
|
||||
|
||||
// Поиск
|
||||
if ($chat = static::search($session, $id));
|
||||
else if ($chat = document::write($session, longpoll::COLLECTION_CHATS, ['id' => $id]) and $journal)
|
||||
journal::init($session, $chat)->write('create', [
|
||||
'changes' => [
|
||||
'new' => collection::search($session, sprintf(
|
||||
<<<'AQL'
|
||||
FOR x IN %s
|
||||
FILTER x._id == "%s"
|
||||
if ($account = collection::search($session, <<<AQL
|
||||
FOR x IN $collection
|
||||
FILTER x.data.data.id == $id
|
||||
LIMIT 1
|
||||
RETURN x
|
||||
AQL,
|
||||
longpoll::COLLECTION_CHATS,
|
||||
$chat
|
||||
)),
|
||||
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, <<<AQL
|
||||
FOR a IN $collection
|
||||
FILTER a._id == $account
|
||||
LIMIT 1
|
||||
RETURN a.data
|
||||
AQL),
|
||||
'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
|
||||
if ($account = collection::search($session, <<<AQL
|
||||
FOR x IN $collection
|
||||
FILTER x.data.data.id == $id
|
||||
LIMIT 1
|
||||
RETURN x
|
||||
AQL,
|
||||
longpoll::COLLECTION_CHATS,
|
||||
$id
|
||||
));
|
||||
AQL)) {
|
||||
// Найден аккаунт
|
||||
|
||||
return $account;
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -19,63 +19,64 @@ class group
|
|||
*
|
||||
* @param _connection $session Сессия соединения с базой данных
|
||||
* @param int $id Идентификатор ВКонтакте
|
||||
* @param bool $journal Записывать в журнал?
|
||||
* @param bool $create Создавать коллекции при их отсутствии?
|
||||
* @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_GROUPS;
|
||||
|
||||
if ($create) {
|
||||
// Запрошено создание коллекций в случае их отсутствия
|
||||
|
||||
// Создание коллекции
|
||||
collection::init($session, longpoll::COLLECTION_GROUPS);
|
||||
collection::init($session, $collection);
|
||||
}
|
||||
|
||||
// Поиск
|
||||
if ($group = static::search($session, $id));
|
||||
else if ($group = document::write($session, longpoll::COLLECTION_GROUPS, ['id' => $id]) and $journal)
|
||||
journal::init($session, $group)->write('create', [
|
||||
'changes' => [
|
||||
'new' => collection::search($session, sprintf(
|
||||
<<<'AQL'
|
||||
FOR x IN %s
|
||||
FILTER x._id == "%s"
|
||||
if ($account = collection::search($session, <<<AQL
|
||||
FOR x IN $collection
|
||||
FILTER x.data.data.id == $id
|
||||
LIMIT 1
|
||||
RETURN x
|
||||
AQL,
|
||||
longpoll::COLLECTION_GROUPS,
|
||||
$group
|
||||
)),
|
||||
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, <<<AQL
|
||||
FOR a IN $collection
|
||||
FILTER a._id == $account
|
||||
LIMIT 1
|
||||
RETURN a.data
|
||||
AQL),
|
||||
'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 == %d
|
||||
if ($account = collection::search($session, <<<AQL
|
||||
FOR x IN $collection
|
||||
FILTER x.data.data.id == $id
|
||||
LIMIT 1
|
||||
RETURN x
|
||||
AQL,
|
||||
longpoll::COLLECTION_GROUPS,
|
||||
$id
|
||||
));
|
||||
AQL)) {
|
||||
// Найден аккаунт
|
||||
|
||||
return $account;
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue