HubicService::injectRequestFactory() - Code Metrics - filoucrackeur/hubic - Measure and Improve Code Quality continuously with Scrutinizer

HubicService::injectRequestFactory() A
last analyzed 2018-03-18 22:31 UTC

↳ Parent: HubicService

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	4
ccs	0
cts	3
cp	0
rs	10
c	0
b	0
f	0
cc	1
eloc	2
nc	1
nop	1
crap	2

<?php
/*
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

namespace Filoucrackeur\Hubic\Service;

use Filoucrackeur\Hubic\Domain\Model\Account;
use Filoucrackeur\Hubic\Domain\Repository\AccountRepository;
use GuzzleHttp\RequestOptions;
use Psr\Http\Message\ResponseInterface;
use TYPO3\CMS\Core\FormProtection\FormProtectionFactory;
use TYPO3\CMS\Core\Http\RequestFactory;
use TYPO3\CMS\Core\SingletonInterface;
use TYPO3\CMS\Core\Utility\GeneralUtility;
use TYPO3\CMS\Extbase\Mvc\Web\Routing\UriBuilder;
use TYPO3\CMS\Extbase\Persistence\Generic\PersistenceManager;
use TYPO3\CMS\Extbase\Persistence\Generic\QueryResult;

class HubicService implements SingletonInterface
{
    const AUTHORIZATION_ENDPOINT = 'https://api.hubic.com/oauth/auth/';

    const TOKEN_ENDPOINT = 'https://api.hubic.com/oauth/token/';

    const DOMAIN_API = 'https://api.hubic.com/';

    const VERSION_API = '1.0';

    /**
     * @var RequestFactory
     */
    protected $requestFactory;

    /**
     * @var \TYPO3\CMS\Extbase\Persistence\Generic\PersistenceManager
     */
    protected $persistenceManager;

    /**
     * @var \Filoucrackeur\Hubic\Domain\Repository\AccountRepository
     */
    protected $accountRepository;

    /**
     * @var \Filoucrackeur\Hubic\Domain\Model\Account
     */
    protected $account;

    /**
     * @param Account $account
     *
     * @return bool
     * @throws \RuntimeException
     */
    public function accessToken(Account $account)
    {
        $credentials = base64_encode($account->getClientId() . ':' . $account->getClientSecret());
        $additionalOptions = [
            'headers' => [
                'Content-Type' => 'application/x-www-form-urlencoded',
                'Authorization' => 'Basic ' . $credentials,
            ],
            RequestOptions::FORM_PARAMS => [
                'code' => GeneralUtility::_GET('code'),
                'redirect_uri' => $this->getHost() . '/',
                'grant_type' => 'authorization_code',
            ],
            RequestOptions::VERSION => '1.1',
        ];

        $response = $this->requestFactory->request(self::TOKEN_ENDPOINT, 'POST', $additionalOptions);

        if (200 === $response->getStatusCode()) {
            $content = json_decode($response->getBody()->getContents());
            $account->setAccessToken($content->access_token);
            $account->setRefreshToken($content->refresh_token);
            $expireIn = new \DateTime('+ ' . $content->expires_in . ' seconds');
            $account->setExpirationDate($expireIn);
            $this->persistenceManager->update($account);
            $this->persistenceManager->persistAll();
        }

        return true;
    }

    /**
     * @return string
     */
    public function getHost(): string
    {
        return $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['HTTP_HOST'];
    }

    /**
     * @param Account $account
     */
    public function redirectUrlRequestToken(Account $account)
    {
        $arguments = [
            'client_id' => $account->getClientId(),
            'redirect_uri' => $this->getRedirectUri($account),
            'scope' => $account->getScope(),
            'response_type' => 'code',
            'state' => time(),
        ];

        $uri = self::AUTHORIZATION_ENDPOINT . '?' . urldecode(http_build_query($arguments));
        header('Location: ' . $uri);
        die();
    }

    /**
     * @param Account $account
     *
     * @return string
     */
    private function getRedirectUri(Account $account): string
    {
        $formProtection = FormProtectionFactory::get();
        $formToken = $formProtection->generateToken('AuthorizationRequest');

        $uriBuilder = GeneralUtility::makeInstance(UriBuilder::class);

        return urlencode($this->getHost() . $uriBuilder
                ->setCreateAbsoluteUri(true)
                ->setArguments([
                    'tx_hubic_tools_hubichubic' => [
                        'action' => 'callback',
                        'controller' => 'Backend\Account',
                        'account' => $account->getUid(),
                    ],
                    'formToken' => $formToken
                ])->buildBackendUri());
    }

    public function getAccount()
    {
        return $this->fetch('/account');
    }

    /**
     * @param Account $account
     */
    public function setAccount(Account $account)
    {
        $this->account = $account;
    }

    /**
     * @param string $path
     * @param string $method
     * @param array $arguments
     * @return \Psr\Http\Message\ResponseInterface|string
     */
    public function fetch(string $path, $method = 'GET', array $arguments = [])
    {
        $additionalOptions = [
            'headers' => [
                'Content-Type' => 'application/x-www-form-urlencoded',
                'Authorization' => 'Bearer ' . $this->account->getAccessToken(),
            ],
            RequestOptions::VERSION => '1.1',
        ];

        if (!empty($arguments)) {
            $additionalOptions[RequestOptions::FORM_PARAMS] = $arguments;
        }

        try {
            $response = $this->requestFactory->request(self::DOMAIN_API . self::VERSION_API . $path, $method,
                $additionalOptions);

            if (200 === $response->getStatusCode()) {
                return json_decode($response->getBody()->getContents());
            }
        } catch (\Exception $e) {
            if ($this->refreshToken($this->account)) {
                return $this->fetch($path, $method);
            }
        }
        return null;
    }

    /**
     * @param Account $account
     * @return bool
     */
    public function refreshToken(Account $account): bool
    {

        $credentials = base64_encode($account->getClientId() . ':' . $account->getClientSecret());
        $additionalOptions = [
            'headers' => [
                'Content-Type' => 'application/x-www-form-urlencoded',
                'Authorization' => 'Basic ' . $credentials,
            ],
            RequestOptions::FORM_PARAMS => [
                'refresh_token' => $account->getRefreshToken(),
                'grant_type' => 'refresh_token',
            ],
            RequestOptions::VERSION => '1.1',
        ];

        $response = $this->requestFactory->request(self::TOKEN_ENDPOINT, 'POST', $additionalOptions);

        if (200 === $response->getStatusCode()) {
            $content = json_decode($response->getBody()->getContents());
            $account->setAccessToken($content->access_token);
            $this->persistenceManager->update($account);
            $this->persistenceManager->persistAll();
        }

        return true;
    }

    /**
     * @param Account $account
     */
    public function delete(Account $account): void
    {
        $this->persistenceManager->remove($account);
        $this->persistenceManager->persistAll();
    }

    /**
     * @param Account $account
     */
    public function unlink(Account $account): void
    {
        $account->setAccessToken('');
        $account->setRefreshToken('');
        $this->persistenceManager->update($account);
        $this->persistenceManager->persistAll();
    }

    /**
     * @return QueryResult|null
     */
    public function getAccounts()
    {
        return $this->accountRepository->findAll();
    }

    /**
     * Get hubiC account Quota.
     *
     * @see https://api.hubic.com/console/
     *
     * @return ResponseInterface|null
     */
    public function getAccountQuota()
    {
        return $this->fetch('/account/usage');
    }

    /**
     * Get hubiC agreements.
     *
     * @see https://api.hubic.com/console/
     *
     * @return ResponseInterface|null
     */
    public function getAgreement()
    {
        return $this->fetch('/agreement');
    }

    /**
     * Get hubiC getAllLinks.
     *
     * @see https://api.hubic.com/console/
     *
     * @return ResponseInterface|null
     */
    public function getAllLinks()
    {
        return $this->fetch('/account/getAllLinks');
    }

    /**
     * Delete hubiC link.
     *
     * @see https://api.hubic.com/console/
     *
     * @param string $uri
     * @return ResponseInterface|null
     */
    public function deleteLink(string $uri)
    {
        $arguments = [
            'uri' => $uri
        ];

        return $this->fetch('/account/link', 'DELETE', $arguments);
    }

    /**
     * @param RequestFactory $requestFactory
     */
    public function injectRequestFactory(RequestFactory $requestFactory): void
    {
        $this->requestFactory = $requestFactory;
    }

    /**
     * @param PersistenceManager $persistenceManager
     */
    public function injectPersistenceManager(PersistenceManager $persistenceManager): void
    {
        $this->persistenceManager = $persistenceManager;
    }

    /**
     * @param AccountRepository $accountRepository
     */
    public function injectAccountRepository(AccountRepository $accountRepository): void
    {
        $this->accountRepository = $accountRepository;
    }
}


