You've already forked Traefik-Redis-Api
66 lines
2.0 KiB
PHP
66 lines
2.0 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace Siteworxpro\App\Controllers;
|
|
|
|
use Nyholm\Psr7\ServerRequest;
|
|
use Psr\Http\Message\ResponseInterface;
|
|
use Siteworxpro\App\Http\JsonResponseFactory;
|
|
use Siteworxpro\App\Services\Facades\RedisClient;
|
|
use Siteworxpro\App\Traefik\EntityEnum;
|
|
|
|
class MiddlewaresController extends Controller
|
|
{
|
|
/**
|
|
* @throws \JsonException
|
|
*/
|
|
public function get(ServerRequest $request): ResponseInterface
|
|
{
|
|
if ($request->getAttribute('id') !== null) {
|
|
$name = $request->getAttribute('id');
|
|
|
|
return JsonResponseFactory::createJsonResponse(
|
|
RedisClient::getMiddleware($name, $this->protocolEnumFromRequest($request))
|
|
);
|
|
}
|
|
|
|
return JsonResponseFactory::createJsonResponse(
|
|
RedisClient::getAllMiddlewares($this->protocolEnumFromRequest($request))
|
|
);
|
|
}
|
|
|
|
/**
|
|
* @throws \JsonException
|
|
*/
|
|
public function post(ServerRequest $request): ResponseInterface
|
|
{
|
|
$name = $request->getAttribute('id');
|
|
$data = $request->getParsedBody();
|
|
|
|
if (empty($data)) {
|
|
return JsonResponseFactory::createJsonResponse(['error' => 'Middleware is invalid'], 400);
|
|
}
|
|
|
|
RedisClient::createOrReplace($name, $data, EntityEnum::MIDDLEWARE, $this->protocolEnumFromRequest($request));
|
|
|
|
return JsonResponseFactory::createJsonResponse(['message' => 'Middleware added successfully']);
|
|
}
|
|
|
|
/**
|
|
* @throws \JsonException
|
|
*/
|
|
public function delete(ServerRequest $request): ResponseInterface
|
|
{
|
|
$name = $request->getAttribute('id');
|
|
|
|
if (empty($name)) {
|
|
return JsonResponseFactory::createJsonResponse(['error' => 'Middleware is invalid'], 400);
|
|
}
|
|
|
|
RedisClient::deleteAllKeys($name, EntityEnum::MIDDLEWARE, $this->protocolEnumFromRequest($request));
|
|
|
|
return JsonResponseFactory::createJsonResponse(['message' => 'Middleware deleted successfully']);
|
|
}
|
|
}
|