SocialConnect\OAuth2\Provider\SmashCast

Complexity

Total Complexity

20

Size/Duplication

Total Lines	196
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	15

Test Coverage

Coverage

0%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getBaseUri()	0	4	1
A	getAuthorizeUri()	0	4	1
A	getRequestTokenUri()	0	4	1
A	getName()	0	4	1
A	getAuthUrlParameters()	0	8	1
A	parseToken()	0	13	3
A	makeAccessTokenRequest()	0	17	1
B	getAccessTokenByRequestParameters()	0	21	5
B	getUserNameByToken()	0	24	3
A	getIdentity()	0	50	3

<?php
/**
 * SocialConnect project
 * @author: Patsura Dmitry https://github.com/ovr <talk@dmtry.me>
 */

namespace SocialConnect\OAuth2\Provider;

use SocialConnect\Common\Http\Client\Client;
use SocialConnect\OAuth2\Exception\InvalidState;
use SocialConnect\OAuth2\Exception\UnknownAuthorization;
use SocialConnect\OAuth2\Exception\UnknownState;
use SocialConnect\Provider\AccessTokenInterface;
use SocialConnect\Provider\Exception\InvalidAccessToken;
use SocialConnect\Provider\Exception\InvalidResponse;
use SocialConnect\OAuth2\AccessToken;
use SocialConnect\Common\Entity\User;
use SocialConnect\Common\Hydrator\ObjectMap;

class SmashCast extends \SocialConnect\OAuth2\AbstractProvider
{
    /**
     * {@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 'smashcast';
    }

    /**
     * {@inheritdoc}
     */
    public function getAuthUrlParameters()
    {
        return [
            'app_token' => $this->consumer->getKey(),
            'redirect_uri' => $this->getRedirectUrl(),
            'response_type' => 'code',
        ];
    }

    /**
     * {@inheritdoc}
     */
    public function parseToken($body)
    {
        if (empty($body)) {
            throw new InvalidAccessToken('Provider response with empty body');
        }

        $result = json_decode($body, true);
        if ($result) {
            return new AccessToken($result);
        }

        throw new InvalidAccessToken('Provider response with not valid JSON');
    }

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

        return new \SocialConnect\Common\Http\Request(
            $this->getRequestTokenUri(),
            $parameters,
            $this->requestHttpMethod,
            [
                'Content-Type' => 'application/x-www-form-urlencoded'
            ]
        );
    }

    /**
     * {@inheritdoc}
     */
    public function getAccessTokenByRequestParameters(array $parameters)
    {
        $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 mixed
     * @throws InvalidResponse
     */
    protected function getUserNameByToken(AccessTokenInterface $accessToken)
    {
        $response = $this->httpClient->request(
            $this->getBaseUri() . 'userfromtoken/' . $accessToken->getToken()
        );

        if (!$response->isSuccess()) {
            throw new InvalidResponse(
                'API response with error code',
                $response
            );
        }

        $result = $response->json();

        if (!$result) {
            throw new InvalidResponse(
                'API response is not a valid JSON object',
                $response->getBody()
            );
        }

        return $result->user_name;
    }

    /**
     * {@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()
            ],
            Client::POST,
            [
                'Content-Type' => 'application/x-www-form-urlencoded'
            ]
        );*/

        $username = $this->getUserNameByToken($accessToken);

        $response = $this->httpClient->request(
            $this->getBaseUri() . 'user/' . $username,
            [
                'authToken' => $accessToken->getToken()
            ]
        );

        if (!$response->isSuccess()) {
            throw new InvalidResponse(
                'API response with error code',
                $response
            );
        }

        $result = $response->json();

        if (!$result) {
            throw new InvalidResponse(
                'API response is not a valid JSON object',
                $response->getBody()
            );
        }

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

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