diff --git a/src/Controller/RequestController.php b/src/Controller/RequestController.php index 34f22bf..e09c944 100644 --- a/src/Controller/RequestController.php +++ b/src/Controller/RequestController.php @@ -9,6 +9,9 @@ use App\Repository\ApikeyRepository; use App\Repository\DomainRepository; use DI\Container; use DI\ContainerBuilder; +use Monolog\Formatter\LineFormatter; +use Monolog\Handler\StreamHandler; +use Monolog\Logger; use OpenApi\Generator; use UnhandledMatchError; use function DI\autowire; @@ -45,6 +48,8 @@ use OpenApi\Attributes as OAT; )] class RequestController { + private Logger $log; + //private DatabaseConnection $databaseConnection; private DomainRepository $domainRepository; private ApikeyRepository $apikeyRepository; @@ -65,9 +70,25 @@ class RequestController { $this->requestMethod = strtoupper(string: $requestMethod); + + $dateFormat = "Y:m:d H:i:s"; + $output = "%datetime% %channel%.%level_name% %message%\n"; // %context% %extra% + $formatter = new LineFormatter(format: $output, dateFormat: $dateFormat); + + $stream = new StreamHandler(stream: dirname(path: __DIR__, levels: 2) . '/bindAPI.log'); + $stream->setFormatter(formatter: $formatter); + + $this->log = new Logger(name: 'bindAPI'); + $this->log->pushHandler(handler: $stream); + + $containerBuilder = new ContainerBuilder(); $containerBuilder->addDefinitions([ DatabaseConnection::class => autowire()->constructorParameter(parameter: 'config', value: $this->config), + DomainRepository::class => autowire() + ->constructorParameter(parameter: 'config', value: $this->config) + ->constructorParameter(parameter: 'log', value: $this->log), + ]); $this->container = $containerBuilder->build(); @@ -112,11 +133,9 @@ class RequestController $resultDomain = []; foreach ($domains as $singleDomain) { $domain = [ - 'id' => $singleDomain->getId(), - 'name' => $singleDomain->getName(), - 'panel_id' => $singleDomain->getPanelId(), - 'a' => $singleDomain->getA(), - 'aaaa' => $singleDomain->getAaaa() + 'id' => $singleDomain->getId(), + 'name' => $singleDomain->getName(), + 'content' => json_decode(json: $singleDomain->getContent()) ]; $resultDomain[] = $domain; } @@ -292,16 +311,12 @@ class RequestController */ public function handleDomainGetRequest(): void { - if (empty($this->uri[3])) { - $this->handleAllDomainsGetRequest(); - } else { - if ($result = $this->domainRepository->findById(id: $this->uri[3])) { + if ($this->uri[3] == 'name') { + if ($result = $this->domainRepository->findByName(name: $this->uri[4])) { $domain = [ - 'id' => $result->getId(), - 'name' => $result->getName(), - 'panel_id' => $result->getPanelId(), - 'a' => $result->getA(), - 'aaaa' => $result->getAaaa() + 'id' => $result->getId(), + 'name' => $result->getName(), + 'content' => json_decode(json: $result->getContent()) ]; $this->result = $domain; } else { @@ -309,127 +324,142 @@ class RequestController $this->status = "404 Not Found "; $this->message = "The specified domain was not found."; } - } - } - - - /** - * @return void - */ - public function handleDomainPostRequest(): void - { - $name = $_POST['name'] ?? ''; - $panelID = intval(value: $_POST['panel_id'] ?? 0); - $a = $_POST['a'] ?? ''; - $aaaa = $_POST['aaaa'] ?? ''; - if (empty($name)) { - $this->header = "400 Bad Request"; - $this->status = "400 Bad Request"; - $this->message = "A name is required"; } else { - if (empty($a) && empty($aaaa) && empty($panelID)) { - $this->header = "400 Bad Request"; - $this->status = "400 Bad Request"; - $this->message = "At least one IP address or panel ID is required."; + if (empty($this->uri[3])) { + $this->handleAllDomainsGetRequest(); } else { - if ($this->domainRepository->findByName(name: $name)) { - $this->header = "400 Bad request"; - $this->status = "400 Bad request"; - $this->message = "Domain: $name already exists."; + if ($result = $this->domainRepository->findById(id: $this->uri[3])) { + $domain = [ + 'id' => $result->getId(), + 'name' => $result->getName(), + 'content' => json_decode(json: $result->getContent()) + ]; + $this->result = $domain; } else { - $domain = new Domain(name: $name, panelID: $panelID, a: $a, aaaa: $aaaa); - $result = $this->domainRepository->insert(domain: $domain); - $this->status = "201 Created"; - $this->message = $result; + $this->header = "404 Not Found "; + $this->status = "404 Not Found "; + $this->message = "The specified domain was not found."; } } } } - - - /** - * @return void - */ - public - function handleDomainPutRequest(): void - { - $putData = fopen(filename: 'php://input', mode: 'r'); - $data = fread(stream: $putData, length: 512); - $params = explode(separator: '&', string: $data); - foreach ($params as $param) { - [$key, $value] = explode(separator: '=', string: $param); - $put[$key] = $value; - } - $id = $put['id'] ?? 0; - $name = $put['name'] ?? ''; - $panelID = $put['panel_id'] ?? ""; - $a = $put['a'] ?? ""; - $aaaa = $put['aaaa'] ?? ""; - if ($id == 0) { - $this->status = "400 Bad Request"; - $this->message = "An ID is required"; - } else { - if (!$this->domainRepository->findByID(id: $id)) { - $this->status = "404 Not Found"; - $this->message = "Domain with ID : $id doesn't exist."; + /** + * @return void + */ + public + function handleDomainPostRequest(): void + { + $name = $_POST['name'] ?? ''; + $panelID = intval(value: $_POST['panel_id'] ?? 0); + $content = $_POST['content'] ?? ''; + if (empty($name)) { + $this->header = "400 Bad Request"; + $this->status = "400 Bad Request"; + $this->message = "A name is required"; } else { - // TODO not required, as we rely on the ID - if (empty($name)) { + if (empty($a) && empty($aaaa) && empty($panelID)) { + $this->header = "400 Bad Request"; $this->status = "400 Bad Request"; - $this->message = "A name is required"; + $this->message = "At least one IP address or panel ID is required."; } else { - if (empty($a) && empty($aaaa)) { - $this->status = "400 Bad Request"; - $this->message = "At least one IP address is required."; + if ($this->domainRepository->findByName(name: $name)) { + $this->header = "400 Bad request"; + $this->status = "400 Bad request"; + $this->message = "Domain: $name already exists."; } else { - $domain = new Domain(name: $panelID, id: $id, panelID: $name, a: $a, aaaa: $aaaa); - $this->domainRepository->update(domain: $domain); - $this->header = "201 Updated"; - $this->status = "201 Updated"; - $this->message = "201 Updated"; + $domain = new Domain(name: $name, content: $content); + $result = $this->domainRepository->insert(domain: $domain); + $this->status = "201 Created"; + $this->message = $result; } } } } - } - - - /** - * @return void - */ - public - function handleDomainDeleteRequest(): void - { - $deleteData = fopen(filename: 'php://input', mode: 'r'); - $data = fread(stream: $deleteData, length: 512); - $params = explode(separator: '&', string: $data); - foreach ($params as $param) { - [$key, $value] = explode(separator: '=', string: $param); - $delete[$key] = $value; - } - $id = $delete['id'] ?? 0; - - if ($id == 0) { - $this->header = "400 Bad Request"; - $this->status = "400 Bad Request"; - $this->message = "You need to supply an ID."; - } else { + /** + * @return void + */ + public + function handleDomainPutRequest(): void + { + $putData = fopen(filename: 'php://input', mode: 'r'); + $data = fread(stream: $putData, length: 512); + $params = explode(separator: '&', string: $data); - if (!$domain = $this->domainRepository->findByID(id: $id)) { - $this->header = "400 Bad Request"; + foreach ($params as $param) { + [$key, $value] = explode(separator: '=', string: $param); + $put[$key] = $value; + } + $id = $put['id'] ?? 0; + $name = $put['name'] ?? ''; + $content = $put['content'] ?? ""; + + if ($id == 0) { $this->status = "400 Bad Request"; - $this->message = "There is no domain with ID $id."; + $this->message = "An ID is required"; } else { - $this->domainRepository->delete(domain: $domain); - $this->header = "204 No content."; - $this->status = "204 No content."; - $this->message = "The domain $id has been deleted."; + if (!$this->domainRepository->findByID(id: $id)) { + $this->status = "404 Not Found"; + $this->message = "Domain with ID : $id doesn't exist."; + } else { + // TODO not required, as we rely on the ID + if (empty($name)) { + $this->status = "400 Bad Request"; + $this->message = "A name is required"; + } else { + if (empty($a) && empty($aaaa)) { + $this->status = "400 Bad Request"; + $this->message = "At least one IP address is required."; + } else { + $domain = new Domain(name: $name, id: $id, content: $content); + $this->domainRepository->update(domain: $domain); + $this->header = "201 Updated"; + $this->status = "201 Updated"; + $this->message = "201 Updated"; + } + } + } } } + + + /** + * @return void + */ + public + function handleDomainDeleteRequest(): void + { + $deleteData = fopen(filename: 'php://input', mode: 'r'); + $data = fread(stream: $deleteData, length: 512); + $params = explode(separator: '&', string: $data); + + foreach ($params as $param) { + [$key, $value] = explode(separator: '=', string: $param); + $delete[$key] = $value; + } + + $id = $delete['id'] ?? 0; + + if ($id == 0) { + $this->header = "400 Bad Request"; + $this->status = "400 Bad Request"; + $this->message = "You need to supply an ID."; + } else { + + if (!$domain = $this->domainRepository->findByID(id: $id)) { + $this->header = "400 Bad Request"; + $this->status = "400 Bad Request"; + $this->message = "There is no domain with ID $id."; + } else { + $this->domainRepository->delete(domain: $domain); + $this->header = "204 No content."; + $this->status = "204 No content."; + $this->message = "The domain $id has been deleted."; + } + } + } + } - -}