Mailxpert\Authentication\OAuth2Client

Complexity

Total Complexity

12

Size/Duplication

Total Lines	165
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	getAuthorizationUrl()	0	15	2
A	getAccessTokenFromCode()	0	10	1
A	getAccessTokenFromAccessToken()	0	10	1
A	requestAccessToken()	0	27	4
A	sendRequestWithClientsParams()	0	8	1
A	getClientParams()	0	7	1

<?php
/**
 * sources.
 * Date: 14/08/15
 */

namespace Mailxpert\Authentication;

use Mailxpert\Exceptions\MailxpertSDKException;
use Mailxpert\MailxpertApp;
use Mailxpert\MailxpertClient;
use Mailxpert\MailxpertRequest;

/**
 * Class OAuth2Client
 * @package Mailxpert\Authentication
 */
class OAuth2Client
{
    const BASE_AUTHORIZATION_URL = 'https://app.mailxpert.ch';

    const REFRESH_TOKEN_VALIDITY = 31536000; // 365 days

    /**
     * @var MailxpertApp
     */
    private $app;

    /**
     * @var MailxpertClient
     */
    private $client;

    /**
     * @var
     */
    private $baseAuthorizationUrl;

    /**
     * @var MailxpertRequest
     */
    private $lastRequest;

    /**
     * OAuth2Client constructor.
     *
     * @param MailxpertApp    $mailxpertApp
     * @param MailxpertClient $mailxpertClient
     * @param string          $baseAuthorizationUrl
     */
    public function __construct(MailxpertApp $mailxpertApp, MailxpertClient $mailxpertClient, $baseAuthorizationUrl = null)
    {
        $this->app = $mailxpertApp;
        $this->client = $mailxpertClient;
        if (is_null($baseAuthorizationUrl)) {
            $baseAuthorizationUrl = static::BASE_AUTHORIZATION_URL;
        }
        $this->baseAuthorizationUrl = $baseAuthorizationUrl;
    }

    /**
     * @param string $redirectUrl
     * @param string $state
     * @param array  $scope
     * @param array  $params
     * @param string $separator
     *
     * @return string
     */
    public function getAuthorizationUrl($redirectUrl, $state, $scope, $params, $separator)
    {
        $params += [
            'client_id' => $this->app->getId(),
            'response_type' => 'code',
            'redirect_uri' => $redirectUrl,
            'scope' => implode(',', $scope),
        ];

        if ($state != null) {
            $params['state'] = $state;
        }

        return $this->baseAuthorizationUrl.'/oauth/v2/auth?'.http_build_query($params, null, $separator);
    }

    /**
     * @param string $code
     * @param string $redirectUrl
     *
     * @return AccessToken
     * @throws MailxpertSDKException
     */
    public function getAccessTokenFromCode($code, $redirectUrl)
    {
        $params = [
            'code' => $code,
            'redirect_uri' => $redirectUrl,
            'grant_type' => 'authorization_code',
        ];

        return $this->requestAccessToken($params);
    }


    /**
     * @param AccessToken $accessToken
     * @param string      $redirectUrl
     *
     * @return AccessToken
     * @throws MailxpertSDKException
     */
    public function getAccessTokenFromAccessToken(AccessToken $accessToken, $redirectUrl)
    {
        $params = [
            'refresh_token' => $accessToken->getRefreshToken(),
            'redirect_uri' => $redirectUrl,
            'grant_type' => 'refresh_token',
        ];

        return $this->requestAccessToken($params);
    }

    /**
     * @param array $params
     *
     * @return AccessToken
     * @throws MailxpertSDKException
     */
    protected function requestAccessToken(array $params)
    {
        $response = $this->sendRequestWithClientsParams('/oauth/v2/token', $params);

        $data = $response->getDecodedBody();

        if (!isset($data['access_token'])) {
            throw new MailxpertSDKException('Access token was not returned.', 401);
        }

        $expiresAt = 0;
        if (isset($data['expires'])) {
            $expiresAt = time() + $data['expires'];
        } elseif (isset($data['expires_in'])) {
            $expiresAt = time() + $data['expires_in'];
        }

        $refreshTokenExpireAt = time() + static::REFRESH_TOKEN_VALIDITY;

        return new AccessToken(
            $data['access_token'],
            $data['refresh_token'],
            $expiresAt,
            $data['scope'],
            $refreshTokenExpireAt
        );
    }

    /**
     * @param $endpoint
     * @param $params
     *
     * @return \Mailxpert\MailxpertResponse
     */
    private function sendRequestWithClientsParams($endpoint, $params)
    {
        $params += $this->getClientParams();

        $this->lastRequest = new MailxpertRequest($this->app, null, 'GET', $this->baseAuthorizationUrl.$endpoint, $params, null);

        return $this->client->sendRequest($this->lastRequest);
    }

    /**
     * @return array
     */
    private function getClientParams()
    {
        return [
            'client_id' => $this->app->getId(),
            'client_secret' => $this->app->getSecret(),
        ];
    }
}