dukt / videos

src/services/Oauth.php

<?php
/**
 * @link      https://dukt.net/videos/
 * @copyright Copyright (c) Dukt
 * @license   https://github.com/dukt/videos/blob/v2/LICENSE.md
 */

namespace dukt\videos\services;

use dukt\videos\models\Token;
use Exception;
use League\OAuth2\Client\Token\AccessToken;
use yii\base\Component;
use dukt\videos\Plugin;
use League\OAuth2\Client\Grant\RefreshToken;

/**
 * Class Oauth service.
 *
 * An instance of the Oauth service is globally accessible via [[Plugin::oauth `Plugin::$plugin->getOauth()`]].
 *
 * @author Dukt <support@dukt.net>
 * @since  2.0
 */
class Oauth extends Component
{
    // Public Methods
    // =========================================================================
    /**
     * Get a token by its gateway handle.
     *
     * @param $gatewayHandle
     * @return AccessToken|null
     * @throws \yii\base\InvalidConfigException
     */
    public function getToken(string $gatewayHandle, bool $refresh = true): ?\League\OAuth2\Client\Token\AccessToken
    {
        $token = Plugin::getInstance()->getTokens()->getToken($gatewayHandle);

        if (!$token instanceof \dukt\videos\models\Token) {
            return null;
        }

        return $this->createTokenFromData($gatewayHandle, $token->accessToken, $refresh);

$token->accessToken of type null|string is incompatible with the type array expected by parameter $data of dukt\videos\services\Oauth::createTokenFromData().

    }

    /**
     * Saves a token.
     *
     * @param $gatewayHandle
     * @param AccessToken $token
     * @return bool
     * @throws Exception
     */
    public function saveToken($gatewayHandle, AccessToken $token): bool
    {
        $tokenModel = Plugin::getInstance()->getTokens()->getToken($gatewayHandle);

        if ($tokenModel === null) {
            $tokenModel = new Token();
            $tokenModel->gateway = $gatewayHandle;
        }

        $tokenModel->accessToken = [

It seems like array('accessToken' => $token->getToken(), 'expires' => $token->getExpires(), 'resourceOwnerId' => $token->getResourceOwnerId(), 'values' => $token->getValues()) of type array<string,array|integer|string> is incompatible with the declared type null|string of property $accessToken.

            'accessToken' => $token->getToken(),
            'expires' => $token->getExpires(),
            'resourceOwnerId' => $token->getResourceOwnerId(),
            'values' => $token->getValues(),
        ];

        if (!empty($token->getRefreshToken())) {
            $tokenModel->accessToken['refreshToken'] = $token->getRefreshToken();
        }

        Plugin::getInstance()->getTokens()->saveToken($tokenModel);

        return true;
    }

    /**
     * Deletes a token.
     *
     * @param $gatewayHandle
     * @return bool
     * @throws \Throwable
     * @throws \yii\base\InvalidConfigException
     * @throws \yii\db\StaleObjectException
     */
    public function deleteToken($gatewayHandle): bool
    {
        $token = Plugin::getInstance()->getTokens()->getToken($gatewayHandle);

        if (!$token instanceof \dukt\videos\models\Token) {
            return true;
        }

        return Plugin::getInstance()->getTokens()->deleteTokenById($token->id);

It seems like $token->id can also be of type null; however, parameter $id of dukt\videos\services\Tokens::deleteTokenById() does only seem to accept integer, maybe add an additional type check?

    }

    // Private Methods
    // =========================================================================
    /**
     * Create token from data.
     *
     *
     * @return AccessToken|null
     * @throws \yii\base\InvalidConfigException
     */
    private function createTokenFromData(string $gatewayHandle, array $data, bool $refreshToken = true): ?\League\OAuth2\Client\Token\AccessToken
    {
        if (!isset($data['accessToken'])) {
            return null;
        }

        $token = new AccessToken([
            'access_token' => $data['accessToken'] ?? null,
            'expires' => $data['expires'] ?? null,
            'refresh_token' => $data['refreshToken'] ?? null,
            'resource_owner_id' => $data['resourceOwnerId'] ?? null,
            'values' => $data['values'] ?? null,
        ]);

        // Refresh OAuth token
        if ($refreshToken && !empty($token->getRefreshToken()) && $token->getExpires() && $token->hasExpired()) {
            $gateway = Plugin::$plugin->getGateways()->getGateway($gatewayHandle);
            $provider = $gateway->getOauthProvider();
            $grant = new RefreshToken();
            $newToken = $provider->getAccessToken($grant, ['refresh_token' => $token->getRefreshToken()]);

            $token = new AccessToken([
                'access_token' => $newToken->getToken(),
                'expires' => $newToken->getExpires(),
                'refresh_token' => $token->getRefreshToken(),
                'resource_owner_id' => $newToken->getResourceOwnerId(),
                'values' => $newToken->getValues(),
            ]);

            Plugin::$plugin->getOauth()->saveToken($gateway->getHandle(), $token);
        }

        return $token;
    }
}