Shoman4eg\Nalog\Http\Authenticator

Complexity

Total Complexity

11

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	setAccessToken()	0	3	1
A	createPhoneChallenge()	0	20	2
A	getAccessToken()	0	3	1
A	createAccessTokenByPhone()	0	21	2
A	createAccessToken()	0	20	2
A	__construct()	0	5	1
A	refreshAccessToken()	0	18	2

<?php
declare(strict_types=1);

namespace Shoman4eg\Nalog\Http;

use Http\Client\HttpClient;
use Psr\Http\Client\ClientExceptionInterface;
use Shoman4eg\Nalog\DTO\DeviceInfo;
use Shoman4eg\Nalog\ErrorHandler;
use Shoman4eg\Nalog\Exception\DomainException;
use Shoman4eg\Nalog\RequestBuilder;
use Shoman4eg\Nalog\Util\JSON;

/**
 * Helper class to get access tokens.
 *
 * @author Artem Dubinin <artem@dubinin.me>
 *
 * @internal this class should not be used outside of the API Client, it is not part of the BC promise
 */
final class Authenticator
{
    private RequestBuilder $requestBuilder;
    private HttpClient $httpClient;
    private ?string $accessToken;
    private array $challenge;
    private string $deviceId;

    public function __construct(RequestBuilder $requestBuilder, HttpClient $httpClient, string $deviceId)
    {
        $this->requestBuilder = $requestBuilder;
        $this->httpClient = $httpClient;
        $this->deviceId = $deviceId;
    }

    /**
     * @throws ClientExceptionInterface
     * @throws \JsonException
     * @throws DomainException
     */
    public function createAccessToken(string $username, string $password): ?string
    {
        $request = $this->requestBuilder->create('POST', '/auth/lkfl', [
            'Referrer' => 'https://lknpd.nalog.ru/',
            'Referrer-Policy' => 'strict-origin-when-cross-origin',
        ], \json_encode([
            'username' => $username,
            'password' => $password,
            'deviceInfo' => new DeviceInfo($this->deviceId),
        ]));

        $response = $this->httpClient->sendRequest($request);

        if ($response->getStatusCode() >= 400) {
            (new ErrorHandler())->handleResponse($response);
        }

        $this->accessToken = (string)$response->getBody();

        return $this->accessToken;
    }

    /**
     * @throws ClientExceptionInterface
     * @throws \JsonException
     */
    public function createAccessTokenByPhone(string $phone, string $challengeToken, string $verificationCode): ?string
    {
        $request = $this->requestBuilder->create('POST', '/auth/challenge/sms/verify', [
            'Referrer' => 'https://lknpd.nalog.ru/',
            'Referrer-Policy' => 'strict-origin-when-cross-origin',
        ], \json_encode([
            'phone' => $phone,
            'code' => $verificationCode,
            'challengeToken' => $challengeToken,
            'deviceInfo' => new DeviceInfo($this->deviceId),
        ]));

        $response = $this->httpClient->sendRequest($request);

        if ($response->getStatusCode() >= 400) {
            (new ErrorHandler())->handleResponse($response);
        }

        $this->accessToken = (string)$response->getBody();

        return $this->accessToken;
    }

    /**
     * @throws ClientExceptionInterface
     * @throws \JsonException
     */
    public function createPhoneChallenge(string $phone): array
    {
        $request = $this->requestBuilder->create('POST', '/auth/challenge/sms/start', [
            'Referrer' => 'https://lknpd.nalog.ru/',
            'Referrer-Policy' => 'strict-origin-when-cross-origin',
        ], \json_encode([
            'phone' => $phone,
            'requireTpToBeActive' => true,
        ]));

        $response = $this->httpClient->sendRequest($request);

        if ($response->getStatusCode() >= 400) {
            (new ErrorHandler())->handleResponse($response);
        }

        $response = (string)$response->getBody();
        $this->challenge = JSON::decode($response);

        return $this->challenge;
    }

    /**
     * @throws ClientExceptionInterface
     * @throws \JsonException
     */
    public function refreshAccessToken(string $refreshToken): ?string
    {
        $request = $this->requestBuilder->create('POST', '/auth/token', [
            'Referrer' => 'https://lknpd.nalog.ru/sales',
            'Referrer-Policy' => 'strict-origin-when-cross-origin',
        ], JSON::encode([
            'deviceInfo' => new DeviceInfo($this->deviceId),
            'refreshToken' => $refreshToken,
        ]));

        $response = $this->httpClient->sendRequest($request);
        if ($response->getStatusCode() !== 200) {
            return null;
        }

        $this->accessToken = (string)$response->getBody();

        return $this->accessToken;
    }

    public function setAccessToken(string $accessToken): void
    {
        $this->accessToken = $accessToken;
    }

    public function getAccessToken(): ?string
    {
        return $this->accessToken;
    }
}