mirror of
https://github.com/elyby/accounts.git
synced 2024-12-11 16:09:25 +05:30
70 lines
2.2 KiB
PHP
70 lines
2.2 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
|
|
namespace common\tasks;
|
|
|
|
use api\exceptions\ThisShouldNotHappenException;
|
|
use common\models\Account;
|
|
use common\models\MojangUsername;
|
|
use Ely\Mojang\Api as MojangApi;
|
|
use Ely\Mojang\Exception\MojangApiException;
|
|
use Ely\Mojang\Exception\NoContentException;
|
|
use GuzzleHttp\Exception\GuzzleException;
|
|
use Yii;
|
|
use yii\queue\JobInterface;
|
|
|
|
class PullMojangUsername implements JobInterface {
|
|
|
|
public $username;
|
|
|
|
public static function createFromAccount(Account $account): self {
|
|
$result = new static();
|
|
$result->username = $account->username;
|
|
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* @param \yii\queue\Queue $queue which pushed and is handling the job
|
|
*
|
|
* @throws \Exception
|
|
*/
|
|
public function execute($queue) {
|
|
Yii::$app->statsd->inc('queue.pullMojangUsername.attempt');
|
|
/** @var MojangApi $mojangApi */
|
|
$mojangApi = Yii::$container->get(MojangApi::class);
|
|
try {
|
|
$response = $mojangApi->usernameToUUID($this->username);
|
|
Yii::$app->statsd->inc('queue.pullMojangUsername.found');
|
|
} catch (NoContentException $e) {
|
|
$response = false;
|
|
Yii::$app->statsd->inc('queue.pullMojangUsername.not_found');
|
|
} catch (GuzzleException | MojangApiException $e) {
|
|
Yii::$app->statsd->inc('queue.pullMojangUsername.error');
|
|
return;
|
|
}
|
|
|
|
/** @var MojangUsername|null $mojangUsername */
|
|
$mojangUsername = MojangUsername::findOne($this->username);
|
|
if ($response === false) {
|
|
if ($mojangUsername !== null) {
|
|
$mojangUsername->delete();
|
|
}
|
|
} else {
|
|
if ($mojangUsername === null) {
|
|
$mojangUsername = new MojangUsername();
|
|
$mojangUsername->username = $response->getName();
|
|
$mojangUsername->uuid = $response->getId();
|
|
} else {
|
|
$mojangUsername->uuid = $response->getId();
|
|
$mojangUsername->touch('last_pulled_at');
|
|
}
|
|
|
|
if (!$mojangUsername->save()) {
|
|
throw new ThisShouldNotHappenException('Cannot save mojang username');
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|