{
"tool_response": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/AI\/QdrantService.php",
"oldString": " \/**\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 *\/",
"newString": " \/**\n * Retrieves collection metadata (vector size, point count, etc).\n * @return array<string, mixed>|null Null if collection doesn't exist\n * @throws RuntimeException If API request fails (excluding 404)\n *\/",
"originalFile": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\AI;\n\n\/\/ @responsibility: Qdrant-Vektor-DB für Similarity-Search\n\nuse Infrastructure\\Config\\CredentialService;\nuse RuntimeException;\n\nfinal 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 private readonly string $host;\n\n \/**\n * Constructs a new QdrantService instance.\n *\n * @param string|null $host The Qdrant API host URL (uses env QDRANT_HOST if null)\n *\/\n public function __construct(?string $host = null)\n {\n $this->host = $host ?? CredentialService::getQdrantHost();\n }\n\n \/**\n * Searches for similar vectors in a Qdrant collection.\n *\n * @param array<int, float> $vector Query embedding vector\n * @param string $collection Collection to search (default: documents)\n * @param int $limit Max results (default: 5)\n * @return array<int, array{id: int|string, score: float, payload: array<string, mixed>}>\n * @throws RuntimeException If API request fails\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 \/** Checks if a collection exists in Qdrant. *\/\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 \/** Lists all available collections. Returns empty array on error. *\/\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 \/** Checks if Qdrant API is available (health check). *\/\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 => true,\n CURLOPT_POST => true,\n CURLOPT_POSTFIELDS => $jsonPayload,\n CURLOPT_TIMEOUT => $timeout,\n CURLOPT_CONNECTTIMEOUT => 10,\n CURLOPT_HTTPHEADER => [\n 'Content-Type: application\/json',\n 'Content-Length: ' . strlen($jsonPayload),\n ],\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 ... [TRUNCATED-20a530f9a3bff801]",
"structuredPatch": [
{
"oldStart": 186,
"oldLines": 26,
"newStart": 186,
"newLines": 9,
"lines": [
" }",
" ",
" \/**",
"- * Retrieves metadata and information about a collection.",
"- *",
"- * Fetches detailed information about a specific collection including",
"- * vector size, distance metric, number of points, and other metadata.",
"- *",
"- * @param string $collection The collection name to query",
"- *",
"- * @return array<string, mixed>|null The collection information array, or null if collection does not exist",
"- *",
"- * @throws RuntimeException If the API request fails (excluding 404)",
"- *",
"- * @example",
"- * $service = new QdrantService();",
"- * $info = $service->getCollectionInfo('documents');",
"- * \/\/ Returns: [",
"- * \/\/ 'status' => 'green',",
"- * \/\/ 'vectors_count' => 1234,",
"- * \/\/ 'points_count' => 1234,",
"- * \/\/ 'config' => ['params' => ['vectors' => ['size' => 1024, 'distance' => 'Cosine']]]",
"- * \/\/ ]",
"+ * Retrieves collection metadata (vector size, point count, etc).",
"+ * @return array<string, mixed>|null Null if collection doesn't exist",
"+ * @throws RuntimeException If API request fails (excluding 404)",
" *\/",
" public function getCollectionInfo(string $collection): ?array",
" {"
]
}
],
"userModified": false,
"replaceAll": false
}
}