Protokoll #24558

{
    "event": "PreToolUse",
    "tool_name": "Edit",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Docs\/ChunkAnalysisService.php",
        "old_string": "public function analyzeAllPending(int $limit = 100): array",
        "new_string": "public function analyzeAllPending(int $limit = Constants::DEFAULT_LIMIT): array"
    }
}

{
    "tool_response": {
        "filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Docs\/ChunkAnalysisService.php",
        "oldString": "public function analyzeAllPending(int $limit = 100): array",
        "newString": "public function analyzeAllPending(int $limit = Constants::DEFAULT_LIMIT): array",
        "originalFile": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Docs;\n\n\/\/ @responsibility: Orchestriert Chunk-Analyse (koordiniert ChunkAnalyzer + ChunkRepository)\n\nuse Domain\\Constants;\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 ChunkDataRepository $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{processed: 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     * 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}\n",
        "structuredPatch": [
            {
                "oldStart": 69,
                "oldLines": 7,
                "newStart": 69,
                "newLines": 7,
                "lines": [
                    "      *",
                    "      * @return array{processed: int, failed: int, errors: array<string>}",
                    "      *\/",
                    "-    public function analyzeAllPending(int $limit = 100): array",
                    "+    public function analyzeAllPending(int $limit = Constants::DEFAULT_LIMIT): array",
                    "     {",
                    "         return $this->processBatch($limit);",
                    "     }"
                ]
            }
        ],
        "userModified": false,
        "replaceAll": false
    }
}