rebuilding architecture; resolved #1, resolved #2, resolved #3, resolved #4, resolved #5, resolved #6

This commit is contained in:
Arsen Mirzaev Tatyano-Muradovich 2025-02-01 23:06:28 +07:00
parent 922cbaa09b
commit 845a9d04e0
17 changed files with 1422 additions and 95 deletions

View File

@ -1,6 +1,6 @@
{ {
"name": "svoboda/negotiator", "name": "svoboda/negotiator",
"description": "Chat-robot negotiator of the Svoboda organization", "description": "Svoboda Telegram chat-robot negotiator",
"homepage": "https://git.svoboda.works/svoboda/negotiator", "homepage": "https://git.svoboda.works/svoboda/negotiator",
"type": "chat-robot", "type": "chat-robot",
"keywords": [ "keywords": [
@ -26,7 +26,8 @@
"php": "^8.4", "php": "^8.4",
"mirzaev/minimal": "^3.4.0", "mirzaev/minimal": "^3.4.0",
"badfarm/zanzara": "^0.9.1", "badfarm/zanzara": "^0.9.1",
"react/filesystem": "^0.1.2" "react/filesystem": "^0.1.2",
"mirzaev/baza": "^3.1.0"
}, },
"require-dev": { "require-dev": {
"phpunit/phpunit": "~9.5" "phpunit/phpunit": "~9.5"

0
examples/demonstration_1_0_0.png Normal file → Executable file
View File

Before

Width:  |  Height:  |  Size: 288 KiB

After

Width:  |  Height:  |  Size: 288 KiB

0
examples/nginx/negotiator.svoboda.conf Normal file → Executable file
View File

0
examples/systemd/negotiator-telegram.service Normal file → Executable file
View File

View File

@ -0,0 +1,26 @@
<?php
// Exit (success)
return [
// System
'svoboda' => 'Svoboda',
// Settings
'settings_language_title' => 'Language',
'settings_language_add' => 'Add a language',
'settings_language_update_success' => 'Language replaced:',
'settings_language_update_fail' => 'Failed to replace language',
// Authorizing
'not_authorized_system' => 'You do not have access to the system',
'not_authorized_contact' => 'You do not have access to contact with the organisation',
'not_authorized_request' => 'You do not have access to requesting to the organisation',
'not_authorized_settings' => 'You do not have access to the settings',
'not_authorized_system_settings' => 'You do not have access to the system settings',
// Errors
'not_initialized_account' => '',
// Other
'why_so_shroomious' => 'why so shroomious',
];

View File

@ -0,0 +1,26 @@
<?php
// Exit (success)
return [
// Система
'svoboda' => 'Свобода',
// Настройки
'settings_language_title' => 'Язык',
'settings_language_add' => 'Добавить язык',
'settings_language_update_success' => 'Язык заменён:',
'settings_language_update_fail' => 'Не удалось заменить язык',
// Авторизация
'not_authorized_system' => 'У тебя нет доступа к системе',
'not_authorized_contact' => 'У тебя нет доступа к коммуникации с организацией',
'not_authorized_request' => 'У тебя нет доступа к отправке запросов в организацию',
'not_authorized_settings' => 'У тебя нет доступа к настройкам',
'not_authorized_system_settings' => 'У тебя нет доступа к системным настройкам',
// Ошибки
'not_initialized_account' => '',
// Прочее
'why_so_shroomious' => 'почему такой грибъёзный',
];

View File

@ -0,0 +1,190 @@
<?php
declare(strict_types=1);
namespace svoboda\negotiator\models;
// Files of the project
use svoboda\negotiator\models\core;
// Baza database
use mirzaev\baza\database,
mirzaev\baza\column,
mirzaev\baza\record,
mirzaev\baza\enumerations\encoding,
mirzaev\baza\enumerations\type;
// Framework for Telegram
use Zanzara\Telegram\Type\User as telegram;
// Built-in libraries
use Exception as exception,
RuntimeException as exception_runtime;
/**
* Account
*
* @package svoboda\negotiator\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
{
/**
* File
*
* @var string $database Path to the accounts database file
*/
protected string $file = DATABASES . DIRECTORY_SEPARATOR . 'accounts.baza';
/**
* Database
*
* @var database $database The database
*/
public static database $database;
/**
* Constructor
*
* @return void
*/
public function __construct()
{
// Initializing the database
static::$database = new database()
->encoding(encoding::utf8)
->columns(
new column('identifier', type::integer_unsigned),
new column('name_first', type::string, ['length' => 64]),
new column('name_second', type::string, ['length' => 64]),
new column('domain', type::string, ['length' => 32]),
new column('language', type::string, ['length' => 2]),
new column('robot', type::char),
new column('authorized_system', type::char),
new column('authorized_contact', type::char),
new column('authorized_request', type::char),
new column('authorized_settings', type::char),
new column('authorized_system_settings', type::char)
)
->connect($this->file);
}
/**
* Initialize
*
* Searches for the account record in the database, and if it does not find it, it creates it
*
* @param telegram $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 record The account record from the database
*/
public function initialize(telegram $telegram): record
{
// Searching for the account in the database
$account = static::$database->read(filter: fn(record $record) => $record->identifier === $telegram->getId(), amount: 1)[0] ?? null;
if ($account instanceof record) {
// Found the account record
if (
$account->name_first !== $telegram->getFirstName() ||
$account->name_second !== $telegram->getLastName() ||
$account->domain !== $telegram->getUsername()
) {
// The telegram account was updated
// Updating the account in the database
$updated = static::$database->read(
filter: fn(record $record) => $record->identifier === $telegram->getId(),
update: function (record &$record) use ($telegram){
// Writing new values into the record
$record->name_first = $telegram->getFirstName();
$record->name_second = $telegram->getLastName();
$record->domain = $telegram->getUsername();
},
amount: 1
)[0] ?? null;
if ($updated instanceof record && $updated->values() !== $account->values()) {
// Updated the account in the database
// Exit (success)
return $updated;
} 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');
}
}
// Exit (success)
return $account;
} else {
// Not found the account record
if ($this->registrate($telegram)) {
// Registered the account
// Searching for the registered account in the database
$account = static::$database->read(filter: fn(record $record) => $record->identifier === $telegram->getId(), amount: 1)[0] ?? null;
if ($account instanceof record) {
// Found the registered account
// Exit (success)
return $account;
} 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
*
* Creates the account record in the database
*
* @param telegram $telegram The telegram account
*
* @return bool Is the accound record created?
*/
public function registrate(telegram $telegram): bool
{
// Initializing the record
$record = static::$database->record(
(int) $telegram->getId(),
$telegram->getFirstName(),
$telegram->getLastName(),
$telegram->getUsername(),
$telegram->getLanguageCode(),
(int) $telegram->isBot(),
1,
1,
1,
1,
0
);
// Creating the accound record in the database
$created = static::$database->write($record);
// Exit (success)
return $created;
}
}

View File

@ -7,34 +7,26 @@ namespace svoboda\negotiator\models;
// Framework for PHP // Framework for PHP
use mirzaev\minimal\model; use mirzaev\minimal\model;
// Baza database
use mirzaev\baza\database,
mirzaev\baza\column,
mirzaev\baza\enumerations\encoding;
// Built-in libraries // Built-in libraries
use exception; use exception;
/** /**
* Models core * Core
* *
* @package svoboda\negotiator\models * @package svoboda\negotiator\models
* *
* @method void __construct(bool $initialize) Constructor * @method void __construct() Constructor
* *
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License * @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
* @author svoboda <mail@domain.zone> * @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
*/ */
class core extends model class core extends model
{ {
/**
* Constructor
*
* @param bool $initialize Initialize a model?
*
* @return void
*/
public function __construct(bool $initialize = true)
{
// For the extends system
parent::__construct($initialize);
}
/** /**
* Write * Write
* *

View File

@ -28,10 +28,6 @@ enum language
* @param language|null $language Language into which to translate * @param language|null $language Language into which to translate
* *
* @return string Translated label of the language * @return string Translated label of the language
*
* @todo
* 1. More languages
* 2. Cases???
*/ */
public function label(?language $language = language::en): string public function label(?language $language = language::en): string
{ {
@ -47,4 +43,20 @@ enum language
} }
}; };
} }
/**
* Flag
*
* Initialize tge flag emoji of the language
*
* @return string The flag emoji of the language
*/
public function flag(): string
{
// Exit (success)
return match ($this) {
language::en => '🇺🇸',
language::ru => '🇷🇺'
};
}
} }

View File

@ -1,48 +0,0 @@
<?php
declare(strict_types=1);
namespace svoboda\negotiator\models;
// Framework for Telegram
use Zanzara\Zanzara,
Zanzara\Context as context,
Zanzara\Telegram\Type\Input\InputFile,
Zanzara\Telegram\Type\File\Document as telegram_document,
Zanzara\Middleware\MiddlewareNode as Node,
Zanzara\Telegram\Type\User as user;
// Built-in libraries
use exception;
/**
* Telegram
*
* @package svoboda\negotiator\models
*
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
* @author svoboda <mail@domain.zone>
*/
final class telegram extends core
{
/**
* Society
*
* Responce for the command: "/society"
*
* @param context $ctx
*
* @return void
*/
public static function society(context $ctx): void
{
$ctx->sendPhoto(
new InputFile(STORAGE . DIRECTORY_SEPARATOR . 'images' . DIRECTORY_SEPARATOR . 'mushroom.jpg'),
[
'caption' => 'why so shroomious',
'disable_notification' => true
]
);
}
}

View File

@ -0,0 +1,123 @@
<?php
declare(strict_types=1);
namespace svoboda\negotiator\models\telegram;
// Files of the project
use svoboda\negotiator\models\core,
svoboda\negotiator\models\account,
svoboda\negotiator\models\enumerations\language;
// Framework for Telegram
use Zanzara\Zanzara,
Zanzara\Context as context,
Zanzara\Telegram\Type\Input\InputFile as file_input,
Zanzara\Telegram\Type\File\Document as document,
Zanzara\Middleware\MiddlewareNode as node,
Zanzara\Telegram\Type\User as user;
// Baza database
use mirzaev\baza\record;
// Built-in libraries
use Exception as exception,
Error as error;
/**
* Telegram settings
*
* @package svoboda\negotiator\models\telegram
*
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
*/
final class settings extends core
{
/**
* Settings: language
*
* Responce for the command: "/language"
*
* Sends a language selection menu
*
* @param context $context Request data from Telegram
*
* @return void
*/
public static function settings_language(context $context): void
{
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Initializing the title
$title = '🌏 *' . $localization['language_settings'] . '*';
// Declaring the buffer of generated keyboard with languages
$keyboard = [];
// Initializing the iterator of rows
$row = 0;
foreach (language::cases() as $language) {
// Iterating over languages
// Initializing the row
$keyboard[$row] ??= [];
// Writing the language choose button into the buffer of generated keyboard with languages
$keyboard[$row][] = [
'text' => ($language->flag() ? $language->flag() . ' ' : '') . $language->label($language),
'callback_data' => 'settings_language_' . $language->name
];
// When reaching 4 buttons in a row, move to the next row
if (count($keyboard[$row]) === 4) ++$row;
}
// Sending the message
$context->sendMessage(
<<<TXT
$title
TXT,
[
'reply_markup' => [
'inline_keyboard' => $keyboard
],
'disable_notification' => true
]
)
->then(function ($message) use ($context) {
//
});
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
}

View File

@ -0,0 +1,274 @@
<?php
declare(strict_types=1);
namespace svoboda\negotiator\models\telegram;
// Files of the project
use svoboda\negotiator\models\core,
svoboda\negotiator\models\account,
svoboda\negotiator\models\enumerations\language;
// Framework for Telegram
use Zanzara\Zanzara,
Zanzara\Context as context,
Zanzara\Telegram\Type\Input\InputFile as file_input,
Zanzara\Telegram\Type\File\Document as document,
Zanzara\Middleware\MiddlewareNode as node,
Zanzara\Telegram\Type\User as user;
// Baza database
use mirzaev\baza\record;
// Built-in libraries
use Exception as exception,
Error as error;
/**
* Telegram commands
*
* @package svoboda\negotiator\models\telegram
*
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
*/
final class commands extends core
{
/**
* Menu
*
* Responce for the commands: "/start", '/menu'
*
* @param context $context Request data from Telegram
*
* @return void
*/
public static function menu(context $context): void
{
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Initializing the title
$title = '*' . $localization['svoboda'] . '*';
// Sending the message
$context->sendMessage(<<<TXT
$title
TXT)
->then(function ($message) use ($context) {
//
});
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Message
*
* Responce for the command: "/message"
*
* Start a process for creating message
*
* @param context $context Request data from Telegram
*
* @return void
*/
public static function message(context $context): void
{
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
// Initializing the title
$title = '';
// Sending the message
$context->sendMessage(<<<TXT
*⚠️ Failed to initialize your Telegram account*
TXT)
->then(function ($message) use ($context) {
//
});
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Language
*
* Responce for the command: "/language"
*
* Sends a language selection menu
*
* @param context $context Request data from Telegram
*
* @return void
*/
public static function language(context $context): void
{
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Declaring the buffer of generated keyboard with languages
$keyboard = [];
// Initializing the iterator of rows
$row = 0;
foreach (language::cases() as $language) {
// Iterating over languages
// Initializing the row
$keyboard[$row] ??= [];
// Writing the language choose button into the buffer of generated keyboard with languages
$keyboard[$row][] = [
'text' => ($language->flag() ? $language->flag() . ' ' : '') . $language->label($language),
'callback_data' => 'settings_language_' . $language->name
];
// When reaching 4 buttons in a row, move to the next row
if (count($keyboard[$row]) === 4) ++$row;
}
// Writing the button for helping lozalizing
$keyboard[++$row] = [
[
'text' => '🗂 ' . $localization['settings_language_add'],
'url' => 'https://git.svoboda.works/svoboda/negotiator/src/branch/stable/svoboda/negotiator/system/localizations'
]
];
// Sending the message
$context->sendMessage(
'🌏 *' . $localization['settings_language_title'] . '*',
[
'reply_markup' => [
'inline_keyboard' => $keyboard
],
'disable_notification' => true
]
);
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Society
*
* Responce for the command: "/society"
*
* Sends the "mushroom" image and the localized text "why so shroomious"
*
* @param context $context Request data from Telegram
*
* @return void
*/
public static function society(context $context): void
{
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Sending the message
$context->sendPhoto(
new file_input(STORAGE . DIRECTORY_SEPARATOR . 'images' . DIRECTORY_SEPARATOR . 'mushroom.jpg'),
[
'caption' => $localization['why_so_shroomious'],
'disable_notification' => true
]
);
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
}

View File

@ -0,0 +1,552 @@
<?php
declare(strict_types=1);
namespace svoboda\negotiator\models\telegram;
// Files of the project
use svoboda\negotiator\models\core,
svoboda\negotiator\models\account,
svoboda\negotiator\models\enumerations\language;
// Framework for Telegram
use Zanzara\Zanzara,
Zanzara\Context as context,
Zanzara\Telegram\Type\Input\InputFile as file_input,
Zanzara\Telegram\Type\File\Document as document,
Zanzara\Middleware\MiddlewareNode as node,
Zanzara\Telegram\Type\User as user;
// Baza database
use mirzaev\baza\record;
// Built-in libraries
use Exception as exception,
Error as error;
/**
* Telegram middlewares
*
* @package svoboda\negotiator\models\telegram
*
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
*/
final class middlewares extends core
{
/**
* Account (middleware)
*
* Initialize or registrate the account and write it to the `account` variable inside the `$context`
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function account(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the telegram account
$telegram = $context->getEffectiveUser();
// Initializing the account
/* $account = new account()->initialize($telegram); */
$account = (new account())->initialize($telegram);
if ($account instanceof record) {
// Initialized the account
// Writing the account into the context variable
$context->set('account', $account);
// Continuation of the process
$next($context);
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Language (middleware)
*
* Implement the account language
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function language(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
if ($account->language) {
// Initialized the language parameter
try {
// Writing the account language into the context variable
$context->set('language', language::{$account->language});
} catch (error $error) {
// Not initialized the language
// Writing the default language into the context variable
$context->set('language', language::en);
}
} else {
// Not initialized the language parameter
// Writing the default language into the context variable
$context->set('language', language::en);
}
// Continuation of the process
$next($context);
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Localization (middleware)
*
* Implement the account language and initialize the localization file
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function localization(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
// Initializing the language
$language = $context->get('language');
if ($language instanceof language) {
// Initialized the language
// Initializing path to the localization file
$file = LOCALIZATIONS . DIRECTORY_SEPARATOR . strtolower($language->label()) . '.php';
if (file_exists($file) && is_readable($file)) {
// Found the localization file
// Initializing localization
$localization = require($file);
if (is_array($localization)) {
// Initializae localization
// Writing localization into the context variable
$context->set('localization', $localization);
// Continuation of the process
$next($context);
} else {
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not found the localization file
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize the localization file*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized language
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize language*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* System (middleware)
*
* Check the account for access to the system
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function system(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
if ($account->authorized_system) {
// Authorized the account to the system
// Continuation of the process
$next($context);
} else {
// Not authorized the account to the system
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Sending the message
$context->sendMessage('⛔ *' . $localization['not_authorized_system'] . '*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
// Stopping the process
$context->set('stop', true);
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Contact (middleware)
*
* Check the account for access to contact with the organization
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function contact(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
if ($account->authorized_contact) {
// Authorized the account to contact with the organization
// Continuation of the process
$next($context);
} else {
// Not authorized the account to contact with the organization
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Sending the message
$context->sendMessage('⛔ *' . $localization['not_authorized_contact'] . '*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
// Stopping the process
$context->set('stop', true);
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Request (middleware)
*
* Check the account for access to request to the organization
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function request(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
if ($account->authorized_request) {
// Authorized the account to request to the organization
// Continuation of the process
$next($context);
} else {
// Not authorized the account to request to the organization
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Sending the message
$context->sendMessage('⛔ *' . $localization['not_authorized_request'] . '*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
// Stopping the process
$context->set('stop', true);
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* Settings (middleware)
*
* Check the account for access to the settings
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function settings(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
if ($account->authorized_settings) {
// Authorized the account to the settings
// Continuation of the process
$next($context);
} else {
// Not authorized the account to the settings
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Sending the message
$context->sendMessage('⛔ *' . $localization['not_authorized_settings'] . '*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
// Stopping the process
$context->set('stop', true);
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
/**
* System settings (middleware)
*
* Check the account for access to the system settings
*
* @param context $context
* @param node $next
*
* @return void
*/
public static function system_settings(context $context, node $next): void
{
// Is the process stopped?
if ($context->get('stop')) return;
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
if ($account->authorized_system_settings) {
// Authorized the account to the system settings
// Continuation of the process
$next($context);
} else {
// Not authorized the account to the system settings
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Sending the message
$context->sendMessage('⛔ *' . $localization['not_authorized_system_settings'] . '*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
// Stopping the process
$context->set('stop', true);
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
}

View File

@ -0,0 +1,155 @@
<?php
declare(strict_types=1);
namespace svoboda\negotiator\models\telegram;
// Files of the project
use svoboda\negotiator\models\core,
svoboda\negotiator\models\account,
svoboda\negotiator\models\enumerations\language,
svoboda\negotiator\models\telegram\middlewares;
// Framework for Telegram
use Zanzara\Zanzara,
Zanzara\Context as context,
Zanzara\Telegram\Type\Input\InputFile as file_input,
Zanzara\Telegram\Type\File\Document as document,
Zanzara\Middleware\MiddlewareNode as node,
Zanzara\Telegram\Type\User as user;
// Baza database
use mirzaev\baza\record;
// Built-in libraries
use Exception as exception,
Error as error;
/**
* Telegram settings
*
* @package svoboda\negotiator\models\telegram
*
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
*/
final class settings extends core
{
/**
* Language
*
* Write language into the account record
*
* @param context $context Request data from Telegram
* @param language $language The language
*
* @return void
*/
public static function language(context $context, language $language): void
{
// Initializing the account
$account = $context->get('account');
if ($account instanceof record) {
// Initialized the account
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
// Updating the account in the database
$updated = account::$database->read(
filter: fn(record $record) => $record->identifier === $account->identifier,
update: function (record &$record) use ($language) {
// Writing new language value into the record
$record->language = $language->name;
},
amount: 1
)[0] ?? null;
if ($updated instanceof record) {
// Updated the account in the database
// Writing the updated account into the context variable
$context->set('account', $updated);
middlewares::language($context, new node(function (context $context) use ($account, $updated) {
// Updated language
middlewares::localization($context, new node(function (context $context) use ($account, $updated) {
// Updated localization
// Initializing localization
$localization = $context->get('localization');
if ($localization) {
// Initialized localization
try {
// Initializing the old language
$old = language::{$account->language};
// Initializing the new language
$new = language::{$updated->language};
// Sending the message
$context->sendMessage('✅ *' . $localization['settings_language_update_success'] . '* ' . ($old->flag() ? $old->flag() . ' ' : '') . $old->label($new) . ' » ' . ($new->flag() ? $new->flag() . ' ' : '') . $new->label($new))
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
} catch (error $error) {
// Failed to send the message about language update
// Sending the message
$context->sendMessage('❎ *' . $localization['settings_language_update_fail'])
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}));
}));
} else {
// Not updated the account in the database
// Sending the message
$context->sendMessage('❎ *' . $localization['settings_language_update_fail'])
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized localization
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize localization*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
} else {
// Not initialized the account
// Sending the message
$context->sendMessage('⚠️ *Failed to initialize your Telegram account*')
->then(function ($message) use ($context) {
// Ending the conversation process
$context->endConversation();
});
}
}
}

View File

@ -4,17 +4,17 @@ declare(strict_types=1);
namespace svoboda\negotiator; namespace svoboda\negotiator;
// Files of the project // Files of the project
use svoboda\negotiator\models\telegram; use svoboda\negotiator\models\telegram\middlewares,
svoboda\negotiator\models\telegram\commands,
// Framework for PHP svoboda\negotiator\models\telegram\buttons,
use mirzaev\minimal\core; svoboda\negotiator\models\telegram\settings,
svoboda\negotiator\models\enumerations\language;
// Framework for Telegram // Framework for Telegram
use Zanzara\Zanzara, use Zanzara\Zanzara as zanzara,
Zanzara\Context, Zanzara\Context as context,
Zanzara\Config; Zanzara\Config as config;
// Enabling debugging // Enabling debugging
/* ini_set('error_reporting', E_ALL); /* ini_set('error_reporting', E_ALL);
@ -24,38 +24,62 @@ ini_set('display_startup_errors', 1); */
// Initializing path to the public directory // Initializing path to the public directory
define('INDEX', __DIR__); define('INDEX', __DIR__);
// Initializing path to the project root directory // Initializing path to the root directory
define('ROOT', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR); define('ROOT', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR);
// Initializing path to the directory of settings // Initializing path to the settings directory
define('SETTINGS', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'settings'); define('SETTINGS', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'settings');
// Initializing path to the storage // Initializing path to the storage directory
define('STORAGE', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'storage'); define('STORAGE', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'storage');
// Initializing path to the databases directory
define('DATABASES', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'databases');
// Initializing path to the localizations directory
define('LOCALIZATIONS', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'localizations');
// Initiailizing telegram key // Initiailizing telegram key
define('TELEGRAM_KEY', require(SETTINGS . DIRECTORY_SEPARATOR . 'telegram.php')); define('TELEGRAM_KEY', require(SETTINGS . DIRECTORY_SEPARATOR . 'telegram.php'));
// Initializing dependencies // Initializing dependencies
require ROOT . 'vendor' . DIRECTORY_SEPARATOR . 'autoload.php'; require ROOT . 'vendor' . DIRECTORY_SEPARATOR . 'autoload.php';
var_dump(TELEGRAM_KEY); // Initializing the configuration
$config = new config();
// Initializing core $config->setParseMode(config::PARSE_MODE_MARKDOWN);
$core = new core(namespace: __NAMESPACE__);
$config = new Config();
$config->setParseMode(Config::PARSE_MODE_MARKDOWN);
$config->useReactFileSystem(true); $config->useReactFileSystem(true);
$bot = new Zanzara(TELEGRAM_KEY, $config); // Initializing the robot
$robot = new Zanzara(TELEGRAM_KEY, $config);
$bot->onUpdate(function (Context $ctx): void { // Initializing the updates listener
var_dump('biba'); $robot->onUpdate(function (Context $context): void {});
});
// Initializing the robot middlewares
$robot->middleware([middlewares::class, 'account']);
$robot->middleware([middlewares::class, 'language']);
$robot->middleware([middlewares::class, 'localization']);
$robot->middleware([middlewares::class, 'system']);
// Initializing the robot commands handlers
$robot->onCommand('start', [commands::class, 'menu']);
$robot->onCommand('menu', [commands::class, 'menu']);
/* $robot->onCommand('request', [telegram::class, 'request_start'])->middleware([telegram::class, 'request']); */
$robot->onCommand('language', [commands::class, 'language'])->middleware([middlewares::class, 'settings']);
$robot->onCommand('society', [commands::class, 'society']);
// Initializing the robot protected commands handlers
/* $robot->onCommand('system_settings', [commands::class, 'system_settings'])->middleware([middlewares::class, 'system_settings']); */
// Initializing the robot buttons handlers
foreach (language::cases() as $language) {
// Iterating over languages
// Initializing language buttons
$robot->onCbQueryData(['settings_language_' . $language->name], fn(context $context) => settings::language($context, $language));
};
/* $bot->onCommand('start', fn($ctx) => telegram::start($ctx)); */
$bot->onCommand('society', fn($ctx) => telegram::society($ctx));
// Starting chat-robot // Starting chat-robot
$bot->run(); $robot->run();

0
svoboda/negotiator/system/settings/telegram.php.sample Normal file → Executable file
View File

0
svoboda/negotiator/system/storage/images/mushroom.jpg Normal file → Executable file
View File

Before

Width:  |  Height:  |  Size: 46 KiB

After

Width:  |  Height:  |  Size: 46 KiB