Thorr\OAuth2\GrantType\ThirdParty\Provider\FacebookProvider

Complexity

Total Complexity

14

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

0%

Importance

Changes	4
Bugs	4	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	22	6
A	getIdentifier()	0	4	1
B	validate()	0	30	4
A	decodeBody()	0	19	3

<?php
/**
 * @author Stefano Torresi (http://stefanotorresi.it)
 * @license See the file LICENSE.txt for copying permission.
 * ************************************************
 */

namespace Thorr\OAuth2\GrantType\ThirdParty\Provider;

use Zend\Http\Client;
use Zend\Http\Response;
use Zend\Json\Json;
use Zend\Stdlib\ArrayUtils;

class FacebookProvider implements
    ProviderInterface
{
    use ProviderTrait;

    /**
     * @var string
     */
    protected $uri;

    /**
     * @var string
     */
    protected $appId;

    /**
     * @var array
     */
    protected $clientOptions;

    /**
     * @var array
     */
    protected $endpointParams = [];

    /**
     * @param $options
     *
     * @throws Exception\InvalidArgumentException
     */
    public function __construct($options)
    {
        if (! isset($options['app_id'])) {
            throw new Exception\InvalidArgumentException('Missing "app_id" option');
        }

        $this->appId = $options['app_id'];

        if (! isset($options['uri'])) {
            throw new Exception\InvalidArgumentException('Missing "uri" option');
        }

        $this->uri = rtrim($options['uri'], '/');

        if (isset($options['client_options'])) {
            $this->clientOptions = $options['client_options'];
        }

        if (isset($options['endpoint_params']) && is_array($options['endpoint_params'])) {
            $this->endpointParams = $options['endpoint_params'];
        }
    }

    /**
     * @return string
     */
    public function getIdentifier()
    {
        return 'facebook';
    }

    /**
     * @param $userId
     * @param $accessToken
     * @param null $errorMessage
     *
     * @throws Exception\ClientException
     *
     * @return bool
     */
    public function validate($userId, $accessToken, &$errorMessage = null)
    {
        $client = new Client($this->uri . '/me', $this->clientOptions);
        $client->setMethod('GET');
        $params = ArrayUtils::merge($this->endpointParams, ['access_token' => $accessToken]);
        $client->setParameterGet($params);

        $userData = $this->decodeBody($client->send());

        if (isset($userData->error)) {
            throw new Exception\ClientException($userData->error->message, 400);
        }

        if (! isset($userData->id)) {
            throw new Exception\ClientException('Invalid data returned by provider', 400);
        }

        if ($userData->id !== $userId) {
            $errorMessage = 'user_id mismatch';

            return false;
        }

        $this->userId = $userData->id;
        unset($userData->id);

        $this->userData = (array) $userData;

        return true;
    }

    /**
     * @param Response $response
     *
     * @throws Exception\ClientException
     *
     * @return mixed
     */
    protected function decodeBody(Response $response)
    {
        if ($response->isServerError()) {
            throw new Exception\ClientException(sprintf(
                "'%s' provider encountered a '%s' error while querying '%s'",
                $this->getIdentifier(),
                $response->getReasonPhrase(),
                $this->uri
            ));
        }

        $body = Json::decode($response->getBody());

        if ($response->isClientError()) {
            throw new Exception\ClientException($body->error->message, $response->getStatusCode());
        }

        return $body;
    }
}