{
"tool_response": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/AI\/QdrantService.php",
"oldString": " \/**\n * Checks if the Qdrant API is available and responding.",
"newString": " \/**\n * Lists all available collections in Qdrant.\n *\n * Retrieves a list of all collection names from the Qdrant database.\n * Returns an empty array if Qdrant is not available or on error.\n *\n * @return array<int, string> Array of collection names\n *\n * @example\n * $service = new QdrantService();\n * $collections = $service->listCollections();\n * \/\/ Returns: ['documents', 'mail', 'entities']\n *\/\n public function listCollections(): array\n {\n $url = $this->host . '\/collections';\n\n try {\n $ch = curl_init($url);\n\n if ($ch === false) {\n return [];\n }\n\n curl_setopt_array($ch, [\n CURLOPT_RETURNTRANSFER => true,\n CURLOPT_TIMEOUT => self::HEALTH_CHECK_TIMEOUT,\n CURLOPT_CONNECTTIMEOUT => self::HEALTH_CHECK_TIMEOUT,\n CURLOPT_HTTPHEADER => ['Content-Type: application\/json'],\n CURLOPT_CUSTOMREQUEST => 'GET',\n ]);\n\n $result = curl_exec($ch);\n $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);\n\n curl_close($ch);\n\n if ($result === false || $httpCode !== 200) {\n return [];\n }\n\n $decoded = json_decode((string) $result, true);\n\n if (!is_array($decoded) || !isset($decoded['result']['collections'])) {\n return [];\n }\n\n $collections = [];\n foreach ($decoded['result']['collections'] as $collection) {\n if (is_array($collection) && isset($collection['name'])) {\n $collections[] = (string) $collection['name'];\n }\n }\n\n sort($collections);\n\n return $collections;\n } catch (\\Throwable) {\n return [];\n }\n }\n\n \/**\n * Checks if the Qdrant API is available and responding.",
"originalFile": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\AI;\n\nuse RuntimeException;\n\n\/**\n * Service for interacting with Qdrant vector database API.\n *\n * Provides methods to:\n * - Search for similar vectors in collections\n * - Check collection existence and availability\n * - Retrieve collection metadata and information\n * - Perform health checks on the Qdrant service\n *\n * This service uses cURL for HTTP requests without external dependencies.\n * All methods include proper timeout handling and exception management.\n *\n * @package Infrastructure\\AI\n * @author System Generated\n * @version 1.0.0\n *\/\nfinal readonly class QdrantService\n{\n \/**\n * Default timeout for HTTP requests in seconds.\n *\/\n private const int DEFAULT_TIMEOUT = 30;\n\n \/**\n * Health check timeout in seconds.\n *\/\n private const int HEALTH_CHECK_TIMEOUT = 5;\n\n \/**\n * Constructs a new QdrantService instance.\n *\n * @param string $host The Qdrant API host URL (default: http:\/\/localhost:6333)\n *\/\n public function __construct(\n private string $host = 'http:\/\/localhost:6333'\n ) {\n }\n\n \/**\n * Searches for similar vectors in a Qdrant collection.\n *\n * Performs a vector similarity search using the provided embedding vector.\n * Returns the most similar points from the collection based on cosine distance.\n *\n * @param array<int, float> $vector The query embedding vector\n * @param string $collection The collection name to search in (default: documents)\n * @param int $limit Maximum number of results to return (default: 5)\n *\n * @return array<int, array{id: int|string, score: float, payload: array<string, mixed>}> Array of search results with scores and payloads\n *\n * @throws RuntimeException If the API request fails or returns invalid data\n *\n * @example\n * $service = new QdrantService();\n * $vector = [0.123, -0.456, 0.789, ...]; \/\/ 1024-dimensional vector\n * $results = $service->search($vector, 'documents', 5);\n * \/\/ Returns: [\n * \/\/ ['id' => 1, 'score' => 0.89, 'payload' => ['content' => '...', 'title' => '...']],\n * \/\/ ['id' => 2, 'score' => 0.76, 'payload' => ['content' => '...', 'title' => '...']]\n * \/\/ ]\n *\/\n public function search(array $vector, string $collection = 'documents', int $limit = 5): array\n {\n $url = sprintf('%s\/collections\/%s\/points\/search', $this->host, urlencode($collection));\n\n $payload = [\n 'vector' => array_values($vector),\n 'limit' => $limit,\n 'with_payload' => true,\n ];\n\n $response = $this->makeRequest($url, $payload, self::DEFAULT_TIMEOUT);\n\n if (!isset($response['result']) || !is_array($response['result'])) {\n throw new RuntimeException('Invalid search response from Qdrant API');\n }\n\n return array_map(\n static function (mixed $item): array {\n if (!is_array($item)) {\n throw new RuntimeException('Invalid search result item format');\n }\n\n return [\n 'id' => $item['id'] ?? throw new RuntimeException('Missing id in search result'),\n 'score' => (float) ($item['score'] ?? throw new RuntimeException('Missing score in search result')),\n 'payload' => is_array($item['payload'] ?? null) ? $item['payload'] : [],\n ];\n },\n $response['result']\n );\n }\n\n \/**\n * Checks if a collection exists in Qdrant.\n *\n * Verifies the existence of a specific collection by attempting to retrieve\n * its information. This is useful before performing searches or operations.\n *\n * @param string $collection The collection name to check\n *\n * @return bool True if the collection exists, false otherwise\n *\n * @example\n * $service = new QdrantService();\n * if ($service->collectionExists('documents')) {\n * echo \"Collection exists\";\n * } else {\n * echo \"Collection not found\";\n * }\n *\/\n public function collectionExists(string $collection): bool\n {\n $url = sprintf('%s\/collections\/%s', $this->host, urlencode($collection));\n\n try {\n $ch = curl_init($url);\n\n if ($ch === false) {\n return false;\n }\n\n curl_setopt_array($ch, [\n CURLOPT_RETURNTRANSFER => true,\n CURLOPT_TIMEOUT => self::HEALTH_CHECK_TIMEOUT,\n CURLOPT_CONNECTTIMEOUT => self::HEALTH_CHECK_TIMEOUT,\n CURLOPT_HTTPHEADER => ['Content-Type: application\/json'],\n CURLOPT_CUSTOMREQUEST => 'GET',\n ]);\n\n $result = curl_exec($ch);\n $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);\n\n curl_close($ch);\n\n return $result !== false && $httpCode === 200;\n } catch (\\Throwable) {\n return false;\n }\n }\n\n \/**\n * Checks if the Qdrant API is available and responding.\n *\n * Performs a health check by querying the Qdrant root endpoint.\n * This is a quick operation with a short timeout.\n *\n * @return bool True if the API is available, false otherwise\n *\n * @example\n * $service = new QdrantService();\n * if ($service->isAvailable()) {\n * echo \"Qdrant is running\";\n * } else {\n * echo \"Qdrant is not available\";\n * }\n *\/\n public function isAvailable(): bool\n {\n $url = $this->host . '\/';\n\n try {\n $ch = curl_init($url);\n\n if ($ch === false) {\n return false;\n }\n\n curl_setopt_array($ch, [\n CURLOPT_RETURNTRANSFER => true,\n CURLOPT_TIMEOUT => self::HEALTH_CHECK_TIMEOUT,\n CURLOPT_CONNECTTIMEOUT => self::HEALTH_CHECK_TIMEOUT,\n CURLOPT_HTTPHEADER => ['Content-Type: application\/json'],\n ]);\n\n $result = curl_exec($ch);\n $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);\n\n curl_close($ch);\n\n return $result !== false && $httpCode === 200;\n } catch (\\Throwable) {\n return false;\n }\n }\n\n \/**\n * Retrieves metadata and information about a collection.\n *\n * Fetches detailed information about a specific collection including\n * vector size, distance metric, number of points, and other metadata.\n *\n * @param string $collection The collection name to query\n *\n * @return array<string, mixed>|null The collection information array, or null if collection does not exist\n *\n * @throws RuntimeException If the API request fails (excluding 404)\n *\n * @example\n * $service = new QdrantService();\n * $info = $service->getCollectionInfo('documents');\n * \/\/ Returns: [\n * \/\/ 'status' => 'green',\n * \/\/ 'vectors_count' => 1234,\n * \/\/ 'points_count' => 1234,\n * \/\/ 'config' => ['params' => ['vectors' => ['size' => 1024, 'distance' => 'Cosine']]]\n * \/\/ ]\n *\/\n public function getCollectionInfo(string $collection): ?array\n {\n $url = sprintf('%s\/collections\/%s', $this->host, urlencode($collection));\n\n try {\n $ch = curl_init($url);\n\n if ($ch === false) {\n throw new RuntimeException('Failed to initialize cURL');\n }\n\n curl_setopt_array($ch, [\n CURLOPT_RETURNTRANSFER => true,\n CURLOPT_TIMEOUT => self::DEFAULT_TIMEOUT,\n CURLOPT_CONNECTTIMEOUT => 10,\n CURLOPT_HTTPHEADER => ['Content-Type: application\/json'],\n CURLOPT_CUSTOMREQUEST => 'GET',\n ]);\n\n $result = curl_exec($ch);\n $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);\n $curlError = curl_error($ch);\n\n curl_close($ch);\n\n if ($result === false) {\n throw new RuntimeException(\n sprintf('cURL request failed: %s', $curlError !== '' ? $curlError : 'Unknown error')\n );\n }\n\n if ($httpCode === 404) {\n return null;\n }\n\n if ($httpCode !== 200) {\n throw new RuntimeException(\n sprintf('Qdrant API returned HTTP %d: %s', $httpCode, $result)\n );\n }\n\n $decoded = json_decode((string) $result, true);\n\n if (!is_array($decoded)) {\n throw new RuntimeException('Failed to decode JSON response from Qdrant API');\n }\n\n return is_array($decoded['result'] ?? null) ? $decoded['result'] : null;\n } catch (RuntimeException $e) {\n throw $e;\n } catch (\\Throwable) {\n return null;\n }\n }\n\n \/**\n * Makes an HTTP POST request to the Qdrant API.\n *\n * Internal helper method that handles cURL initialization, request execution,\n * error handling, and response parsing for POST requests.\n *\n * @param string $url The API endpoint URL\n * @param array<string, mixed> $payload The JSON payload to send\n * @param int $timeout The request timeout in seconds\n *\n * @return array<string, mixed> The decoded JSON response\n *\n * @throws RuntimeException If the request fails or returns an error\n *\/\n private function makeRequest(string $url, array $payload, int $timeout): array\n {\n $ch = curl_init($url);\n\n if ($ch === false) {\n throw new RuntimeException('Failed to initialize cURL');\n }\n\n $jsonPayload = json_encode($payload);\n\n if ($jsonPayload === false) {\n curl_close($ch);\n\n throw new RuntimeException('Failed to encode JSON payload');\n }\n\n curl_setopt_array($ch, [\n CURLOPT_RETURNTRANSFER =... [TRUNCATED-214b1e2763c6dc84]",
"structuredPatch": [
{
"oldStart": 148,
"oldLines": 6,
"newStart": 148,
"newLines": 68,
"lines": [
" }",
" ",
" \/**",
"+ * Lists all available collections in Qdrant.",
"+ *",
"+ * Retrieves a list of all collection names from the Qdrant database.",
"+ * Returns an empty array if Qdrant is not available or on error.",
"+ *",
"+ * @return array<int, string> Array of collection names",
"+ *",
"+ * @example",
"+ * $service = new QdrantService();",
"+ * $collections = $service->listCollections();",
"+ * \/\/ Returns: ['documents', 'mail', 'entities']",
"+ *\/",
"+ public function listCollections(): array",
"+ {",
"+ $url = $this->host . '\/collections';",
"+",
"+ try {",
"+ $ch = curl_init($url);",
"+",
"+ if ($ch === false) {",
"+ return [];",
"+ }",
"+",
"+ curl_setopt_array($ch, [",
"+ CURLOPT_RETURNTRANSFER => true,",
"+ CURLOPT_TIMEOUT => self::HEALTH_CHECK_TIMEOUT,",
"+ CURLOPT_CONNECTTIMEOUT => self::HEALTH_CHECK_TIMEOUT,",
"+ CURLOPT_HTTPHEADER => ['Content-Type: application\/json'],",
"+ CURLOPT_CUSTOMREQUEST => 'GET',",
"+ ]);",
"+",
"+ $result = curl_exec($ch);",
"+ $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);",
"+",
"+ curl_close($ch);",
"+",
"+ if ($result === false || $httpCode !== 200) {",
"+ return [];",
"+ }",
"+",
"+ $decoded = json_decode((string) $result, true);",
"+",
"+ if (!is_array($decoded) || !isset($decoded['result']['collections'])) {",
"+ return [];",
"+ }",
"+",
"+ $collections = [];",
"+ foreach ($decoded['result']['collections'] as $collection) {",
"+ if (is_array($collection) && isset($collection['name'])) {",
"+ $collections[] = (string) $collection['name'];",
"+ }",
"+ }",
"+",
"+ sort($collections);",
"+",
"+ return $collections;",
"+ } catch (\\Throwable) {",
"+ return [];",
"+ }",
"+ }",
"+",
"+ \/**",
" * Checks if the Qdrant API is available and responding.",
" *",
" * Performs a health check by querying the Qdrant root endpoint."
]
}
],
"userModified": false,
"replaceAll": false
}
}