Added backend search using API

2024-04-26 15:50:32 +03:00
parent 8c1c6b61f5
commit e7291fc886
1 changed files with 78 additions and 0 deletions
--- a/src/API/Backends/Search.php
+++ b/src/API/Backends/Search.php
@@ -0,0 +1,78 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\API\Backends;
+
+use App\Libs\Attributes\Route\Get;
+use App\Libs\DataUtil;
+use App\Libs\Exceptions\RuntimeException;
+use App\Libs\HTTP_STATUS;
+use App\Libs\Options;
+use App\Libs\Traits\APITraits;
+use Psr\Http\Message\ResponseInterface as iResponse;
+use Psr\Http\Message\ServerRequestInterface as iRequest;
+
+final class Search
+{
+    use APITraits;
+
+    #[Get(Index::URL . '/{name:backend}/search[/[{id}[/]]]', name: 'backends.backend.search.id')]
+    public function searchById(iRequest $request, array $args = []): iResponse
+    {
+        if (null === ($name = ag($args, 'name'))) {
+            return api_error('Invalid value for name path parameter.', HTTP_STATUS::HTTP_BAD_REQUEST);
+        }
+
+        $params = DataUtil::fromRequest($request, true);
+
+        $id = ag($args, 'id', $params->get('id', null));
+        $query = $params->get('query', null);
+
+        if (null === $id && null === $query) {
+            return api_error('No search id or query string was provided.', HTTP_STATUS::HTTP_BAD_REQUEST);
+        }
+
+        try {
+            $backend = $this->getClient(name: $name);
+        } catch (RuntimeException $e) {
+            return api_error($e->getMessage(), HTTP_STATUS::HTTP_NOT_FOUND);
+        }
+
+        if (null !== $id) {
+            $data = $backend->searchId($id, [Options::RAW_RESPONSE => (bool)$params->get('raw', false)]);
+        } else {
+            $data = $backend->search(
+                query: $query,
+                limit: (int)$params->get('limit', 25),
+                opts: [Options::RAW_RESPONSE => (bool)$params->get('raw', false)]
+            );
+        }
+
+        if (count($data) < 1) {
+            return api_error(r("No results are found for '{query}'.", [
+                'query' => $id ?? $query
+            ]), HTTP_STATUS::HTTP_NOT_FOUND);
+        }
+
+        $apiUrl = $request->getUri()->withHost('')->withPort(0)->withScheme('');
+        $response = [
+            'results' => $id ? [$data] : $data,
+            'links' => [
+                'self' => (string)$apiUrl,
+                'backend' => (string)$apiUrl->withPath(parseConfigValue(Index::URL . '/' . $name)),
+                'list' => (string)$apiUrl->withPath(parseConfigValue(Index::URL)),
+            ],
+            'options' => [
+                'raw' => (bool)$params->get('raw', false),
+            ],
+        ];
+
+        if (null === $id && $query) {
+            $response['options']['limit'] = (int)$params->get('limit', 25);
+        }
+
+        return api_response(HTTP_STATUS::HTTP_OK, $response);
+    }
+
+}