{
"event": "PreToolUse",
"tool_name": "Edit",
"tool_input": {
"file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Docs\/ChunkAnalysisService.php",
"old_string": " \/**\n * Gets analysis statistics.\n *\n * @return array{pending: int, processing: int, completed: int, failed: int, by_category: array<array{category: string, count: int}>}\n *\/\n public function getStats(): array\n {\n $stmt = $this->pdo->query(\"\n SELECT\n SUM(CASE WHEN analysis_status = 'pending' THEN 1 ELSE 0 END) as pending,\n SUM(CASE WHEN analysis_status = 'processing' THEN 1 ELSE 0 END) as processing,\n SUM(CASE WHEN analysis_status = 'completed' THEN 1 ELSE 0 END) as completed,\n SUM(CASE WHEN analysis_status = 'failed' THEN 1 ELSE 0 END) as failed\n FROM dokumentation_chunks\n \");\n $counts = $stmt->fetch(PDO::FETCH_ASSOC);\n\n $stmt = $this->pdo->query('\n SELECT taxonomy_category as category, COUNT(*) as count\n FROM dokumentation_chunks\n WHERE taxonomy_category IS NOT NULL\n GROUP BY taxonomy_category\n ORDER BY count DESC\n ');\n $byCategory = $stmt->fetchAll(PDO::FETCH_ASSOC);\n\n return [\n 'pending' => (int) ($counts['pending'] ?? 0),\n 'processing' => (int) ($counts['processing'] ?? 0),\n 'completed' => (int) ($counts['completed'] ?? 0),\n 'failed' => (int) ($counts['failed'] ?? 0),\n 'by_category' => $byCategory,\n ];\n }\n}",
"new_string": " \/**\n * Gets analysis statistics (implements ChunkProcessorInterface).\n *\n * @return array{pending: int, processing: int, completed: int, failed: int, by_category: array<array{category: string, count: int}>}\n *\/\n public function getStats(): array\n {\n return $this->repository->getStats();\n }\n}"
}
}
{
"tool_response": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Docs\/ChunkAnalysisService.php",
"oldString": " \/**\n * Gets analysis statistics.\n *\n * @return array{pending: int, processing: int, completed: int, failed: int, by_category: array<array{category: string, count: int}>}\n *\/\n public function getStats(): array\n {\n $stmt = $this->pdo->query(\"\n SELECT\n SUM(CASE WHEN analysis_status = 'pending' THEN 1 ELSE 0 END) as pending,\n SUM(CASE WHEN analysis_status = 'processing' THEN 1 ELSE 0 END) as processing,\n SUM(CASE WHEN analysis_status = 'completed' THEN 1 ELSE 0 END) as completed,\n SUM(CASE WHEN analysis_status = 'failed' THEN 1 ELSE 0 END) as failed\n FROM dokumentation_chunks\n \");\n $counts = $stmt->fetch(PDO::FETCH_ASSOC);\n\n $stmt = $this->pdo->query('\n SELECT taxonomy_category as category, COUNT(*) as count\n FROM dokumentation_chunks\n WHERE taxonomy_category IS NOT NULL\n GROUP BY taxonomy_category\n ORDER BY count DESC\n ');\n $byCategory = $stmt->fetchAll(PDO::FETCH_ASSOC);\n\n return [\n 'pending' => (int) ($counts['pending'] ?? 0),\n 'processing' => (int) ($counts['processing'] ?? 0),\n 'completed' => (int) ($counts['completed'] ?? 0),\n 'failed' => (int) ($counts['failed'] ?? 0),\n 'by_category' => $byCategory,\n ];\n }\n}",
"newString": " \/**\n * Gets analysis statistics (implements ChunkProcessorInterface).\n *\n * @return array{pending: int, processing: int, completed: int, failed: int, by_category: array<array{category: string, count: int}>}\n *\/\n public function getStats(): array\n {\n return $this->repository->getStats();\n }\n}",
"originalFile": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Docs;\n\n\/\/ @responsibility: Orchestriert Chunk-Analyse (koordiniert ChunkAnalyzer + ChunkRepository)\n\nuse RuntimeException;\n\nfinal class ChunkAnalysisService implements ChunkProcessorInterface\n{\n private const string TAXONOMY_MODEL = 'gemma3:4b-it-qat';\n private const int BATCH_SIZE = 10;\n\n public function __construct(\n private ChunkRepository $repository,\n private ChunkAnalyzer $analyzer\n ) {\n }\n\n \/**\n * Analyzes a single chunk.\n *\n * @return array{taxonomy: array<string>, entities: array<array{name: string, type: string}>, keywords: array<string>}\n *\/\n public function analyzeChunk(int $chunkId): array\n {\n return $this->process($chunkId);\n }\n\n \/**\n * Processes a single chunk (implements ChunkProcessorInterface).\n *\n * @return array{taxonomy: array<string>, entities: array<array{name: string, type: string}>, keywords: array<string>}\n *\/\n public function process(int $chunkId): array\n {\n $chunk = $this->repository->findById($chunkId);\n\n if ($chunk === null) {\n throw new RuntimeException(\"Chunk #{$chunkId} not found\");\n }\n\n \/\/ Mark as processing\n $this->repository->updateStatus($chunkId, 'processing');\n\n try {\n \/\/ Get document context\n $docContext = $this->repository->getDocumentContext((int) $chunk['dokumentation_id']);\n\n \/\/ Perform analysis via ChunkAnalyzer\n $analysis = $this->analyzer->analyze($chunk, $docContext);\n\n \/\/ Store results\n $this->repository->storeAnalysisResults($chunkId, $analysis, self::TAXONOMY_MODEL);\n\n return $analysis;\n } catch (RuntimeException $e) {\n $this->repository->updateStatus($chunkId, 'failed', $e->getMessage());\n\n throw $e;\n }\n }\n\n \/**\n * Analyzes all pending chunks in batches.\n *\n * @return array{analyzed: int, failed: int, errors: array<string>}\n *\/\n public function analyzeAllPending(int $limit = 100): array\n {\n return $this->processBatch($limit);\n }\n\n \/**\n * Processes multiple chunks in batch (implements ChunkProcessorInterface).\n *\n * @return array{processed: int, failed: int, errors: array<string>}\n *\/\n public function processBatch(int $limit): array\n {\n $results = ['processed' => 0, 'failed' => 0, 'errors' => []];\n\n $chunks = $this->repository->findPending($limit);\n\n foreach ($chunks as $chunk) {\n try {\n $this->process((int) $chunk['id']);\n $results['processed']++;\n\n \/\/ Progress output\n if ($results['processed'] % self::BATCH_SIZE === 0) {\n echo \"Analyzed {$results['processed']} chunks...\\n\";\n }\n } catch (RuntimeException $e) {\n $results['failed']++;\n $results['errors'][] = \"Chunk #{$chunk['id']}: \" . $e->getMessage();\n }\n }\n\n \/\/ Return with legacy key 'analyzed' for backward compatibility\n $results['analyzed'] = $results['processed'];\n\n return $results;\n }\n\n\n \/**\n * Gets analysis statistics.\n *\n * @return array{pending: int, processing: int, completed: int, failed: int, by_category: array<array{category: string, count: int}>}\n *\/\n public function getStats(): array\n {\n $stmt = $this->pdo->query(\"\n SELECT\n SUM(CASE WHEN analysis_status = 'pending' THEN 1 ELSE 0 END) as pending,\n SUM(CASE WHEN analysis_status = 'processing' THEN 1 ELSE 0 END) as processing,\n SUM(CASE WHEN analysis_status = 'completed' THEN 1 ELSE 0 END) as completed,\n SUM(CASE WHEN analysis_status = 'failed' THEN 1 ELSE 0 END) as failed\n FROM dokumentation_chunks\n \");\n $counts = $stmt->fetch(PDO::FETCH_ASSOC);\n\n $stmt = $this->pdo->query('\n SELECT taxonomy_category as category, COUNT(*) as count\n FROM dokumentation_chunks\n WHERE taxonomy_category IS NOT NULL\n GROUP BY taxonomy_category\n ORDER BY count DESC\n ');\n $byCategory = $stmt->fetchAll(PDO::FETCH_ASSOC);\n\n return [\n 'pending' => (int) ($counts['pending'] ?? 0),\n 'processing' => (int) ($counts['processing'] ?? 0),\n 'completed' => (int) ($counts['completed'] ?? 0),\n 'failed' => (int) ($counts['failed'] ?? 0),\n 'by_category' => $byCategory,\n ];\n }\n}\n",
"structuredPatch": [
{
"oldStart": 107,
"oldLines": 37,
"newStart": 107,
"newLines": 12,
"lines": [
" ",
" ",
" \/**",
"- * Gets analysis statistics.",
"+ * Gets analysis statistics (implements ChunkProcessorInterface).",
" *",
" * @return array{pending: int, processing: int, completed: int, failed: int, by_category: array<array{category: string, count: int}>}",
" *\/",
" public function getStats(): array",
" {",
"- $stmt = $this->pdo->query(\"",
"- SELECT",
"- SUM(CASE WHEN analysis_status = 'pending' THEN 1 ELSE 0 END) as pending,",
"- SUM(CASE WHEN analysis_status = 'processing' THEN 1 ELSE 0 END) as processing,",
"- SUM(CASE WHEN analysis_status = 'completed' THEN 1 ELSE 0 END) as completed,",
"- SUM(CASE WHEN analysis_status = 'failed' THEN 1 ELSE 0 END) as failed",
"- FROM dokumentation_chunks",
"- \");",
"- $counts = $stmt->fetch(PDO::FETCH_ASSOC);",
"-",
"- $stmt = $this->pdo->query('",
"- SELECT taxonomy_category as category, COUNT(*) as count",
"- FROM dokumentation_chunks",
"- WHERE taxonomy_category IS NOT NULL",
"- GROUP BY taxonomy_category",
"- ORDER BY count DESC",
"- ');",
"- $byCategory = $stmt->fetchAll(PDO::FETCH_ASSOC);",
"-",
"- return [",
"- 'pending' => (int) ($counts['pending'] ?? 0),",
"- 'processing' => (int) ($counts['processing'] ?? 0),",
"- 'completed' => (int) ($counts['completed'] ?? 0),",
"- 'failed' => (int) ($counts['failed'] ?? 0),",
"- 'by_category' => $byCategory,",
"- ];",
"+ return $this->repository->getStats();",
" }",
" }"
]
}
],
"userModified": false,
"replaceAll": false
}
}