App::fetchAccessToken() - Code Metrics - Inspection of "Merge remote-tracking branch 'origin/main' into ma..." - lifeboat-app/php-sdk - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — main ( 2560cc...5cc9d7 )

by Dylan

created 2022-03-26 06:33 UTC

App::fetchAccessToken() B

↳ Parent: App

Complexity

Conditions	8
Paths	4

Size

Total Lines	28
Code Lines	19

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	8
eloc	19
c	0
b	0
f	0
nc	4
nop	1
dl	0
loc	28
rs	8.4444

<?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);

        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()
        ]);

        $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() ?? [];
    }

    /**
     * @return array
     * @throws Exceptions\OAuthException
     */
    public function getAuthHeaders(): array
    {
        $headers = parent::getAuthHeaders();
        $headers['app-id'] = $this->getAppID();
        
        if (!$this->getAccessToken()) $this->fetchAccessToken();
        if (!$this->getAccessToken()) throw new OAuthException("Access token has not been retreived");
        
        $headers['access-token'] = $this->getAccessToken();
        
        return $headers;
    }
}


1			<?php
2
3			namespace Lifeboat;
4
5			use Lifeboat\Exceptions\InvalidArgumentException;
6			use Lifeboat\Exceptions\OAuthException;
7			use Lifeboat\Utils\Curl;
8			use Lifeboat\Utils\URL;
9			use Lifeboat\Utils\Utils;
10
11			/**
12			* Class App
13			* @package Lifeboat
14			*/
15			class App extends Connector {
16
17			const CODE_URL = '/oauth/code';
18
19			const ACCESS_TOKEN_PARAM = 'lb_app_access_token';
20			const API_CHALLENGE_PARAM = 'lb_app_api_challenge';
21
22			private $_app_id;
23			private $_app_secret;
24			private $_api_challenge = '';
25
26			/**
27			* @param string $app_id
28			* @param string $app_secret
29			* @param string $auth_domain
30			*/
31			public function __construct(string $app_id, string $app_secret, string $auth_domain = self::AUTH_DOMAIN)
32			{
33			if (!$app_id \|\| !$app_secret) {
34			throw new InvalidArgumentException(static::class . "expects an app_id and app_secret");
35			}
36
37			$this->setAppID($app_id);
38			$this->setAppSecret($app_secret);
39			$this->_auth_domain = rtrim($auth_domain, '/');
40
41			if (session_status() === PHP_SESSION_ACTIVE) {
42			$this->setAccessToken($_SESSION[self::ACCESS_TOKEN_PARAM] ?? '');
43			}
44			}
45
46			/**
47			* @return string
48			*/
49			public function getAppID(): string
50			{
51			return $this->_app_id;
52			}
53
54			/**
55			* @param string $id
56			* @return $this
57			*/
58			public function setAppID(string $id): App
59			{
60			$this->_app_id = $id;
61			return $this;
62			}
63
64			/**
65			* @return string
66			*/
67			public function getAppSecret(): string
68			{
69			return $this->_app_secret;
70			}
71
72			/**
73			* @param string $token
74			* @return $this
75			*/
76			public function setAccessToken(string $token): App
77			{
78			$this->_access_token = $token;
79
80			if (session_status() === PHP_SESSION_ACTIVE) {
81			$_SESSION[self::ACCESS_TOKEN_PARAM] = $this->_access_token;
82			}
83
84			return $this;
85			}
86
87			/**
88			* @param string $secret
89			* @return $this
90			*/
91			public function setAppSecret(string $secret): App
92			{
93			$this->_app_secret = $secret;
94			return $this;
95			}
96
97			/**
98			* @param string $challenge
99			* @return $this
100			*/
101			public function setAPIChallenge(string $challenge): App
102			{
103			$this->_api_challenge = $challenge;
104
105			if (session_status() === PHP_SESSION_ACTIVE) {
106			$_SESSION[self::API_CHALLENGE_PARAM] = $this->_api_challenge;
107			}
108
109			return $this;
110			}
111
112			/**
113			* @param bool $check_session
114			* @return string
115			*/
116			public function getAPIChallenge(bool $check_session = true): string
117			{
118			if ($this->_api_challenge) return $this->_api_challenge;
119
120			if ($check_session && session_status() === PHP_SESSION_ACTIVE) {
121			$this->setAPIChallenge($_SESSION[self::API_CHALLENGE_PARAM] ?? '');
122			return $this->getAPIChallenge(false);
123			}
124
125			$this->_api_challenge = Utils::create_random_string(128);
126			$this->setAPIChallenge($this->_api_challenge);
127
128			return $this->_api_challenge;
129			}
130
131			/**
132			* @param string $process_url
133			* @param string $error_url
134			* @param string $challenge
135			* @return string
136			*/
137			public function getAuthURL(string $process_url, string $error_url, string $challenge): string
138			{
139			$url = URL::setGetVar('app_id', $this->getAppID(), $this->auth_url(self::CODE_URL));
140			$url = URL::setGetVar('process_url', urlencode($process_url), $url);
141			$url = URL::setGetVar('error_url', urlencode($error_url), $url);
142
143			return URL::setGetVar('challenge', Utils::pack($challenge), $url);
144			}
145
146			/**
147			* @param string\|null $code
148			* @return string
149			*/
150			public function fetchAccessToken(string $code = null): string
151			{
152			$curl = new Curl($this->auth_url('/oauth/token'), [
153			'app_id' => $this->getAppID(),
154			'challenge' => $this->getAPIChallenge(),
155			'app_secret' => $this->getAppSecret(),
156			'site_key' => $this->getSiteKey(),
157			'code' => $code
158			]);
159
160			$curl->setMethod('POST');
161			$response = $curl->curl();
162			$json = $response->getJSON();
163
164			if (!$response->isValid() \|\| !$json \|\| !array_key_exists('access_token', $json)) {
165			if (array_key_exists('error', $json)) throw new OAuthException($json['error']);
166			return '';
167			} else {
168			$this->setAccessToken($json['access_token']);
169
170			if (array_key_exists('store_data', $json) &&
171			array_key_exists('domain', $json['store_data']) &&
172			array_key_exists('site_key', $json['store_data'])
173			) {
174			$this->setActiveSite($json['store_data']['domain'], $json['store_data']['site_key']);
175			}
176
177			return $this->getAccessToken(false);
178			}
179			}
180
181			/**
182			* @param bool $check_session
183			* @return string
184			*/
185			public function getAccessToken(bool $check_session = true): string
186			{
187			if ($this->_access_token) return $this->_access_token;
188
189			if ($check_session && session_status() === PHP_SESSION_ACTIVE) {
190			$this->setAccessToken($_SESSION[self::ACCESS_TOKEN_PARAM] ?? '');
191			return $this->getAccessToken(false);
192			}
193
194			return '';
195			}
196
197			/**
198			* Makes a request to the API to refresh the current access token
199			*
200			* @return $this
201			* @throws OAuthException
202			*/
203			public function refreshAccessToken(): Connector
204			{
205			$curl = new Curl($this->auth_url('/oauth/refresh_token'), [
206			'access_token' => $this->getAccessToken(),
207			'app_id' => $this->getAppID()
208			]);
209
210			$curl->setMethod('POST');
211			$response = $curl->curl();
212			$json = $response->getJSON();
213
214			if (!$response->isValid() \|\| !$json \|\| !array_key_exists('access_token', $json)) {
215			throw new OAuthException($response->getError());
216			} else {
217			$this->setAccessToken($json['access_token']);
218			}
219
220			return $this;
221			}
222
223
224			/**
225			* @return array
226			* @throws OAuthException
227			*/
228			public function getSites(): array
229			{
230			$curl = new Curl($this->auth_url(self::SITES_URL), [
231			'access_token' => $this->getAccessToken(),
232			'app_id' => $this->getAppID()
233			]);
234
235			$curl->setMethod('POST');
236			$response = $curl->curl();
237
238			if (!$response->isValid()) {
239			$error = $response->getJSON();
240			throw new OAuthException($error['error'], $error['code']);
241			}
242
243			return $response->getJSON() ?? [];
244			}
245
246			/**
247			* @return array
248			* @throws Exceptions\OAuthException
249			*/
250			public function getAuthHeaders(): array
251			{
252			$headers = parent::getAuthHeaders();
253			$headers['app-id'] = $this->getAppID();
254
255			if (!$this->getAccessToken()) $this->fetchAccessToken();
256			if (!$this->getAccessToken()) throw new OAuthException("Access token has not been retreived");
257
258			$headers['access-token'] = $this->getAccessToken();
259
260			return $headers;
261			}
262			}
263

lifeboat-app / php-sdk

Push — main ( 2560cc...5cc9d7 )

App::fetchAccessToken() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like