Lifeboat\App

Complexity

Total Complexity

40

Size/Duplication

Total Lines	264
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	setAppSecret()	0	4	1
A	__construct()	0	12	4
A	setAppID()	0	4	1
A	getAppSecret()	0	3	1
A	getAPIChallenge()	0	13	4
A	setAPIChallenge()	0	9	2
A	setAccessToken()	0	9	2
A	getAppID()	0	3	1
A	refreshAccessToken()	0	19	4
B	fetchAccessToken()	0	28	8
A	getAuthHeaders()	0	5	1
A	getSites()	0	16	2
A	getAuthURL()	0	9	2
A	getAccessToken()	0	10	4
A	curl_api()	0	10	3

<?php

namespace Lifeboat;

use Lifeboat\Exceptions\InvalidArgumentException;
use Lifeboat\Exceptions\OAuthException;
use Lifeboat\Utils\Curl;
use Lifeboat\Utils\URL;
use Lifeboat\Utils\Utils;

/**
 * Class App
 * @package Lifeboat
 */
class App extends Connector {

    const CODE_URL      = '/oauth/code';

    const ACCESS_TOKEN_PARAM    = 'lb_app_access_token';
    const API_CHALLENGE_PARAM   = 'lb_app_api_challenge';

    private $_app_id;
    private $_app_secret;
    private $_api_challenge = '';

    /**
     * @param string $app_id
     * @param string $app_secret
     * @param string $auth_domain
     */
    public function __construct(string $app_id, string $app_secret, string $auth_domain = self::AUTH_DOMAIN)
    {
        if (!$app_id || !$app_secret) {
            throw new InvalidArgumentException(static::class . "expects an app_id and app_secret");
        }

        $this->setAppID($app_id);
        $this->setAppSecret($app_secret);
        $this->_auth_domain = rtrim($auth_domain, '/');

        if (session_status() === PHP_SESSION_ACTIVE) {
            $this->setAccessToken($_SESSION[self::ACCESS_TOKEN_PARAM] ?? '');
        }
    }

    /**
     * @return string
     */
    public function getAppID(): string
    {
        return $this->_app_id;
    }

    /**
     * @param string $id
     * @return $this
     */
    public function setAppID(string $id): App
    {
        $this->_app_id = $id;
        return $this;
    }

    /**
     * @return string
     */
    public function getAppSecret(): string
    {
        return $this->_app_secret;
    }

    /**
     * @param string $token
     * @return $this
     */
    public function setAccessToken(string $token): App
    {
        $this->_access_token = $token;

        if (session_status() === PHP_SESSION_ACTIVE) {
            $_SESSION[self::ACCESS_TOKEN_PARAM] = $this->_access_token;
        }

        return $this;
    }

    /**
     * @param string $secret
     * @return $this
     */
    public function setAppSecret(string $secret): App
    {
        $this->_app_secret = $secret;
        return $this;
    }

    /**
     * @param string $challenge
     * @return $this
     */
    public function setAPIChallenge(string $challenge): App
    {
        $this->_api_challenge = $challenge;

        if (session_status() === PHP_SESSION_ACTIVE) {
            $_SESSION[self::API_CHALLENGE_PARAM] = $this->_api_challenge;
        }

        return $this;
    }

    /**
     * @param bool $check_session
     * @return string
     */
    public function getAPIChallenge(bool $check_session = true): string
    {
        if ($this->_api_challenge) return $this->_api_challenge;

        if ($check_session && session_status() === PHP_SESSION_ACTIVE) {
            $this->setAPIChallenge($_SESSION[self::API_CHALLENGE_PARAM] ?? '');
            return $this->getAPIChallenge(false);
        }

        $this->_api_challenge = Utils::create_random_string(128);
        $this->setAPIChallenge($this->_api_challenge);

        return $this->_api_challenge;
    }

