SocialConnect\OAuth2\Provider\SmashCast

Complexity

Total Complexity

18

Size/Duplication

Total Lines	153
Duplicated Lines	0 %

Test Coverage

Coverage

62.22%

Importance

Changes	2
Bugs	0	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getAuthUrlParameters()	0	10	1
B	getAccessTokenByRequestParameters()	0	26	8
A	getRequestTokenUri()	0	3	1
A	getName()	0	3	1
A	getAuthorizeUri()	0	3	1
A	getBaseUri()	0	3	1
A	getUserNameByToken()	0	5	1
A	prepareRequest()	0	4	2
A	makeAccessTokenRequest()	0	11	1
A	getIdentity()	0	25	1

<?php
/**
 * SocialConnect project
 * @author: Patsura Dmitry https://github.com/ovr <talk@dmtry.me>
 */
declare(strict_types=1);

namespace SocialConnect\OAuth2\Provider;

use Psr\Http\Message\RequestInterface;
use SocialConnect\Common\ArrayHydrator;
use SocialConnect\OAuth2\Exception\InvalidState;
use SocialConnect\OAuth2\Exception\Unauthorized;
use SocialConnect\OAuth2\Exception\UnknownAuthorization;
use SocialConnect\OAuth2\Exception\UnknownState;
use SocialConnect\Provider\AccessTokenInterface;
use SocialConnect\Provider\Exception\InvalidResponse;
use SocialConnect\OAuth2\AccessToken;
use SocialConnect\Common\Entity\User;

class SmashCast extends \SocialConnect\OAuth2\AbstractProvider
{
    const NAME = 'smashcast';

    /**
     * {@inheritdoc}
     */
    public function getBaseUri()
    {
        return 'https://api.smashcast.tv/';
    }

    /**
     * {@inheritdoc}
     */
    public function getAuthorizeUri()
    {
        return 'https://api.smashcast.tv/oauth/login';
    }

    /**
     * {@inheritdoc}
     */
    public function getRequestTokenUri()
    {
        return 'https://api.smashcast.tv/oauth/exchange';
    }

    /**
     * {@inheritdoc}
     */
    public function getName()
    {
        return self::NAME;
    }

    /**
     * {@inheritdoc}
     */
    public function getAuthUrlParameters(): array
    {
        $parameters = $this->getArrayOption('auth.parameters', []);

        // Because SmashCast developers dont know about OAuth spec...
        $parameters['app_token'] = $this->consumer->getKey();
        $parameters['redirect_uri'] = $this->getRedirectUrl();
        $parameters['response_type'] = 'code';

        return $parameters;
    }

    /**
     * {@inheritdoc}
     */
    protected function makeAccessTokenRequest(string $code): RequestInterface
    {
        $parameters = [
            'request_token' => $code,
            'app_token' => $this->consumer->getKey(),
            'hash' => base64_encode($this->consumer->getKey() . $this->consumer->getSecret()),
        ];

        return $this->httpStack->createRequest($this->requestHttpMethod, $this->getRequestTokenUri())
            ->withHeader('Content-Type', 'application/x-www-form-urlencoded')
            ->withBody($this->httpStack->createStream(http_build_query($parameters)))
        ;
    }

    /**
     * {@inheritdoc}
     */
    public function getAccessTokenByRequestParameters(array $parameters)
    {
        if (isset($parameters['error']) && $parameters['error'] === 'access_denied') {
            throw new Unauthorized();
        }

        if (!$this->getBoolOption('stateless', false)) {
            $state = $this->session->get('oauth2_state');
            if (!$state) {
                throw new UnknownAuthorization();
            }

            if (!isset($parameters['state'])) {
                throw new UnknownState();
            }

            if ($state !== $parameters['state']) {
                throw new InvalidState();
            }
        }

        if (isset($parameters['authToken'])) {
            return new AccessToken(['access_token' => $parameters['authToken']]);
        }

        return $this->getAccessToken($parameters['request_token']);
    }

    /**
     * This method it needed, because I cannot fix auth/login with accessToken
     * BTW: Yes, I known that it's unneeded round trip to the server
     *
     * @param AccessTokenInterface $accessToken
     * @return string
     * @throws InvalidResponse
     * @throws \Psr\Http\Client\ClientExceptionInterface
     */
    protected function getUserNameByToken(AccessTokenInterface $accessToken): string
    {
        $response = $this->request('GET', 'userfromtoken/' . $accessToken->getToken(), [], $accessToken);

        return $response['user_name'];
    }

    /**
     * {@inheritDoc}
     */
    public function prepareRequest(string $method, string $uri, array &$headers, array &$query, ?AccessTokenInterface $accessToken = null): void
    {
        if ($accessToken) {
            $query['authToken'] = $accessToken->getToken();
        }
    }

    /**
     * {@inheritdoc}
     */
    public function getIdentity(AccessTokenInterface $accessToken)
    {
        // @todo Find a problem with this code
        /*$response = $this->httpClient->request(
            $this->getBaseUri() . 'auth/login',
            [
                'app' => 'desktop', // @any app name, not working, I was using JSON and not working..
                'authToken' => $accessToken->getToken()
            ],
            'POST',
            [
                'Content-Type' => 'application/x-www-form-urlencoded'
            ]
        );*/

        $username = $this->getUserNameByToken($accessToken);
        $response = $this->request('GET', 'user/' . $username, [], $accessToken);

        $hydrator = new ArrayHydrator([
            'user_id' => 'id',
            'user_name' => 'username',
            'user_email' => 'email',
        ]);

        return $hydrator->hydrate(new User(), $response);
    }
}