Protokoll #12844

{
    "event": "PreToolUse",
    "tool_name": "Read",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Controller\/ChatController.php"
    }
}

{
    "tool_response": {
        "type": "text",
        "file": {
            "filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Controller\/ContentPipelineController.php",
            "content": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Controller;\n\n\/\/ @responsibility: HTTP-Endpunkte für Content-Pipeline-Verwaltung\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;\nuse UseCases\\Pipeline\\UpdatePipelineConfigUseCase;\n\nclass ContentPipelineController extends Controller\n{\n    private PipelineRepository $repository;\n    private PipelineStepService $stepService;\n    private RunPipelineUseCase $runUseCase;\n    private PipelineRunStatusUseCase $statusUseCase;\n    private UpdatePipelineConfigUseCase $configUseCase;\n\n    public function __construct(\n        PipelineRepository $repository,\n        PipelineStepService $stepService,\n        RunPipelineUseCase $runUseCase,\n        PipelineRunStatusUseCase $statusUseCase,\n        UpdatePipelineConfigUseCase $configUseCase\n    ) {\n        $this->repository = $repository;\n        $this->stepService = $stepService;\n        $this->runUseCase = $runUseCase;\n        $this->statusUseCase = $statusUseCase;\n        $this->configUseCase = $configUseCase;\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::getDefaultModel(),\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 (AJAX)\n     *\/\n    public function updateStepModel(string $id, string $stepId): void\n    {\n        $result = $this->stepService->updateModel(\n            (int) $id,\n            (int) $stepId,\n            $_POST['model'] ?? ''\n        );\n\n        if (!$result['success']) {\n            $this->json(['error' => $result['error']], $result['error'] === 'Schritt nicht gefunden' ? 404 : 400);\n\n            return;\n        }\n\n        $this->json($result);\n    }\n\n    \/**\n     * POST \/content-pipeline\/{id}\/steps\/{stepId}\/collection (AJAX)\n     *\/\n    public function updateStepCollection(string $id, string $stepId): void\n    {\n        $result = $this->stepService->updateCollection(\n            (int) $id,\n            (int) $stepId,\n            $_POST['collection'] ?? ''\n        );\n\n        if (!$result['success']) {\n            $this->json(['error' => $result['error']], $result['error'] === 'Schritt nicht gefunden' ? 404 : 400);\n\n            return;\n        }\n\n        $this->json($result);\n    }\n\n    \/**\n     * POST \/content-pipeline\/{id}\/config (AJAX)\n     *\/\n    public function updateConfig(string $id): void\n    {\n        $result = $this->configUseCase->execute((int) $id, $_POST);\n\n        if (!$result['success']) {\n            $code = $result['error'] === 'Pipeline nicht gefunden' ? 404 : 400;\n            $this->json(['error' => $result['error']], $code);\n\n            return;\n        }\n\n        $this->json(['success' => true]);\n    }\n\n    \/**\n     ... [TRUNCATED-51a7f33badcbdaf2]",
            "numLines": 368,
            "startLine": 1,
            "totalLines": 368
        }
    }
}