    /**
     * @param string $process_url
     * @param string $error_url
     * @param string $challenge
     * @return string
     */
    public function getAuthURL(string $process_url, string $error_url, string $challenge): string
    {
        $url    = URL::setGetVar('app_id', $this->getAppID(), $this->auth_url(self::CODE_URL));
        $url    = URL::setGetVar('process_url', urlencode($process_url), $url);
        $url    = URL::setGetVar('error_url', urlencode($error_url), $url);

        if ($this->getSiteKey()) $url = URL::setGetVar('site_key', $this->getSiteKey(), $url);

        return URL::setGetVar('challenge', Utils::pack($challenge), $url);
    }

    /**
     * @param string|null $code
     * @return string
     */
    public function fetchAccessToken(string $code = null): string
    {
        $curl = new Curl($this->auth_url('/oauth/token'), [
            'app_id'        => $this->getAppID(),
            'challenge'     => $this->getAPIChallenge(),
            'app_secret'    => $this->getAppSecret(),
            'site_key'      => $this->getSiteKey(),
            'code'          => $code
        ]);

        $curl->setMethod('POST');
        $response = $curl->curl();
        $json = $response->getJSON();

        if (!$response->isValid() || !$json || !array_key_exists('access_token', $json)) {
            if (array_key_exists('error', $json)) throw new OAuthException($json['error']);
            return '';
        } else {
            $this->setAccessToken($json['access_token']);

            if (array_key_exists('store_data', $json) &&
                array_key_exists('domain', $json['store_data']) &&
                array_key_exists('site_key', $json['store_data'])
            ) {
                $this->setActiveSite($json['store_data']['domain'], $json['store_data']['site_key']);
            }

            return $this->getAccessToken(false);
        }
    }

    /**
     * @param bool $check_session
     * @return string
     */
    public function getAccessToken(bool $check_session = true): string
    {
        if ($this->_access_token) return $this->_access_token;

        if ($check_session && session_status() === PHP_SESSION_ACTIVE) {
            $this->setAccessToken($_SESSION[self::ACCESS_TOKEN_PARAM] ?? '');
            return $this->getAccessToken(false);
        }

        return '';
    }

    /**
     * Makes a request to the API to refresh the current access token
     *
     * @return $this
     * @throws OAuthException
     */
    public function refreshAccessToken(): Connector
    {
        $curl = new Curl($this->auth_url('/oauth/refresh_token'), [
            'access_token'  => $this->getAccessToken(),
            'app_id'        => $this->getAppID(),
            'site_key'      => $this->getSiteKey()
        ]);

        $curl->setMethod('POST');
        $response = $curl->curl();
        $json = $response->getJSON();

        if (!$response->isValid() || !$json || !array_key_exists('access_token', $json)) {
            throw new OAuthException($response->getError());
        } else {
            $this->setAccessToken($json['access_token']);
        }

        return $this;
    }


    /**
     * @return array
     * @throws OAuthException
     */
    public function getSites(): array
    {
        $curl = new Curl($this->auth_url(self::SITES_URL), [
            'access_token'  => $this->getAccessToken(),
            'app_id'        => $this->getAppID()
        ]);

        $curl->setMethod('POST');
        $response = $curl->curl();

        if (!$response->isValid()) {
            $error = $response->getJSON();
            throw new OAuthException($error['error'], $error['code']);
        }

        return $response->getJSON() ?? [];
    }

    /**
     * @param string $url
     * @param string $method
     * @param array $data
     * @param array $headers
     * @param bool $retry
     * @return CurlResponse
     * @throws OAuthException
     */
    public function curl_api(string $url, string $method = 'GET', array $data = [], array $headers = [], bool $retry = true): CurlResponse
    {
        $response = parent::curl_api($url, $method, $data, $headers);

        if ($retry && $response->getHTTPCode() === 401) {
            $this->fetchAccessToken();
            return $this->curl_api($url, $method, $data, $headers, false);
        }

        return $response;
    }

    /**
     * @return array
     * @throws Exceptions\OAuthException
     */
    public function getAuthHeaders(): array
    {
        $headers = parent::getAuthHeaders();
        $headers['app-id'] = $this->getAppID();
        return $headers;
    }
}