{
"tool_response": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Controller\/ContentPipelineController.php",
"oldString": " \/**\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 $runId = $this->repository->createRun((int) $id);\n\n \/\/ Pipeline im Hintergrund starten\n $cmd = sprintf(\n 'nohup %s %s all --pipeline-id=%d --run-id=%d > %s 2>&1 &',\n escapeshellarg('\/opt\/scripts\/pipeline\/venv\/bin\/python'),\n escapeshellarg('\/opt\/scripts\/pipeline\/pipeline.py'),\n (int) $id,\n $runId,\n escapeshellarg('\/tmp\/pipeline_run_' . $runId . '.log')\n );\n\n exec($cmd);\n\n \/\/ Redirect zur Live-Status-Seite\n $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $runId . '\/status');\n }",
"newString": " \/**\n * POST \/content-pipeline\/{id}\/run\n *\/\n public function run(string $id): void\n {\n $this->requireCsrf();\n\n $result = $this->runUseCase->start((int) $id);\n\n if (!$result['success']) {\n $this->notFound($result['error'] ?? 'Pipeline nicht gefunden');\n }\n\n $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $result['run_id'] . '\/status');\n }",
"originalFile": "<?php\n\nnamespace Controller;\n\nuse Application\\PipelineStepService;\nuse Framework\\Controller;\nuse Infrastructure\\AI\\ModelConfig;\nuse Infrastructure\\Config\\PipelineStepConfig;\nuse Infrastructure\\Persistence\\PipelineRepository;\nuse UseCases\\Pipeline\\PipelineRunStatusUseCase;\nuse UseCases\\Pipeline\\RunPipelineUseCase;\n\nclass ContentPipelineController extends Controller\n{\n private PipelineRepository $repository;\n private PipelineStepService $stepService;\n private RunPipelineUseCase $runUseCase;\n private PipelineRunStatusUseCase $statusUseCase;\n\n public function __construct(\n ?PipelineRepository $repository = null,\n ?PipelineStepService $stepService = null,\n ?RunPipelineUseCase $runUseCase = null,\n ?PipelineRunStatusUseCase $statusUseCase = null\n ) {\n $this->repository = $repository ?? new PipelineRepository();\n $this->stepService = $stepService ?? new PipelineStepService($this->repository);\n $this->runUseCase = $runUseCase ?? new RunPipelineUseCase($this->repository);\n $this->statusUseCase = $statusUseCase ?? new PipelineRunStatusUseCase($this->repository);\n }\n\n \/**\n * GET \/content-pipeline\n *\/\n public function index(): void\n {\n $this->view('content-pipeline.index', [\n 'title' => 'Content Pipeline',\n 'pipelines' => $this->repository->findAll(),\n 'stats' => $this->repository->getStatistics(),\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 $this->view('content-pipeline.import', [\n 'title' => 'Import Pipeline',\n 'pipeline' => $pipeline,\n 'latestRun' => $pipeline !== null\n ? $this->repository->findLatestRun((int) $pipeline['id'])\n : null,\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' => PipelineStepConfig::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 $this->view('content-pipeline.show', [\n 'title' => 'Pipeline: ' . $pipeline['name'],\n 'pipeline' => $pipeline,\n 'runs' => $this->repository->findRuns((int) $id, 10),\n 'stepTypes' => PipelineStepConfig::getStepTypes(),\n 'models' => ModelConfig::getAll(),\n 'defaultModel' => ModelConfig::DEFAULT_MODEL,\n 'collections' => PipelineStepConfig::getCollections(),\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' => PipelineStepConfig::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\n if ($name === '') {\n $_SESSION['error'] = 'Name ist erforderlich.';\n $this->redirect('\/content-pipeline\/new');\n }\n\n $pipelineId = $this->repository->create([\n 'name' => $name,\n 'description' => trim($_POST['description'] ?? ''),\n 'source_path' => trim($_POST['source_path'] ?? '\/var\/www\/nextcloud\/data\/root\/files\/Documents'),\n 'extensions' => PipelineStepConfig::parseExtensions($_POST['extensions'] ?? ''),\n 'is_default' => isset($_POST['is_default']) ? 1 : 0,\n ]);\n\n $this->stepService->createDefaultSteps($pipelineId);\n\n $_SESSION['success'] = 'Pipeline erfolgreich erstellt.';\n $this->redirect('\/content-pipeline\/' . $pipelineId);\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\n if ($name === '') {\n $_SESSION['error'] = 'Name ist erforderlich.';\n $this->redirect('\/content-pipeline\/' . $id . '\/edit');\n }\n\n $this->repository->update((int) $id, [\n 'name' => $name,\n 'description' => trim($_POST['description'] ?? ''),\n 'source_path' => trim($_POST['source_path'] ?? ''),\n 'extensions' => PipelineStepConfig::parseExtensions($_POST['extensions'] ?? ''),\n 'is_default' => isset($_POST['is_default']) ? 1 : 0,\n ]);\n\n $_SESSION['success'] = 'Pipeline aktualisiert.';\n $this->redirect('\/content-pipeline\/' . $id);\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 $runId = $this->repository->createRun((int) $id);\n\n \/\/ Pipeline im Hintergrund starten\n $cmd = sprintf(\n 'nohup %s %s all --pipeline-id=%d --run-id=%d > %s 2>&1 &',\n escapeshellarg('\/opt\/scripts\/pipeline\/venv\/bin\/python'),\n escapeshellarg('\/opt\/scripts\/pipeline\/pipeline.py'),\n (int) $id,\n $runId,\n escapeshellarg('\/tmp\/pipeline_run_' . $runId . '.log')\n );\n\n exec($cmd);\n\n \/\/ Redirect zur Live-Status-Seite\n $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $runId . '\/status');\n }\n\n \/**\n * GET \/content-pipeline\/{id}\/status (AJAX)\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\n return;\n }\n\n $this->json([\n 'pipeline_id' => (int) $id,\n 'run' => $this->repository->findLatestRun((int) $id),\n ]);\n }\n\n \/**\n * GET \/content-pipeline\/{id}\/run\/{runId}\/status\n *\/\n public function runStatus(string $id, string $runId): void\n {\n $pipeline = $this->repository->findById((int) $id);\n\n if ($pipeline === null) {\n $this->notFound('Pipeline nicht gefunden');\n }\n\n $run = $this->repository->findRunById((int) $runId);\n\n if ($run === null || (int) $run['pipeline_id'] !== (int) $id) {\n $this->notFound('Run nicht gefunden');\n }\n\n $this->view('content-pipeline.run-status', [\n 'title' => 'Pipeline Status: ' . $pipeline['name'],\n 'pipeline' => $pipeline,\n 'run' => $run,\n ]);\n }\n\n \/**\n * GET \/content-pipeline\/{id}\/run\/{runId}\/poll (AJAX\/HTMX)\n *\/\n public function runStatusPoll(string $id, string $runId): void\n {\n $run = $this->repository->findRunById((int) $runId);\n\n if ($run === null || (int) $run['pipeline_id'] !== (int) $id) {\n $this->json(['error' => 'Run nicht gefunden'], 404);\n\n return;\n }\n\n \/\/ Berechne verstrichene Zeit\n $startedAt = strtotime($run['started_at'] ?? 'now');\n $elapsed = time() - $startedAt;\n\n \/\/ Fortschrittsberechnung\n $total = (int) ($run['documents_total'] ?? 0);\n $processed = (int) ($run['documents_processed'] ?? 0);\n $progress = $total > 0 ? round(($processed \/ $total) * 100) : 0;\n\n \/\/ Geschätzte Restzeit\n $estimatedRemaining = null;\n if ($processed > 0 && $total > $processed) {\n $avgTimePerDoc = $elapsed \/ $processed;\n $remaining = $total - $processed;\n $estimatedRemaining = (int) ($avgTimePerDoc * $remaining);\n }\n\n \/\/ Stall-Erkennung (keine Aktivität seit >60s)\n $lastUpdate = strtotime($run['last_update_at'] ?? $run['started_at'] ?? 'now');\n $isStalled = (time() - $lastUpdate) > 60 && $run['status'] === 'running';\n\n \/\/ Terminal-Status (Polling stoppen wenn fertig)\n $isTerminal = in_array($run['status'], ['completed', 'failed', 'cancelled'], true);\n\n $this->json([\n 'status' => $run['status'],\n 'current_step' => $run['current_step'],\n 'current_document' => $run['current_document'],\n 'documents_total' => $total,\n 'documents_processed' => $processed,\n 'documents_failed' => (int) ($run['documents_failed'] ?? 0),\n 'chunks_created' => (int) ($run['chunks_created'] ?? 0),\n 'embeddings_created' => (int) ($run['embeddings_created'] ?? 0),\n 'progress' => $progress,\n 'elapsed' => $elapsed,\n 'elapsed_formatted' => gmdate('i:s', $elapsed),\n 'estimated_remaining' => $estimatedRemaining,\n 'estimated_formatted' => $estimatedRemaining !== null ? gmdate('i:s', $estimatedRemaining) : null,\n 'log_tail' => $run['log_tail'] ?? '',\n 'is_stalled' => $isStalled,\n 'is_terminal' => $isTerminal,\n 'completed_at' => $run['completed_at'],\n 'error_log' => $run['error_log'],\n ]... [TRUNCATED-4b643f3317c967df]",
"structuredPatch": [
{
"oldStart": 181,
"oldLines": 28,
"newStart": 181,
"newLines": 13,
"lines": [
" {",
" $this->requireCsrf();",
" ",
"- $pipeline = $this->repository->findById((int) $id);",
"+ $result = $this->runUseCase->start((int) $id);",
" ",
"- if ($pipeline === null) {",
"- $this->notFound('Pipeline nicht gefunden');",
"+ if (!$result['success']) {",
"+ $this->notFound($result['error'] ?? 'Pipeline nicht gefunden');",
" }",
" ",
"- $runId = $this->repository->createRun((int) $id);",
"-",
"- \/\/ Pipeline im Hintergrund starten",
"- $cmd = sprintf(",
"- 'nohup %s %s all --pipeline-id=%d --run-id=%d > %s 2>&1 &',",
"- escapeshellarg('\/opt\/scripts\/pipeline\/venv\/bin\/python'),",
"- escapeshellarg('\/opt\/scripts\/pipeline\/pipeline.py'),",
"- (int) $id,",
"- $runId,",
"- escapeshellarg('\/tmp\/pipeline_run_' . $runId . '.log')",
"- );",
"-",
"- exec($cmd);",
"-",
"- \/\/ Redirect zur Live-Status-Seite",
"- $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $runId . '\/status');",
"+ $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $result['run_id'] . '\/status');",
" }",
" ",
" \/**"
]
}
],
"userModified": false,
"replaceAll": false
}
}