mirror/php-flextype
1
0
Fork 0
mirror of https://github.com/flextype/flextype.git synced 2025-08-07 21:56:33 +02:00
Code Issues Releases Wiki Activity

feat(endpoints): add Utils Endpoints class #565

Browse Source
This commit is contained in:
Awilum
2021-08-10 12:03:18 +03:00
parent 9b05413b7f
commit 3aea945547
1 changed files with 45 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

100
src/flextype/core/Endpoints/utils.php
View File

@@ -7,69 +7,59 @@ declare(strict_types=1);
* Founded by Sergey Romanenko and maintained by Flextype Community.
*/
namespace Flextype;
namespace Flextype\Endpoints;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Flextype\Endpoints\Endpoints;
use function array_replace_recursive;
use function filesystem;
use function flextype;
/**
* Clear cache
*
* endpoint: POST /api/utils/cache/clear
*
* Body:
* token - [REQUIRED] - Valid public token.
* access_token - [REQUIRED] - Valid access token.
*
* Returns:
* Returns an empty body with HTTP status 204
*/
app()->post('/api/utils/cache/clear', function (ServerRequestInterface $request, ResponseInterface $response) {
class Utils extends Endpoints
{
public function clearCache(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
{
// Get Query Params
$data = $request->getParsedBody();
// Get Query Params
$data = $request->getParsedBody();
// Check is utils api enabled
if (! registry()->get('flextype.settings.api.utils.enabled')) {
return $this->getApiResponse($response, $this->statusCodeMessages['400'], 400);
}
// Check is utils api enabled
if (! registry()->get('flextype.settings.api.utils.enabled')) {
return getApiResponseWithError($response, 400);
// Check is token param exists
if (! isset($data['token'])) {
return $this->getApiResponse($response, $this->statusCodeMessages['400'], 400);
}
// Check is token exists
if (! tokens()->has($data['token'])) {
return $this->getApiResponse($response, $this->statusCodeMessages['401'], 401);
}
// Fetch token
$tokenData = tokens()->fetch($data['token']);
// Verify access token
if (password_verify($tokenData['hashed_access_token'], $data['access_token'])) {
return $this->getApiResponse($response, $this->statusCodeMessages['401'], 401);
}
// Check token state and limit_calls
if ($tokenData['state'] === 'disabled' ||
($tokenData['limit_calls'] !== 0 && $tokenData['calls'] >= $tokenData['limit_calls'])) {
return $this->getApiResponse($response, $this->statusCodeMessages['400'], 400);
}
// Update token calls
tokens()->update($data['token'], ['calls' => $tokenData['calls'] + 1]);
// Clear cache
filesystem()->directory(PATH['tmp'])->delete();
// Return success response
return $this->getApiResponse($response, [], 204);
}
// Check is token param exists
if (! isset($data['token'])) {
return getApiResponseWithError($response, 400);
}
// Check is token exists
if (! tokens()->has($data['token'])) {
return getApiResponseWithError($response, 401);
}
// Fetch token
$tokenData = tokens()->fetch($data['token']);
// Verify access token
if (password_verify($tokenData['hashed_access_token'], $data['access_token'])) {
return getApiResponseWithError($response, 401);
}
// Check token state and limit_calls
if ($tokenData['state'] === 'disabled' ||
($tokenData['limit_calls'] !== 0 && $tokenData['calls'] >= $tokenData['limit_calls'])) {
return getApiResponseWithError($response, 400);
}
// Update token calls
tokens()->update($data['token'], ['calls' => $tokenData['calls'] + 1]);
// Clear cache
filesystem()->directory(PATH['tmp'])->delete();
// Return success response
$response->withStatus(204);
$response->withHeader('Content-Type', 'application/json;charset=' . registry()->get('flextype.settings.charset'));
return $response;
});
}