{
"event": "PostToolUse",
"tool_name": "Read",
"tool_response": {
"type": "text",
"file": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/ChunkRepository.php",
"content": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Persistence;\n\n\/\/ @responsibility: CRUD-Operationen für Text-Chunks aus Dokumenten\n\nuse Domain\\Repository\\ChunkRepositoryInterface;\nuse PDO;\n\nfinal class ChunkRepository implements ChunkRepositoryInterface\n{\n private PDO $db;\n\n public function __construct(PDO $pdo)\n {\n $this->db = $pdo;\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function getStats(): array\n {\n $result = $this->db->query(\n 'SELECT\n COUNT(*) as total,\n COALESCE(SUM(token_count), 0) as tokens,\n SUM(CASE WHEN qdrant_id IS NOT NULL THEN 1 ELSE 0 END) as embedded\n FROM chunks'\n )->fetch();\n\n return $result !== false ? $result : ['total' => 0, 'tokens' => 0, 'embedded' => 0];\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function findRecent(int $limit = 5): array\n {\n $stmt = $this->db->prepare(\n 'SELECT c.id, c.content, c.token_count, c.created_at, c.qdrant_id, d.filename\n FROM chunks c\n JOIN documents d ON c.document_id = d.id\n ORDER BY c.created_at DESC\n LIMIT :limit'\n );\n $stmt->bindValue(':limit', $limit, PDO::PARAM_INT);\n $stmt->execute();\n\n return $stmt->fetchAll();\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function findByDocument(int $documentId): array\n {\n $stmt = $this->db->prepare(\n 'SELECT c.id, c.chunk_index, c.content, c.token_count, c.heading_path,\n c.metadata, c.qdrant_id, c.created_at\n FROM chunks c\n WHERE c.document_id = :id\n ORDER BY c.chunk_index'\n );\n $stmt->execute(['id' => $documentId]);\n\n return $stmt->fetchAll();\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function findFiltered(string $search = '', string $embedded = '', int $limit = 50, int $offset = 0): array\n {\n $sql = 'SELECT c.id, c.chunk_index, c.content, c.token_count, c.qdrant_id, c.created_at,\n d.filename, d.id as document_id\n FROM chunks c\n JOIN documents d ON c.document_id = d.id\n WHERE 1=1';\n\n $params = [];\n\n if ($search !== '') {\n $sql .= ' AND c.content LIKE :search';\n $params['search'] = '%' . $search . '%';\n }\n\n if ($embedded === 'yes') {\n $sql .= ' AND c.qdrant_id IS NOT NULL';\n } elseif ($embedded === 'no') {\n $sql .= ' AND c.qdrant_id IS NULL';\n }\n\n $sql .= ' ORDER BY c.created_at DESC LIMIT ' . $limit . ' OFFSET ' . $offset;\n\n $stmt = $this->db->prepare($sql);\n $stmt->execute($params);\n\n return $stmt->fetchAll();\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function count(string $search = '', string $embedded = ''): int\n {\n $sql = 'SELECT COUNT(*) FROM chunks c\n JOIN documents d ON c.document_id = d.id\n WHERE 1=1';\n\n $params = [];\n\n if ($search !== '') {\n $sql .= ' AND c.content LIKE :search';\n $params['search'] = '%' . $search . '%';\n }\n\n if ($embedded === 'yes') {\n $sql .= ' AND c.qdrant_id IS NOT NULL';\n } elseif ($embedded === 'no') {\n $sql .= ' AND c.qdrant_id IS NULL';\n }\n\n $stmt = $this->db->prepare($sql);\n $stmt->execute($params);\n\n return (int) $stmt->fetchColumn();\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function find(int $id): ?array\n {\n $stmt = $this->db->prepare(\n 'SELECT c.*, d.filename, d.source_path, d.id as document_id\n FROM chunks c\n JOIN documents d ON c.document_id = d.id\n WHERE c.id = :id'\n );\n $stmt->execute(['id' => $id]);\n $result = $stmt->fetch();\n\n return $result === false ? null : $result;\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function findByDocumentAndIndex(int $documentId, int $chunkIndex): ?array\n {\n $stmt = $this->db->prepare(\n 'SELECT id, chunk_index FROM chunks\n WHERE document_id = :doc_id AND chunk_index = :idx'\n );\n $stmt->execute(['doc_id' => $documentId, 'idx' => $chunkIndex]);\n $result = $stmt->fetch();\n\n return $result === false ? null : $result;\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function getChunkEntities(int $chunkId): array\n {\n $stmt = $this->db->prepare(\n 'SELECT e.id, e.name, e.type, ce.relevance_score\n FROM chunk_entities ce\n JOIN entities e ON ce.entity_id = e.id\n WHERE ce.chunk_id = :chunk_id\n ORDER BY ce.relevance_score DESC'\n );\n $stmt->execute(['chunk_id' => $chunkId]);\n\n return $stmt->fetchAll(PDO::FETCH_ASSOC) ?: [];\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function getChunkTaxonomy(int $chunkId): array\n {\n $stmt = $this->db->prepare(\n 'SELECT tt.id as term_id, tt.name as term_name, tt.path as term_path, ct.confidence\n FROM chunk_taxonomy ct\n JOIN taxonomy_terms tt ON ct.taxonomy_term_id = tt.id\n WHERE ct.chunk_id = :chunk_id\n ORDER BY ct.confidence DESC'\n );\n $stmt->execute(['chunk_id' => $chunkId]);\n\n return $stmt->fetchAll(PDO::FETCH_ASSOC) ?: [];\n }\n\n \/**\n * {@inheritDoc}\n *\/\n public function findChunksByEntity(int $entityId, int $limit = 10): array\n {\n $stmt = $this->db->prepare(\n 'SELECT c.id as chunk_id, c.content, ce.relevance_score\n FROM chunk_entities ce\n JOIN chunks c ON ce.chunk_id = c.id\n WHERE ce.entity_id = :entity_id\n ORDER BY ce.relevance_score DESC\n LIMIT :limit'\n );\n $stmt->bindValue(':entity_id', $entityId, PDO::PARAM_INT);\n $stmt->bindValue(':limit', $limit, PDO::PARAM_INT);\n $stmt->execute();\n\n return $stmt->fetchAll(PDO::FETCH_ASSOC) ?: [];\n }\n}\n",
"numLines": 218,
"startLine": 1,
"totalLines": 218
}
}
}