{
"tool_response": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Controller\/ContentPipelineController.php",
"oldString": " $this->view('content-pipeline.show', [\n 'title' => 'Pipeline: ' . $pipeline['name'],\n 'pipeline' => $pipeline,\n 'runs' => $runs,\n 'stepTypes' => $this->getStepTypes(),\n ]);",
"newString": " $this->view('content-pipeline.show', [\n 'title' => 'Pipeline: ' . $pipeline['name'],\n 'pipeline' => $pipeline,\n 'runs' => $runs,\n 'stepTypes' => $this->getStepTypes(),\n 'models' => ModelConfig::getAll(),\n 'defaultModel' => ModelConfig::DEFAULT_MODEL,\n ]);",
"originalFile": "<?php\n\nnamespace Controller;\n\nuse Framework\\Controller;\nuse Infrastructure\\AI\\ModelConfig;\nuse Infrastructure\\Persistence\\PipelineRepository;\n\nclass ContentPipelineController extends Controller\n{\n private PipelineRepository $repository;\n\n public function __construct()\n {\n $this->repository = new PipelineRepository();\n }\n\n \/**\n * GET \/content-pipeline\n *\/\n public function index(): void\n {\n $pipelines = $this->repository->findAll();\n $stats = $this->repository->getStatistics();\n\n $this->view('content-pipeline.index', [\n 'title' => 'Content Pipeline',\n 'pipelines' => $pipelines,\n 'stats' => $stats,\n ]);\n }\n\n \/**\n * GET \/content-pipeline\/import\n *\/\n public function import(): void\n {\n $pipeline = $this->repository->findDefault();\n\n if ($pipeline === null) {\n $pipelines = $this->repository->findAll(1);\n $pipeline = $pipelines[0] ?? null;\n }\n\n $latestRun = $pipeline !== null\n ? $this->repository->findLatestRun((int) $pipeline['id'])\n : null;\n\n $this->view('content-pipeline.import', [\n 'title' => 'Import Pipeline',\n 'pipeline' => $pipeline,\n 'latestRun' => $latestRun,\n ]);\n }\n\n \/**\n * GET \/content-pipeline\/new\n *\/\n public function pipelineNew(): void\n {\n $this->view('content-pipeline.form', [\n 'title' => 'Neue Pipeline',\n 'pipeline' => null,\n 'stepTypes' => $this->getStepTypes(),\n ]);\n }\n\n \/**\n * GET \/content-pipeline\/{id}\n *\/\n public function show(string $id): void\n {\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->notFound('Pipeline nicht gefunden');\n }\n\n $runs = $this->repository->findRuns((int) $id, 10);\n\n $this->view('content-pipeline.show', [\n 'title' => 'Pipeline: ' . $pipeline['name'],\n 'pipeline' => $pipeline,\n 'runs' => $runs,\n 'stepTypes' => $this->getStepTypes(),\n ]);\n }\n\n \/**\n * GET \/content-pipeline\/{id}\/edit\n *\/\n public function edit(string $id): void\n {\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->notFound('Pipeline nicht gefunden');\n }\n\n $this->view('content-pipeline.form', [\n 'title' => 'Pipeline bearbeiten: ' . $pipeline['name'],\n 'pipeline' => $pipeline,\n 'stepTypes' => $this->getStepTypes(),\n ]);\n }\n\n \/**\n * POST \/content-pipeline\n *\/\n public function store(): void\n {\n $this->requireCsrf();\n\n $name = trim($_POST['name'] ?? '');\n $description = trim($_POST['description'] ?? '');\n $sourcePath = trim($_POST['source_path'] ?? '\/var\/www\/nextcloud\/data\/root\/files\/Documents');\n $extensions = $this->parseExtensions($_POST['extensions'] ?? '');\n $isDefault = isset($_POST['is_default']) ? 1 : 0;\n\n if ($name === '') {\n $_SESSION['error'] = 'Name ist erforderlich.';\n header('Location: \/content-pipeline\/new');\n exit;\n }\n\n $pipelineId = $this->repository->create([\n 'name' => $name,\n 'description' => $description,\n 'source_path' => $sourcePath,\n 'extensions' => $extensions,\n 'is_default' => $isDefault,\n ]);\n\n \/\/ Standard-Steps hinzufuegen\n $this->createDefaultSteps($pipelineId);\n\n $_SESSION['success'] = 'Pipeline erfolgreich erstellt.';\n header('Location: \/content-pipeline\/' . $pipelineId);\n exit;\n }\n\n \/**\n * POST \/content-pipeline\/{id}\n *\/\n public function update(string $id): void\n {\n $this->requireCsrf();\n\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->notFound('Pipeline nicht gefunden');\n }\n\n $name = trim($_POST['name'] ?? '');\n $description = trim($_POST['description'] ?? '');\n $sourcePath = trim($_POST['source_path'] ?? '');\n $extensions = $this->parseExtensions($_POST['extensions'] ?? '');\n $isDefault = isset($_POST['is_default']) ? 1 : 0;\n\n if ($name === '') {\n $_SESSION['error'] = 'Name ist erforderlich.';\n header('Location: \/content-pipeline\/' . $id . '\/edit');\n exit;\n }\n\n $this->repository->update((int) $id, [\n 'name' => $name,\n 'description' => $description,\n 'source_path' => $sourcePath,\n 'extensions' => $extensions,\n 'is_default' => $isDefault,\n ]);\n\n $_SESSION['success'] = 'Pipeline aktualisiert.';\n header('Location: \/content-pipeline\/' . $id);\n exit;\n }\n\n \/**\n * POST \/content-pipeline\/{id}\/run\n *\/\n public function run(string $id): void\n {\n $this->requireCsrf();\n\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->notFound('Pipeline nicht gefunden');\n }\n\n \/\/ Neuen Run erstellen\n $runId = $this->repository->createRun((int) $id);\n\n \/\/ Pipeline im Hintergrund starten\n $pipelineScript = '\/opt\/scripts\/pipeline\/pipeline.py';\n $venvPython = '\/opt\/scripts\/pipeline\/venv\/bin\/python';\n $logFile = '\/tmp\/pipeline_run_' . $runId . '.log';\n\n $cmd = sprintf(\n 'nohup %s %s all --pipeline-id=%d --run-id=%d > %s 2>&1 &',\n escapeshellarg($venvPython),\n escapeshellarg($pipelineScript),\n (int) $id,\n $runId,\n escapeshellarg($logFile)\n );\n\n exec($cmd);\n\n $_SESSION['success'] = 'Pipeline gestartet (Run #' . $runId . ')';\n header('Location: \/content-pipeline\/' . $id);\n exit;\n }\n\n \/**\n * GET \/content-pipeline\/{id}\/status\n * AJAX endpoint for run status\n *\/\n public function status(string $id): void\n {\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->json(['error' => 'Pipeline nicht gefunden'], 404);\n return;\n }\n\n $latestRun = $this->repository->findLatestRun((int) $id);\n\n $this->json([\n 'pipeline_id' => (int) $id,\n 'run' => $latestRun,\n ]);\n }\n\n \/**\n * POST \/content-pipeline\/{id}\/steps\/{stepId}\/toggle\n *\/\n public function toggleStep(string $id, string $stepId): void\n {\n $this->requireCsrf();\n\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->notFound('Pipeline nicht gefunden');\n }\n\n \/\/ Find step and toggle\n foreach ($pipeline['steps'] as $step) {\n if ((int) $step['id'] === (int) $stepId) {\n $this->repository->updateStep((int) $stepId, [\n 'enabled' => $step['enabled'] ? 0 : 1,\n ]);\n break;\n }\n }\n\n header('Location: \/content-pipeline\/' . $id);\n exit;\n }\n\n \/**\n * POST \/content-pipeline\/{id}\/delete\n *\/\n public function delete(string $id): void\n {\n $this->requireCsrf();\n\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->notFound('Pipeline nicht gefunden');\n }\n\n $this->repository->delete((int) $id);\n\n $_SESSION['success'] = 'Pipeline geloescht.';\n header('Location: \/content-pipeline');\n exit;\n }\n\n \/**\n * @return array<string, array<string, mixed>>\n *\/\n private function getStepTypes(): array\n {\n return [\n \/\/ Phase 1: Vorverarbeitung\n 'detect' => [\n 'label' => 'Erkennung',\n 'description' => 'Dateien scannen und Format prüfen',\n 'phase' => 'Vorverarbeitung',\n ],\n 'validate' => [\n 'label' => 'Validierung',\n 'description' => 'Datei-Prüfung auf Lesbarkeit und Korruption',\n 'phase' => 'Vorverarbeitung',\n ],\n 'page_split' => [\n 'label' => 'Seitenzerlegung',\n 'description' => 'PDF in Einzelseiten zerlegen für Referenz und Vision-Analyse',\n 'phase' => 'Vorverarbeitung',\n ],\n 'vision_analyze' => [\n 'label' => 'Bildanalyse',\n 'description' => 'Seiten via Vision-Modell analysieren, Bilder und Grafiken erkennen',\n 'phase' => 'Vorverarbeitung',\n ],\n 'extract' => [\n 'label' => 'Textextraktion',\n 'description' => 'Text extrahieren, OCR für Bilder mit Text',\n 'phase' => 'Vorverarbeitung',\n ],\n 'structure' => [\n 'label' => 'Strukturerkennung',\n 'description' => 'Überschriften, Listen und Hierarchie erkennen',\n 'phase' => 'Vorverarbeitung',\n ],\n 'segment' => [\n 'label' => 'Abschnitte',\n 'description' => 'Logische Dokumentgliederung nach Struktur',\n 'phase' => 'Vorverarbeitung',\n ],\n 'chunk' => [\n 'label' => 'Textbausteine',\n 'description' => 'Chunks erstellen (max 800 Token) mit Seitenreferenz',\n 'phase' => 'Vorverarbeitung',\n ],\n \/\/ Phase 2: Speicherung & Vektorisierung\n 'metadata_store' => [\n 'label' => 'DB-Speicherung',\n 'description' => 'Dokument, Seiten und Chunks in MariaDB speichern',\n 'phase' => 'Speicherung',\n ],\n 'embed' => [\n 'label' => 'Vektorisierung',\n 'descript... [TRUNCATED-cb790bac21ed685a]",
"structuredPatch": [
{
"oldStart": 83,
"oldLines": 6,
"newStart": 83,
"newLines": 8,
"lines": [
" 'pipeline' => $pipeline,",
" 'runs' => $runs,",
" 'stepTypes' => $this->getStepTypes(),",
"+ 'models' => ModelConfig::getAll(),",
"+ 'defaultModel' => ModelConfig::DEFAULT_MODEL,",
" ]);",
" }",
" "
]
}
],
"userModified": false,
"replaceAll": false
}
}