Protokoll #4812

{
    "event": "PreToolUse",
    "tool_name": "Edit",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Controller\/ContentPipelineController.php",
        "old_string": "        $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        ]);",
        "new_string": "        $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            'collections' => $this->getAvailableCollections(),\n        ]);"
    }
}

{
    "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            'models' => ModelConfig::getAll(),\n            'defaultModel' => ModelConfig::DEFAULT_MODEL,\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            'collections' => $this->getAvailableCollections(),\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            'models' => ModelConfig::getAll(),\n            'defaultModel' => ModelConfig::DEFAULT_MODEL,\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\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}\/steps\/{stepId}\/model (AJAX)\n     * Update step model configuration\n     *\/\n    public function updateStepModel(string $id, string $stepId): 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        $model = trim($_POST['model'] ?? '');\n\n        if ($model === '' || !ModelConfig::isValid($model)) {\n            $this->json(['error' => 'Ungültiges Modell'], 400);\n\n            return;\n        }\n\n        \/\/ Find step\n        $stepFound = false;\n        foreach ($pipeline['steps'] as $step) {\n            if ((int) $step['id'] === (int) $stepId) {\n                $stepFound = true;\n                $config = $step['config'] ?? [];\n\n                \/\/ Determine provider from model\n                $provider = ModelConfig::isLocal($model) ? 'ollama' : 'anthropic';\n\n                \/\/ Update config with new model\n                $config['model'] = ModelConfig::isLocal($model)\n                    ? substr($model, 7)  \/\/ Remove 'ollama:' prefix\n                    : $model;\n                $config['provider'] = $provider;\n\n                $this->repository->updateStep((int) $stepId, [\n                    'config' => $config,\n                ]);\n                break;\n            }\n        }\n\n        if (!$stepFound) {\n            $this->json(['error' => 'Schritt nicht gefunden'], 404);\n\n            return;\n        }\n\n        $this->json([\n            'success' => true,\n            'model' => $model,\n            'label' => ModelConfig::getLabel($model),\n        ]);\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                'storage' => null,\n            ],\n            'validate' => [\n                'label' => 'Validierung',\n                ... [TRUNCATED-2c7fe886dc9375fd]",
        "structuredPatch": [
            {
                "oldStart": 85,
                "oldLines": 6,
                "newStart": 85,
                "newLines": 7,
                "lines": [
                    "             'stepTypes' => $this->getStepTypes(),",
                    "             'models' => ModelConfig::getAll(),",
                    "             'defaultModel' => ModelConfig::DEFAULT_MODEL,",
                    "+            'collections' => $this->getAvailableCollections(),",
                    "         ]);",
                    "     }",
                    " "
                ]
            }
        ],
        "userModified": false,
        "replaceAll": false
    }
}