{
"tool_response": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Controller\/ContentPipelineController.php",
"oldString": " \/**\n * POST \/content-pipeline\/{id}\/run\/{runId}\/cancel\n *\/\n public function runCancel(string $id, string $runId): void\n {\n $this->requireCsrf();\n\n $result = $this->runUseCase->cancel((int) $id, (int) $runId);\n\n if (!$result['success']) {\n if ($result['error'] === 'Run nicht gefunden') {\n $this->notFound($result['error']);\n }\n $_SESSION['error'] = $result['error'];\n } else {\n $_SESSION['success'] = 'Pipeline-Run wurde abgebrochen.';\n }\n\n $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $runId . '\/status');\n }",
"newString": " \/**\n * POST \/content-pipeline\/{id}\/run\/{runId}\/cancel\n *\/\n public function runCancel(string $id, string $runId): void\n {\n $this->requireCsrf();\n\n $result = $this->runUseCase->cancel((int) $id, (int) $runId);\n\n if (!$result['success']) {\n if ($result['error'] === 'Run nicht gefunden') {\n $this->notFound($result['error']);\n }\n\n if ($this->isHtmxRequest()) {\n $this->htmxError($result['error']);\n\n return;\n }\n $_SESSION['error'] = $result['error'];\n } else {\n \/\/ HTMX: Return disabled button\n if ($this->isHtmxRequest()) {\n $this->partial('content-pipeline.partials.cancel-button', [\n 'disabled' => true,\n 'label' => 'Abgebrochen',\n ]);\n\n return;\n }\n $_SESSION['success'] = 'Pipeline-Run wurde abgebrochen.';\n }\n\n $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $runId . '\/status');\n }",
"originalFile": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Controller;\n\n\/\/ @responsibility: HTTP-Endpunkte für Content-Pipeline-Verwaltung\n\nuse Application\\PipelineStepService;\nuse Domain\\Repository\\PipelineRepositoryInterface;\nuse Framework\\Controller;\nuse Infrastructure\\AI\\ModelRegistry;\nuse Infrastructure\\Config\\PipelineStepConfig;\nuse UseCases\\Pipeline\\PipelineRunStatusUseCase;\nuse UseCases\\Pipeline\\RunPipelineUseCase;\nuse UseCases\\Pipeline\\UpdatePipelineConfigUseCase;\n\nclass ContentPipelineController extends Controller\n{\n public function __construct(\n private PipelineRepositoryInterface $repository,\n private PipelineStepService $stepService,\n private RunPipelineUseCase $runUseCase,\n private PipelineRunStatusUseCase $statusUseCase,\n private UpdatePipelineConfigUseCase $configUseCase,\n private ModelRegistry $modelRegistry\n ) {\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' => $this->modelRegistry->getChatModels(),\n 'defaultModel' => $this->modelRegistry->getDefaultChatModel(),\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 $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 }\n\n \/**\n * GET \/content-pipeline\/{id}\/status (AJAX)\n *\/\n public function status(string $id): void\n {\n $result = $this->runUseCase->getStatus((int) $id);\n\n if (!$result['success']) {\n $this->json(['error' => $result['error']], 404);\n\n return;\n }\n\n $this->json($result);\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 $result = $this->statusUseCase->execute((int) $id, (int) $runId);\n\n if (!$result['success']) {\n $this->json(['error' => $result['error']], 404);\n\n return;\n }\n\n $this->json($result['data']);\n }\n\n \/**\n * POST \/content-pipeline\/{id}\/run\/{runId}\/cancel\n *\/\n public function runCancel(string $id, string $runId): void\n {\n $this->requireCsrf();\n\n $result = $this->runUseCase->cancel((int) $id, (int) $runId);\n\n if (!$result['success']) {\n if ($result['error'] === 'Run nicht gefunden') {\n $this->notFound($result['error']);\n }\n $_SESSION['error'] = $result['error'];\n } else {\n $_SESSION['success'] = 'Pipeline-Run wurde abgebrochen.';\n }\n\n $this->redirect('\/content-pipeline\/' . $id . '\/run\/' . $runId . '\/status');\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 if (!$this->stepService->toggleStep((int) $id, (int) $stepId)) {\n $this->notFound('Pipeline oder Schritt nicht gefunden');\n }\n\n $this->redirect('\/content-pipeline\/' . $id);\n }\n\n \/**\n * POST \/content-pipeline\/{id}\/steps\/{stepId}\/model (HTMX)\n *\/\n public function updateStepModel(string $id, string $stepId): void\n {\n $this->requireCsrf();\n\n $result = $this->stepService->updateModel(\n (int) $id,\n (int) $stepId,\n $_POST['model'] ?? ''\n );\n\n if (!$result['success']) {\n $this->htmxError($result['error']);\n\n return;\n }\n\n \/\/ hx-swap=\"none\" erwartet nur Status 200\n $this->text('OK');\n }\n\n \/**\n * POST \/content-pipeline\/{id}\/steps\/{stepId}\/collection (HTMX)\n *\/\n public function updateStepCollection(string $id, string $stepId): void\n {\n $this->requireCsrf();\n\n $result = $this->stepService->updateCollection(\n (int) $id,\n (int) $stepId,\n $_POST['collection'] ?? ''\n );\n\n if (!$result['success']) {\n $this->htmxError($result['error']);\n\n return;\n }\n\n \/\/ hx-swap=\"none\" erwartet nur Status 200\n $this->text('OK');\n }\n\n \/**\n * POST \/content-pipeline\/{id}\/config (HTMX)\n *\/\n public function updateConfig(string $id): void\n {\n $this->requireCsrf();\n\n $result = $this->configUseCase->execute((int) $id, $_POST);\n\n if (!$result['success']) {\n $this->htmxError($result['error']);\n\n return;\n }\n\n \/\/ hx-swap=\"none\" erwartet nur Status 200\n $this->text('OK');\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 ... [TRUNCATED-69eb693498ff8d2f]",
"structuredPatch": [
{
"oldStart": 257,
"oldLines": 8,
"newStart": 257,
"newLines": 23,
"lines": [
" if ($result['error'] === 'Run nicht gefunden') {",
" $this->notFound($result['error']);",
" }",
"+",
"+ if ($this->isHtmxRequest()) {",
"+ $this->htmxError($result['error']);",
"+",
"+ return;",
"+ }",
" $_SESSION['error'] = $result['error'];",
" } else {",
"+ \/\/ HTMX: Return disabled button",
"+ if ($this->isHtmxRequest()) {",
"+ $this->partial('content-pipeline.partials.cancel-button', [",
"+ 'disabled' => true,",
"+ 'label' => 'Abgebrochen',",
"+ ]);",
"+",
"+ return;",
"+ }",
" $_SESSION['success'] = 'Pipeline-Run wurde abgebrochen.';",
" }",
" "
]
}
],
"userModified": false,
"replaceAll": false
}
}