forked from mirzaev/pot-php
created from kodorvan/neurobot
This commit is contained in:
377
author/project/system/models/account.php
Normal file
377
author/project/system/models/account.php
Normal file
@@ -0,0 +1,377 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace ${REPO_OWNER}\${REPO_NAME}\models;
|
||||
|
||||
// Files of the project
|
||||
use ${REPO_OWNER}\${REPO_NAME}\models\core,
|
||||
${REPO_OWNER}\${REPO_NAME}\models\authorizations,
|
||||
${REPO_OWNER}\${REPO_NAME}\models\chat,
|
||||
${REPO_OWNER}\${REPO_NAME}\models\settings,
|
||||
${REPO_OWNER}\${REPO_NAME}\models\tariff,
|
||||
${REPO_OWNER}\${REPO_NAME}\models\code,
|
||||
${REPO_OWNER}\${REPO_NAME}\models\enumerations\tariff as tariff_type;
|
||||
|
||||
// The library for languages support
|
||||
use mirzaev\languages\language;
|
||||
|
||||
// Baza database
|
||||
use mirzaev\baza\database,
|
||||
mirzaev\baza\column,
|
||||
mirzaev\baza\record,
|
||||
mirzaev\baza\enumerations\encoding,
|
||||
mirzaev\baza\enumerations\type;
|
||||
|
||||
// Active Record pattern
|
||||
use mirzaev\record\interfaces\record as record_interface,
|
||||
mirzaev\record\traits\record as record_trait;
|
||||
|
||||
// Svoboda time
|
||||
use svoboda\time\statement as svoboda;
|
||||
|
||||
// Framework for Telegram
|
||||
use Zanzara\Telegram\Type\User as telegram_user;
|
||||
|
||||
// Built-in libraries
|
||||
use Exception as exception,
|
||||
RuntimeException as exception_runtime;
|
||||
|
||||
/**
|
||||
* Account
|
||||
*
|
||||
* @package ${REPO_OWNER}\${REPO_NAME}\models
|
||||
*
|
||||
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
|
||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
||||
*/
|
||||
final class account extends core implements record_interface
|
||||
{
|
||||
use record_trait;
|
||||
|
||||
/**
|
||||
* File
|
||||
*
|
||||
* @var string $$database Path to the database file
|
||||
*/
|
||||
protected string $$file = DATABASES . DIRECTORY_SEPARATOR . 'accounts.baza';
|
||||
|
||||
/**
|
||||
* Database
|
||||
*
|
||||
* @var database $$database The database
|
||||
*/
|
||||
public protected(set) database $$database;
|
||||
|
||||
/**
|
||||
* Constructor
|
||||
*
|
||||
* @method record|null $$record The record
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function __construct(?record $$record = null)
|
||||
{
|
||||
// Initializing the database
|
||||
$$this->database = new database()
|
||||
->encoding(encoding::utf8)
|
||||
->columns(
|
||||
new column('identifier', type::long_long_unsigned),
|
||||
new column('identifier_telegram', type::long_long_unsigned),
|
||||
new column('domain', type::string, ['length' => 32]),
|
||||
new column('name_first', type::string, ['length' => 64]),
|
||||
new column('name_second', type::string, ['length' => 64]),
|
||||
new column('language', type::string, ['length' => 2]),
|
||||
new column('robot', type::char),
|
||||
/* new column('', type::), */
|
||||
new column('updated', type::integer_unsigned),
|
||||
new column('created', type::integer_unsigned)
|
||||
)
|
||||
->connect($$this->file);
|
||||
|
||||
// Initializing the record
|
||||
$$record instanceof record and $$this->record = $$record;
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize
|
||||
*
|
||||
* @param telegram_user $$telegram The telegram account
|
||||
*
|
||||
* @throws exception_runtime if update the account record in the database by the telegram account values
|
||||
* @throws exception_runtime if failed to find the registered account
|
||||
* @throws exception_runtime if failed to registrate the account
|
||||
*
|
||||
* @return static|null The account, if found, updated or created
|
||||
*/
|
||||
public function initialize(telegram_user $$telegram): ?static
|
||||
{
|
||||
// Searching for the account in the database
|
||||
$$account = $$this->database->read(filter: fn(record $$record) => $$record->identifier_telegram === $$telegram->getId(), amount: 1)[0] ?? null;
|
||||
|
||||
if ($$account instanceof record) {
|
||||
// Found the account record
|
||||
|
||||
if (
|
||||
$$account->domain !== (string) $$telegram->getUsername() ||
|
||||
$$account->name_first !== (string) $$telegram->getFirstName() ||
|
||||
$$account->name_second !== (string) $$telegram->getLastName() ||
|
||||
$$account->language !== (string) $$telegram->getLanguageCode()
|
||||
) {
|
||||
// The telegram account was updated
|
||||
|
||||
// Updating the account in the database
|
||||
$$updated = $$this->database->read(
|
||||
filter: fn(record $$record) => $$record->identifier_telegram === $$telegram->getId(),
|
||||
update: function (record &$$record) use ($$telegram) {
|
||||
// Writing new values into the record
|
||||
$$record->domain = (string) $$telegram->getUsername();
|
||||
$$record->name_first = (string) $$telegram->getFirstName();
|
||||
$$record->name_second = (string) $$telegram->getLastName();
|
||||
$$record->language = (string) $$telegram->getLanguageCode();
|
||||
$$record->updated = svoboda::timestamp();
|
||||
},
|
||||
amount: 1
|
||||
)[0] ?? null;
|
||||
|
||||
if ($$updated instanceof record && $$updated->values() !== $$account->values()) {
|
||||
// Updated the account in the database
|
||||
|
||||
// Writing the updated record into the account object
|
||||
$$this->record = $$updated;
|
||||
|
||||
// Deserializing parameters
|
||||
$$this->deserialize();
|
||||
|
||||
// Exit (success)
|
||||
return $$this;
|
||||
} else {
|
||||
// Not updated the account in the database
|
||||
|
||||
// Exit (fail)
|
||||
throw new exception_runtime('Failed to update the account record in the database by the telegram account values');
|
||||
}
|
||||
}
|
||||
|
||||
// Writing the found record into the account object
|
||||
$$this->record = $$account;
|
||||
|
||||
// Deserializing parameters
|
||||
$$this->deserialize();
|
||||
|
||||
// Exit (success)
|
||||
return $$this;
|
||||
} else {
|
||||
// Not found the account record
|
||||
|
||||
if ($$this->registrate($$telegram)) {
|
||||
// Registered the account
|
||||
|
||||
// Searching for the registered account in the database
|
||||
$$registered = $$this->database->read(filter: fn(record $$record) => $$record->identifier_telegram === $$telegram->getId(), amount: 1)[0] ?? null;
|
||||
|
||||
if ($$registered instanceof record) {
|
||||
// Found the registered account
|
||||
|
||||
// Writing the registered record into the account object
|
||||
$$this->record = $$registered;
|
||||
|
||||
// Deserializing parameters
|
||||
$$this->deserialize();
|
||||
|
||||
// Exit (success)
|
||||
return $$this;
|
||||
} else {
|
||||
// Not found the registered account
|
||||
|
||||
// Exit (fail)
|
||||
throw new exception_runtime('Failed to find the registered account');
|
||||
}
|
||||
} else {
|
||||
// Not registered the account
|
||||
|
||||
// Exit (fail)
|
||||
throw new exception_runtime('Failed to registrate the account');
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Registrate
|
||||
*
|
||||
* Create the account by the telegram account data
|
||||
*
|
||||
* @param telegram_user $$telegram The telegram account
|
||||
*
|
||||
* @return record|false The record, if created
|
||||
*/
|
||||
public function registrate(telegram_user $$telegram): record|false
|
||||
{
|
||||
// Creating the record
|
||||
$$record = $$this->write(
|
||||
telegram_identifier: (int) $$telegram->getId(),
|
||||
name_first: (string) $$telegram->getFirstName(),
|
||||
name_last: (string) $$telegram->getLastName(),
|
||||
domain: (string) $$telegram->getUsername(),
|
||||
language: (string) $$telegram->getLanguageCode(),
|
||||
robot: (bool) $$telegram->isBot()
|
||||
);
|
||||
|
||||
if ($$record instanceof record) {
|
||||
// The record was writed into the database
|
||||
|
||||
// Initializing the authorizations model
|
||||
$$authorizations = new authorizations();
|
||||
|
||||
// Creating the authorizations record
|
||||
$$authorizations->write(account: $$record->identifier);
|
||||
|
||||
// Initializing the settings model
|
||||
$$settings = new settings();
|
||||
|
||||
// Creating the account settings
|
||||
$$settings->write(account: $$record->identifier);
|
||||
|
||||
// Initializing the chat model
|
||||
$$chat = new chat();
|
||||
|
||||
// Creating the account chat
|
||||
$$record->chat = $$chat->write(account: $$record->identifier, network: NETWORK_DEFAULT);
|
||||
|
||||
// Initializing the tariff model
|
||||
$$tariff = new tariff();
|
||||
|
||||
// Creating the tariff record
|
||||
$$record->tariff = $$tariff->write(account: $$record->identifier, invoice: 0, active: 1, type: TARIFF_DEFAULT ?? tariff_type::free);
|
||||
|
||||
// Writing the record into the database
|
||||
$$record = $$this->database->read(
|
||||
filter: fn(record $$_record) => $$_record->identifier === $$record->identifier,
|
||||
update: fn(record &$$_record) => $$_record = $$record,
|
||||
amount: 1
|
||||
)[0] ?? null;
|
||||
|
||||
// Exit (success)
|
||||
return $$record;
|
||||
}
|
||||
|
||||
// Exit (fail)
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Write
|
||||
*
|
||||
* @param int $$telegram_identifier The telegram account identifier
|
||||
* @param string $$name_first
|
||||
* @param string $$name_last
|
||||
* @param string $$domain
|
||||
* @param language|string $$language
|
||||
* @param bool $$robot Is a robot?
|
||||
*
|
||||
* @return record|false The record, if created
|
||||
*/
|
||||
public function write(
|
||||
int $$telegram_identifier,
|
||||
string $$domain = '',
|
||||
string $$name_first = '',
|
||||
string $$name_last = '',
|
||||
language|string $$language = LANGUAGE_DEFAULT ?? language::en,
|
||||
bool $$robot = false,
|
||||
): record|false {
|
||||
// Initializing the record
|
||||
$$record = $$this->database->record(
|
||||
$$this->database->count() + 1,
|
||||
(int) $$telegram_identifier,
|
||||
$$domain,
|
||||
$$name_first,
|
||||
$$name_last,
|
||||
$$language instanceof language ? $$language->name : (string) $$language,
|
||||
(int) $$robot,
|
||||
/* */
|
||||
svoboda::timestamp(),
|
||||
svoboda::timestamp()
|
||||
);
|
||||
|
||||
// Writing the record into the database
|
||||
$$created = $$this->database->write($$record);
|
||||
|
||||
// Exit (success)
|
||||
return $$created ? $$record : false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Serialize
|
||||
*
|
||||
* @return self The instance from which the method was called (fluent interface)
|
||||
*/
|
||||
public function serialize(): self
|
||||
{
|
||||
// Serializing the record parameters
|
||||
$$this->record->language = $$this->record->language->name;
|
||||
|
||||
// Exit (success)
|
||||
return $$this;
|
||||
}
|
||||
|
||||
/**
|
||||
* Deserialize
|
||||
*
|
||||
* @return self The instance from which the method was called (fluent interface)
|
||||
*/
|
||||
public function deserialize(): self
|
||||
{
|
||||
// Deserializing the record parameters
|
||||
$$this->record->language = language::{$$this->record->language} ?? LANGUAGE_DEFAULT ?? language::en;
|
||||
|
||||
// Exit (success)
|
||||
return $$this;
|
||||
}
|
||||
|
||||
/**
|
||||
* Authorizations
|
||||
*
|
||||
* Search for the account authorizations
|
||||
*
|
||||
* @return authorizations|null The account authorizations
|
||||
*/
|
||||
public function authorizations(): ?authorizations
|
||||
{
|
||||
// Search for the account authorizations
|
||||
$$authorizations = new authorizations()->read(filter: fn(record $$record) => $$record->active === 1 && $$record->account === $$this->identifier);
|
||||
|
||||
if ($$authorizations instanceof authorizations) {
|
||||
// Found the account authorizations
|
||||
|
||||
// Exit (success)
|
||||
return $$authorizations;
|
||||
}
|
||||
|
||||
// Exit (fail)
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Settings
|
||||
*
|
||||
* Search for the account settings
|
||||
*
|
||||
* @return settings|null The account settings
|
||||
*/
|
||||
public function settings(): ?settings
|
||||
{
|
||||
// Search for the account settings
|
||||
$$settings = new settings()->read(filter: fn(record $$record) => $$record->active === 1 && $$record->account === $$this->identifier);
|
||||
|
||||
if ($$settings instanceof settings) {
|
||||
// Found the account settings
|
||||
|
||||
// Exit (success)
|
||||
return $$settings;
|
||||
}
|
||||
|
||||
// Exit (fail)
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user