mirror of
https://github.com/elyby/accounts.git
synced 2024-12-05 21:19:04 +05:30
89 lines
2.6 KiB
PHP
89 lines
2.6 KiB
PHP
<?php
|
|
namespace api\models\profile;
|
|
|
|
use api\models\AccountIdentity;
|
|
use api\models\base\ApiForm;
|
|
use api\validators\PasswordRequiredValidator;
|
|
use common\helpers\Amqp;
|
|
use common\models\amqp\UsernameChanged;
|
|
use common\models\UsernameHistory;
|
|
use common\validators\UsernameValidator;
|
|
use Exception;
|
|
use PhpAmqpLib\Message\AMQPMessage;
|
|
use Yii;
|
|
use yii\base\ErrorException;
|
|
|
|
class ChangeUsernameForm extends ApiForm {
|
|
|
|
public $username;
|
|
|
|
public $password;
|
|
|
|
public function rules() {
|
|
return [
|
|
['username', UsernameValidator::class, 'accountCallback' => function() {
|
|
return $this->getAccount()->id;
|
|
}],
|
|
['password', PasswordRequiredValidator::class],
|
|
];
|
|
}
|
|
|
|
public function change() {
|
|
if (!$this->validate()) {
|
|
return false;
|
|
}
|
|
|
|
$transaction = Yii::$app->db->beginTransaction();
|
|
$account = $this->getAccount();
|
|
$oldNickname = $account->username;
|
|
try {
|
|
$account->username = $this->username;
|
|
if (!$account->save()) {
|
|
throw new ErrorException('Cannot save account model with new username');
|
|
}
|
|
|
|
$usernamesHistory = new UsernameHistory();
|
|
$usernamesHistory->account_id = $account->id;
|
|
$usernamesHistory->username = $account->username;
|
|
if (!$usernamesHistory->save()) {
|
|
throw new ErrorException('Cannot save username history record');
|
|
}
|
|
|
|
$this->createEventTask($account->id, $account->username, $oldNickname);
|
|
|
|
$transaction->commit();
|
|
} catch (Exception $e) {
|
|
$transaction->rollBack();
|
|
throw $e;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* TODO: вынести это в отдельную сущность, т.к. эта команда используется внутри формы регистрации
|
|
*
|
|
* @param integer $accountId
|
|
* @param string $newNickname
|
|
* @param string $oldNickname
|
|
* @throws \PhpAmqpLib\Exception\AMQPExceptionInterface
|
|
*/
|
|
public function createEventTask($accountId, $newNickname, $oldNickname) {
|
|
$model = new UsernameChanged;
|
|
$model->accountId = $accountId;
|
|
$model->oldUsername = $oldNickname;
|
|
$model->newUsername = $newNickname;
|
|
|
|
$message = Amqp::getInstance()->prepareMessage($model, [
|
|
'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT,
|
|
]);
|
|
|
|
Amqp::sendToEventsExchange('accounts.username-changed', $message);
|
|
}
|
|
|
|
protected function getAccount() : AccountIdentity {
|
|
return Yii::$app->user->identity;
|
|
}
|
|
|
|
}
|