Poniverse\Lib\Service\Poniverse\Meta

Complexity

Total Complexity

4

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	handleError()	0	10	2
A	introspect()	0	22	1
B	syncAccount()	0	28	1

<?php

/**
 * Copyright 2016 Peter Deltchev
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

namespace Poniverse\Lib\Service\Poniverse;

use League\OAuth2\Client\Token\AccessToken;
use Poniverse\Lib\Errors\InvalidAccessTokenException;
use Poniverse\Lib\Service\Service;

class Meta extends Service {
    /**
     * @param \Psr\Http\Message\ResponseInterface $response
     * @throws InvalidAccessTokenException
     * @throws \Poniverse\Lib\Errors\ApiException
     */
    protected function handleError(\Psr\Http\Message\ResponseInterface $response) {
        if (404 === $response->getStatusCode()) {
            throw new InvalidAccessTokenException('This access token is expired or invalid!');
        } else {
            throw new \Poniverse\Lib\Errors\ApiException(
                $response->getStatusCode(),
                ['response' => var_export($response, true)],

array('response' => var_export($response, true)) is of type array<string,string,{"response":"string"}>, but the function expects a array<integer,object<Poniverse\Lib\Errors\Error>>.

                'An unknown error occurred while contacting the Poniverse API.');
        }
    }

    /**
     * Gets information about the given access token.
     *
     * @link https://tools.ietf.org/html/draft-richer-oauth-introspection-06
     *
     * @param $accessTokenToIntrospect
     * @return \Poniverse\Lib\AccessToken
     */
    public function introspect($accessTokenToIntrospect) {
        $clientToken = $this->client->getOAuthProvider()->getAccessToken('client_credentials');
        $this->client->setAccessToken($clientToken);

        $request = $this->request(
            'post',
            $this->client->getPoniverseUrl() . "/v1/meta/introspect?token={$accessTokenToIntrospect}",
            ['headers' => array_merge(
                ['Accept' => 'application/json'],
                $this->client->getAuthHeader()
            )]
        );

        $response = json_decode($request->getBody(), true);

        $tokenInfo = new \Poniverse\Lib\AccessToken($accessTokenToIntrospect);
        $tokenInfo
            ->setIsActive($response['active'])
            ->setScopes($response['scope'])
            ->setClientId($response['client_id']);
        return $tokenInfo;
    }

    /**
     * Generates a new refresh token for a user and updates their email address.
     *
     * @see \League\OAuth2\Client\Token\AccessToken
     *
     * @param int $poniverseUserId
     * @param callable $tokenUpdater A callable that updates your stored access token
     *                               and refresh token for the user. A League AccessToken
     *                               object (see above) is passed as the callable's only argument.
     * @param callable $emailAddressUpdater A callable that updates the user's locally
     *                                      stored email address. The user's current
     *                                      email address is passed as its only argument.
     * @return void
     */
    public function syncAccount($poniverseUserId, $tokenUpdater, $emailAddressUpdater) {
        $clientToken = $this->client->getOAuthProvider()->getAccessToken('client_credentials');
        $this->client->setAccessToken($clientToken);

        $request = $this->request(
            'post',
            $this->client->getPoniverseUrl() . "/v1/meta/sync-account?user_id={$poniverseUserId}",
            [
                'headers' => array_merge(
                    ['Accept' => 'application/json'],
                    $this->client->getAuthHeader()
                )
            ]
        );

        $response = json_decode($request->getBody(), true);
        $tokenDetails = $response['token_info'];

        $accessToken = new AccessToken([
            'access_token'      => $tokenDetails['access_token'],
            'expires_in'        => $tokenDetails['expires_in'],
            'refresh_token'     => $tokenDetails['refresh_token'],
            'resource_owner_id' => $poniverseUserId,
        ]);

        $tokenUpdater($accessToken);
        $emailAddressUpdater($response['email']);
    }
}