1			<?php
2			/*
3			* This program is free software: you can redistribute it and/or modify
4			* it under the terms of the GNU General Public License as published by
5			* the Free Software Foundation, either version 3 of the License, or
6			* (at your option) any later version.
7			*
8			* This program is distributed in the hope that it will be useful,
9			* but WITHOUT ANY WARRANTY; without even the implied warranty of
10			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11			* GNU General Public License for more details.
12			*
13			* You should have received a copy of the GNU General Public License
14			* along with this program. If not, see <http://www.gnu.org/licenses/>.
15			*/
16
17			namespace Filoucrackeur\Hubic\Service;
18
19			use Filoucrackeur\Hubic\Domain\Model\Account;
20			use Filoucrackeur\Hubic\Domain\Repository\AccountRepository;
21			use GuzzleHttp\RequestOptions;
22			use Psr\Http\Message\ResponseInterface;
23			use TYPO3\CMS\Core\FormProtection\FormProtectionFactory;
24			use TYPO3\CMS\Core\Http\RequestFactory;
25			use TYPO3\CMS\Core\SingletonInterface;
26			use TYPO3\CMS\Core\Utility\GeneralUtility;
27			use TYPO3\CMS\Extbase\Mvc\Web\Routing\UriBuilder;
28			use TYPO3\CMS\Extbase\Persistence\Generic\PersistenceManager;
29			use TYPO3\CMS\Extbase\Persistence\Generic\QueryResult;
30
31			class HubicService implements SingletonInterface
32			{
33			const AUTHORIZATION_ENDPOINT = 'https://api.hubic.com/oauth/auth/';
34
35			const TOKEN_ENDPOINT = 'https://api.hubic.com/oauth/token/';
36
37			const DOMAIN_API = 'https://api.hubic.com/';
38
39			const VERSION_API = '1.0';
40
41			/**
42			* @var RequestFactory
43			*/
44			protected $requestFactory;
45
46			/**
47			* @var \TYPO3\CMS\Extbase\Persistence\Generic\PersistenceManager
48			*/
49			protected $persistenceManager;
50
51			/**
52			* @var \Filoucrackeur\Hubic\Domain\Repository\AccountRepository
53			*/
54			protected $accountRepository;
55
56			/**
57			* @var \Filoucrackeur\Hubic\Domain\Model\Account
58			*/
59			protected $account;
60
61			/**
62			* @param Account $account
63			*
64			* @return bool
65			* @throws \RuntimeException
66			*/
67			public function accessToken(Account $account)
68			{
69			$credentials = base64_encode($account->getClientId() . ':' . $account->getClientSecret());
70			$additionalOptions = [
71			'headers' => [
72			'Content-Type' => 'application/x-www-form-urlencoded',
73			'Authorization' => 'Basic ' . $credentials,
74			],
75			RequestOptions::FORM_PARAMS => [
76			'code' => GeneralUtility::_GET('code'),
77			'redirect_uri' => $this->getHost() . '/',
78			'grant_type' => 'authorization_code',
79			],
80			RequestOptions::VERSION => '1.1',
81			];
82
83			$response = $this->requestFactory->request(self::TOKEN_ENDPOINT, 'POST', $additionalOptions);
84
85			if (200 === $response->getStatusCode()) {
86			$content = json_decode($response->getBody()->getContents());
87			$account->setAccessToken($content->access_token);
88			$account->setRefreshToken($content->refresh_token);
89			$expireIn = new \DateTime('+ ' . $content->expires_in . ' seconds');
90			$account->setExpirationDate($expireIn);
91			$this->persistenceManager->update($account);
92			$this->persistenceManager->persistAll();
93			}
94
95			return true;
96			}
97
98			/**
99			* @return string
100			*/
101			public function getHost(): string
102			{
103			return $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['HTTP_HOST'];
104			}
105
106			/**
107			* @param Account $account
108			*/
109			public function redirectUrlRequestToken(Account $account)
110			{
111			$arguments = [
112			'client_id' => $account->getClientId(),
113			'redirect_uri' => $this->getRedirectUri($account),
114			'scope' => $account->getScope(),
115			'response_type' => 'code',
116			'state' => time(),
117			];
118
119			$uri = self::AUTHORIZATION_ENDPOINT . '?' . urldecode(http_build_query($arguments));
120			header('Location: ' . $uri);
121			die();
122			}
123
124			/**
125			* @param Account $account
126			*
127			* @return string
128			*/
129			private function getRedirectUri(Account $account): string
130			{
131			$formProtection = FormProtectionFactory::get();
132			$formToken = $formProtection->generateToken('AuthorizationRequest');
133
134			$uriBuilder = GeneralUtility::makeInstance(UriBuilder::class);
135
136			return urlencode($this->getHost() . $uriBuilder
137			->setCreateAbsoluteUri(true)
138			->setArguments([
139			'tx_hubic_tools_hubichubic' => [
140			'action' => 'callback',
141			'controller' => 'Backend\Account',
142			'account' => $account->getUid(),
143			],
144			'formToken' => $formToken
145			])->buildBackendUri());
146			}
147
148			public function getAccount()
149			{
150			return $this->fetch('/account');
151			}
152
153			/**
154			* @param Account $account
155			*/
156			public function setAccount(Account $account)
157			{
158			$this->account = $account;
159			}
160
161			/**
162			* @param string $path
163			* @param string $method
164			* @param array $arguments
165			* @return \Psr\Http\Message\ResponseInterface\|string
166			*/
167			public function fetch(string $path, $method = 'GET', array $arguments = [])
168			{
169			$additionalOptions = [
170			'headers' => [
171			'Content-Type' => 'application/x-www-form-urlencoded',
172			'Authorization' => 'Bearer ' . $this->account->getAccessToken(),
173			],
174			RequestOptions::VERSION => '1.1',
175			];
176
177			if (!empty($arguments)) {
178			$additionalOptions[RequestOptions::FORM_PARAMS] = $arguments;
179			}
180
181			try {
182			$response = $this->requestFactory->request(self::DOMAIN_API . self::VERSION_API . $path, $method,
183			$additionalOptions);
184
185			if (200 === $response->getStatusCode()) {
186			return json_decode($response->getBody()->getContents());
187			}
188			} catch (\Exception $e) {
189			if ($this->refreshToken($this->account)) {
190			return $this->fetch($path, $method);
191			}
192			}
193			return null;
194			}
195
196			/**
197			* @param Account $account
198			* @return bool
199			*/
200			public function refreshToken(Account $account): bool
201			{
202
203			$credentials = base64_encode($account->getClientId() . ':' . $account->getClientSecret());
204			$additionalOptions = [
205			'headers' => [
206			'Content-Type' => 'application/x-www-form-urlencoded',
207			'Authorization' => 'Basic ' . $credentials,
208			],
209			RequestOptions::FORM_PARAMS => [
210			'refresh_token' => $account->getRefreshToken(),
211			'grant_type' => 'refresh_token',
212			],
213			RequestOptions::VERSION => '1.1',
214			];
215
216			$response = $this->requestFactory->request(self::TOKEN_ENDPOINT, 'POST', $additionalOptions);
217
218			if (200 === $response->getStatusCode()) {
219			$content = json_decode($response->getBody()->getContents());
220			$account->setAccessToken($content->access_token);
221			$this->persistenceManager->update($account);
222			$this->persistenceManager->persistAll();
223			}
224
225			return true;
226			}
227
228			/**
229			* @param Account $account
230			*/
231			public function delete(Account $account): void
232			{
233			$this->persistenceManager->remove($account);
234			$this->persistenceManager->persistAll();
235			}
236
237			/**
238			* @param Account $account
239			*/
240			public function unlink(Account $account): void
241			{
242			$account->setAccessToken('');
243			$account->setRefreshToken('');
244			$this->persistenceManager->update($account);
245			$this->persistenceManager->persistAll();
246			}
247
248			/**
249			* @return QueryResult\|null
250			*/
251			public function getAccounts()
252			{
253			return $this->accountRepository->findAll();
254			}
255
256			/**
257			* Get hubiC account Quota.
258			*
259			* @see https://api.hubic.com/console/
260			*
261			* @return ResponseInterface\|null
262			*/
263			public function getAccountQuota()
264			{
265			return $this->fetch('/account/usage');
266			}
267
268			/**
269			* Get hubiC agreements.
270			*
271			* @see https://api.hubic.com/console/
272			*
273			* @return ResponseInterface\|null
274			*/
275			public function getAgreement()
276			{
277			return $this->fetch('/agreement');
278			}
279
280			/**
281			* Get hubiC getAllLinks.
282			*
283			* @see https://api.hubic.com/console/
284			*
285			* @return ResponseInterface\|null
286			*/
287			public function getAllLinks()
288			{
289			return $this->fetch('/account/getAllLinks');
290			}
291
292			/**
293			* Delete hubiC link.
294			*
295			* @see https://api.hubic.com/console/
296			*
297			* @param string $uri
298			* @return ResponseInterface\|null
299			*/
300			public function deleteLink(string $uri)
301			{
302			$arguments = [
303			'uri' => $uri
304			];
305
306			return $this->fetch('/account/link', 'DELETE', $arguments);
307			}
308
309			/**
310			* @param RequestFactory $requestFactory
311			*/
312			public function injectRequestFactory(RequestFactory $requestFactory): void
313			{
314			$this->requestFactory = $requestFactory;
315			}
316
317			/**
318			* @param PersistenceManager $persistenceManager
319			*/
320			public function injectPersistenceManager(PersistenceManager $persistenceManager): void
321			{
322			$this->persistenceManager = $persistenceManager;
323			}
324
325			/**
326			* @param AccountRepository $accountRepository
327			*/
328			public function injectAccountRepository(AccountRepository $accountRepository): void
329			{
330			$this->accountRepository = $accountRepository;
331			}
332			}
333

filoucrackeur / hubic

HubicService::injectRequestFactory() A last analyzed 2018-03-18 22:31 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

HubicService::injectRequestFactory() A
last analyzed 2018-03-18 22:31 UTC