mirror of
https://github.com/flextype/flextype.git
synced 2025-08-07 13:46:42 +02:00
feat(endpoints): add Tokens endpoints #565
This commit is contained in:
Awilum
238
src/flextype/core/Endpoints/Tokens.php
Normal file
238
src/flextype/core/Endpoints/Tokens.php
Normal file
@@ -0,0 +1,238 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
/**
|
||||
* Flextype (https://flextype.org)
|
||||
* Founded by Sergey Romanenko and maintained by Flextype Community.
|
||||
*/
|
||||
|
||||
namespace Flextype\Endpoints;
|
||||
|
||||
use Psr\Http\Message\ResponseInterface;
|
||||
use Psr\Http\Message\ServerRequestInterface;
|
||||
|
||||
use function tokens;
|
||||
use function count;
|
||||
use function password_verify;
|
||||
use function registry;
|
||||
|
||||
class Tokens extends Api
|
||||
{
|
||||
/**
|
||||
* Fetch token.
|
||||
*
|
||||
* @param ServerRequestInterface $request PSR7 request.
|
||||
* @param ResponseInterface $response PSR7 response.
|
||||
*
|
||||
* @return ResponseInterface Response.
|
||||
*/
|
||||
public function fetch(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
|
||||
{
|
||||
// Get Request Query Params
|
||||
$requestQueryParams = $request->getQueryParams();
|
||||
|
||||
// Validate Api Request
|
||||
if (
|
||||
count($result = $this->validateApiRequest([
|
||||
'request' => $request,
|
||||
'api' => 'tokens',
|
||||
'params' => ['token', 'id'],
|
||||
])) > 0
|
||||
) {
|
||||
return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
|
||||
}
|
||||
|
||||
// Get token data
|
||||
$contentData = tokens()->fetch($requestQueryParams['id'], $requestQueryParams['options'] ?? [])->toArray();
|
||||
|
||||
if (count($contentData) > 0) {
|
||||
return $this->getApiResponse($response, $contentData, 200);
|
||||
}
|
||||
|
||||
return $this->getApiResponse($response, $this->getStatusCodeMessage(404), 404);
|
||||
}
|
||||
|
||||
/**
|
||||
* Create token.
|
||||
*
|
||||
* @param ServerRequestInterface $request PSR7 request.
|
||||
* @param ResponseInterface $response PSR7 response.
|
||||
*
|
||||
* @return ResponseInterface Response.
|
||||
*/
|
||||
public function create(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
|
||||
{
|
||||
// Get Request Parsed Body
|
||||
$requestParsedBody = $request->getParsedBody();
|
||||
|
||||
// Validate Api Request
|
||||
if (
|
||||
count($result = $this->validateApiRequest([
|
||||
'request' => $request,
|
||||
'api' => 'tokens',
|
||||
'params' => ['token', 'id', 'access_token'],
|
||||
])) > 0
|
||||
) {
|
||||
return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
|
||||
}
|
||||
|
||||
// Create new token
|
||||
tokens()->create($requestParsedBody['id'], $requestParsedBody['data'] ?? []);
|
||||
|
||||
// Fetch token
|
||||
$contentData = tokens()->fetch($requestParsedBody['id'])->toArray();
|
||||
|
||||
// Return response
|
||||
if (count($contentData) > 0) {
|
||||
return $this->getApiResponse($response, $contentData, 200);
|
||||
}
|
||||
|
||||
return $this->getApiResponse($response, [], 404);
|
||||
}
|
||||
|
||||
/**
|
||||
* Update token.
|
||||
*
|
||||
* @param ServerRequestInterface $request PSR7 request.
|
||||
* @param ResponseInterface $response PSR7 response.
|
||||
*
|
||||
* @return ResponseInterface Response.
|
||||
*/
|
||||
public function update(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
|
||||
{
|
||||
// Get Request Parsed Body
|
||||
$requestParsedBody = $request->getParsedBody();
|
||||
|
||||
// Validate Api Request
|
||||
if (
|
||||
count($result = $this->validateApiRequest([
|
||||
'request' => $request,
|
||||
'api' => 'tokens',
|
||||
'params' => ['token', 'id', 'access_token'],
|
||||
])) > 0
|
||||
) {
|
||||
return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
|
||||
}
|
||||
|
||||
// Update token
|
||||
tokens()->update($requestParsedBody['id'], $requestParsedBody['data'] ?? []);
|
||||
|
||||
// Fetch token
|
||||
$contentData = tokens()->fetch($requestParsedBody['id'])->toArray();
|
||||
|
||||
// Return response
|
||||
if (count($contentData) > 0) {
|
||||
return $this->getApiResponse($response, $contentData, 200);
|
||||
}
|
||||
|
||||
return $this->getApiResponse($response, [], 404);
|
||||
}
|
||||
|
||||
/**
|
||||
* Move token.
|
||||
*
|
||||
* @param ServerRequestInterface $request PSR7 request.
|
||||
* @param ResponseInterface $response PSR7 response.
|
||||
*
|
||||
* @return ResponseInterface Response.
|
||||
*/
|
||||
public function move(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
|
||||
{
|
||||
// Get Request Parsed Body
|
||||
$requestParsedBody = $request->getParsedBody();
|
||||
|
||||
// Validate Api Request
|
||||
if (
|
||||
count($result = $this->validateApiRequest([
|
||||
'request' => $request,
|
||||
'api' => 'tokens',
|
||||
'params' => ['token', 'id', 'new_id', 'access_token'],
|
||||
])) > 0
|
||||
) {
|
||||
return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
|
||||
}
|
||||
|
||||
// Move token
|
||||
tokens()->move($requestParsedBody['id'], $requestParsedBody['new_id']);
|
||||
|
||||
// Fetch token
|
||||
$contentData = tokens()->fetch($requestParsedBody['new_id'])->toArray();
|
||||
|
||||
// Return response
|
||||
if (count($contentData) > 0) {
|
||||
return $this->getApiResponse($response, $contentData, 200);
|
||||
}
|
||||
|
||||
return $this->getApiResponse($response, [], 404);
|
||||
}
|
||||
|
||||
/**
|
||||
* Copy token.
|
||||
*
|
||||
* @param ServerRequestInterface $request PSR7 request.
|
||||
* @param ResponseInterface $response PSR7 response.
|
||||
*
|
||||
* @return ResponseInterface Response.
|
||||
*/
|
||||
public function copy(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
|
||||
{
|
||||
// Get Request Parsed Body
|
||||
$requestParsedBody = $request->getParsedBody();
|
||||
|
||||
// Validate Api Request
|
||||
if (
|
||||
count($result = $this->validateApiRequest([
|
||||
'request' => $request,
|
||||
'api' => 'tokens',
|
||||
'params' => ['token', 'id', 'new_id', 'access_token'],
|
||||
])) > 0
|
||||
) {
|
||||
return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
|
||||
}
|
||||
|
||||
// Copy token
|
||||
tokens()->copy($requestParsedBody['id'], $requestParsedBody['new_id']);
|
||||
|
||||
// Fetch token
|
||||
$contentData = tokens()->fetch($requestParsedBody['new_id'])->toArray();
|
||||
|
||||
// Return response
|
||||
if (count($contentData) > 0) {
|
||||
return $this->getApiResponse($response, $contentData, 200);
|
||||
}
|
||||
|
||||
return $this->getApiResponse($response, [], 404);
|
||||
}
|
||||
|
||||
/**
|
||||
* Delete token.
|
||||
*
|
||||
* @param ServerRequestInterface $request PSR7 request.
|
||||
* @param ResponseInterface $response PSR7 response.
|
||||
*
|
||||
* @return ResponseInterface Response.
|
||||
*/
|
||||
public function delete(ServerRequestInterface $request, ResponseInterface $response): ResponseInterface
|
||||
{
|
||||
// Get Request Parsed Body
|
||||
$requestParsedBody = $request->getParsedBody();
|
||||
|
||||
// Validate Api Request
|
||||
if (
|
||||
count($result = $this->validateApiRequest([
|
||||
'request' => $request,
|
||||
'api' => 'tokens',
|
||||
'params' => ['token', 'id', 'access_token'],
|
||||
])) > 0
|
||||
) {
|
||||
return $this->getApiResponse($response, $this->getStatusCodeMessage($result['http_status_code']), $result['http_status_code']);
|
||||
}
|
||||
|
||||
// Copy token
|
||||
tokens()->delete($requestParsedBody['id']);
|
||||
|
||||
// Return success response
|
||||
return $this->getApiResponse($response, [], 204);
|
||||
}
|
||||
}
|
||||
106
src/flextype/routes/endpoints/tokens.php
Normal file
106
src/flextype/routes/endpoints/tokens.php
Normal file
@@ -0,0 +1,106 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
/**
|
||||
* Flextype (https://flextype.org)
|
||||
* Founded by Sergey Romanenko and maintained by Flextype Community.
|
||||
*/
|
||||
|
||||
namespace Flextype;
|
||||
|
||||
use Flextype\Endpoints\Tokens;
|
||||
|
||||
/**
|
||||
* Fetch token
|
||||
*
|
||||
* endpoint: GET /api/tokens
|
||||
*
|
||||
* Query:
|
||||
* id - [REQUIRED] - Unique identifier of the token.
|
||||
* token - [REQUIRED] - Valid public token.
|
||||
* options - [OPTIONAL] - Select items in collection by given conditions.
|
||||
*
|
||||
* Returns:
|
||||
* An array of token objects.
|
||||
*/
|
||||
app()->get('/api/tokens', [Tokens::class, 'fetch']);
|
||||
|
||||
/**
|
||||
* Create token
|
||||
*
|
||||
* endpoint: POST /api/tokens
|
||||
*
|
||||
* Body:
|
||||
* id - [REQUIRED] - Unique identifier of the token.
|
||||
* token - [REQUIRED] - Valid public token.
|
||||
* access_token - [REQUIRED] - Valid access token.
|
||||
* data - [REQUIRED] - Data to store for the token.
|
||||
*
|
||||
* Returns:
|
||||
* Returns the token object for the token that was just created.
|
||||
*/
|
||||
app()->post('/api/tokens', [Tokens::class, 'create']);
|
||||
|
||||
/**
|
||||
* Update token
|
||||
*
|
||||
* endpoint: PATCH /api/tokens
|
||||
*
|
||||
* Body:
|
||||
* id - [REQUIRED] - Unique identifier of the token.
|
||||
* token - [REQUIRED] - Valid public token.
|
||||
* access_token - [REQUIRED] - Valid access token.
|
||||
* data - [REQUIRED] - Data to update for the token.
|
||||
*
|
||||
* Returns:
|
||||
* Returns the token object for the token that was just updated.
|
||||
*/
|
||||
app()->patch('/api/tokens', [Tokens::class, 'update']);
|
||||
|
||||
/**
|
||||
* Move token
|
||||
*
|
||||
* endpoint: PUT /api/tokens
|
||||
*
|
||||
* Body:
|
||||
* id - [REQUIRED] - Unique identifier of the token.
|
||||
* new_id - [REQUIRED] - New Unique identifier of the token.
|
||||
* token - [REQUIRED] - Valid public token.
|
||||
* access_token - [REQUIRED] - Valid access token.
|
||||
*
|
||||
* Returns:
|
||||
* Returns the token object for the token that was just moved.
|
||||
*/
|
||||
app()->put('/api/tokens', [Tokens::class, 'move']);
|
||||
|
||||
/**
|
||||
* Copy token
|
||||
*
|
||||
* endpoint: PUT /api/tokens/copy
|
||||
*
|
||||
* Body:
|
||||
* id - [REQUIRED] - Unique identifier of the token.
|
||||
* new_id - [REQUIRED] - New Unique identifier of the token.
|
||||
* token - [REQUIRED] - Valid public token.
|
||||
* access_token - [REQUIRED] - Valid access token.
|
||||
*
|
||||
* Returns:
|
||||
* Returns the token object for the token that was just copied.
|
||||
*/
|
||||
app()->put('/api/tokens/copy', [Tokens::class, 'copy']);
|
||||
|
||||
/**
|
||||
* Delete token
|
||||
*
|
||||
* endpoint: DELETE /api/tokens
|
||||
*
|
||||
* Body:
|
||||
* id - [REQUIRED] - Unique identifier of the token.
|
||||
* token - [REQUIRED] - Valid pulbic token.
|
||||
* access_token - [REQUIRED] - Valid access token.
|
||||
*
|
||||
* Returns:
|
||||
* Returns an empty body with HTTP status 204
|
||||
*/
|
||||
app()->delete('/api/tokens', [Tokens::class, 'delete']);
|
||||
Reference in New Issue
Block a user