Protokoll #7228

{
    "event": "PreToolUse",
    "tool_name": "Edit",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/UseCases\/Pipeline\/RunPipelineUseCase.php",
        "old_string": "<?php\n\ndeclare(strict_types=1);\n\nnamespace UseCases\\Pipeline;\n\nuse Infrastructure\\Persistence\\PipelineRepository;\n\n\/**\n * RunPipelineUseCase - Start and manage pipeline executions.\n *\n * Handles creating runs, starting background processes, and cancellation.\n *\/\nclass RunPipelineUseCase",
        "new_string": "<?php\n\ndeclare(strict_types=1);\n\nnamespace UseCases\\Pipeline;\n\n\/\/ @responsibility: Startet und verwaltet Pipeline-Ausführungen\n\nuse Infrastructure\\Persistence\\PipelineRepository;\n\nclass RunPipelineUseCase"
    }
}

{
    "tool_response": {
        "filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/UseCases\/Pipeline\/RunPipelineUseCase.php",
        "oldString": "<?php\n\ndeclare(strict_types=1);\n\nnamespace UseCases\\Pipeline;\n\nuse Infrastructure\\Persistence\\PipelineRepository;\n\n\/**\n * RunPipelineUseCase - Start and manage pipeline executions.\n *\n * Handles creating runs, starting background processes, and cancellation.\n *\/\nclass RunPipelineUseCase",
        "newString": "<?php\n\ndeclare(strict_types=1);\n\nnamespace UseCases\\Pipeline;\n\n\/\/ @responsibility: Startet und verwaltet Pipeline-Ausführungen\n\nuse Infrastructure\\Persistence\\PipelineRepository;\n\nclass RunPipelineUseCase",
        "originalFile": "<?php\n\ndeclare(strict_types=1);\n\nnamespace UseCases\\Pipeline;\n\nuse Infrastructure\\Persistence\\PipelineRepository;\n\n\/**\n * RunPipelineUseCase - Start and manage pipeline executions.\n *\n * Handles creating runs, starting background processes, and cancellation.\n *\/\nclass RunPipelineUseCase\n{\n    private const PYTHON_BIN = '\/opt\/scripts\/pipeline\/venv\/bin\/python';\n    private const PIPELINE_SCRIPT = '\/opt\/scripts\/pipeline\/pipeline.py';\n    private const LOG_DIR = '\/tmp';\n\n    private PipelineRepository $repository;\n\n    public function __construct(?PipelineRepository $repository = null)\n    {\n        $this->repository = $repository ?? new PipelineRepository();\n    }\n\n    \/**\n     * Start a new pipeline run.\n     *\n     * @param int $pipelineId Pipeline ID\n     * @return array{success: bool, run_id?: int, error?: string}\n     *\/\n    public function start(int $pipelineId): array\n    {\n        $pipeline = $this->repository->findById($pipelineId);\n\n        if ($pipeline === null) {\n            return ['success' => false, 'error' => 'Pipeline nicht gefunden'];\n        }\n\n        $runId = $this->repository->createRun($pipelineId);\n\n        $this->executeInBackground($pipelineId, $runId);\n\n        return ['success' => true, 'run_id' => $runId];\n    }\n\n    \/**\n     * Cancel a running pipeline.\n     *\n     * @param int $pipelineId Pipeline ID\n     * @param int $runId Run ID\n     * @return array{success: bool, error?: string}\n     *\/\n    public function cancel(int $pipelineId, int $runId): array\n    {\n        $run = $this->repository->findRunById($runId);\n\n        if ($run === null || (int) $run['pipeline_id'] !== $pipelineId) {\n            return ['success' => false, 'error' => 'Run nicht gefunden'];\n        }\n\n        if ($run['status'] !== 'running') {\n            return [\n                'success' => false,\n                'error' => 'Run kann nicht abgebrochen werden (Status: ' . $run['status'] . ')',\n            ];\n        }\n\n        $this->repository->updateRun($runId, [\n            'status' => 'cancelled',\n            'completed_at' => date('Y-m-d H:i:s'),\n        ]);\n\n        return ['success' => true];\n    }\n\n    \/**\n     * Get simple status for a pipeline (latest run).\n     *\n     * @param int $pipelineId Pipeline ID\n     * @return array{success: bool, error?: string, run?: array}\n     *\/\n    public function getStatus(int $pipelineId): array\n    {\n        $pipeline = $this->repository->findById($pipelineId);\n\n        if ($pipeline === null) {\n            return ['success' => false, 'error' => 'Pipeline nicht gefunden'];\n        }\n\n        return [\n            'success' => true,\n            'pipeline_id' => $pipelineId,\n            'run' => $this->repository->findLatestRun($pipelineId),\n        ];\n    }\n\n    \/**\n     * Execute pipeline script in background.\n     *\/\n    private function executeInBackground(int $pipelineId, int $runId): void\n    {\n        $logFile = sprintf('%s\/pipeline_run_%d.log', self::LOG_DIR, $runId);\n\n        $cmd = sprintf(\n            'nohup %s %s all --pipeline-id=%d --run-id=%d > %s 2>&1 &',\n            escapeshellarg(self::PYTHON_BIN),\n            escapeshellarg(self::PIPELINE_SCRIPT),\n            $pipelineId,\n            $runId,\n            escapeshellarg($logFile)\n        );\n\n        exec($cmd);\n    }\n}\n",
        "structuredPatch": [
            {
                "oldStart": 4,
                "oldLines": 13,
                "newStart": 4,
                "newLines": 10,
                "lines": [
                    " ",
                    " namespace UseCases\\Pipeline;",
                    " ",
                    "+\/\/ @responsibility: Startet und verwaltet Pipeline-Ausführungen",
                    "+",
                    " use Infrastructure\\Persistence\\PipelineRepository;",
                    " ",
                    "-\/**",
                    "- * RunPipelineUseCase - Start and manage pipeline executions.",
                    "- *",
                    "- * Handles creating runs, starting background processes, and cancellation.",
                    "- *\/",
                    " class RunPipelineUseCase",
                    " {",
                    "     private const PYTHON_BIN = '\/opt\/scripts\/pipeline\/venv\/bin\/python';"
                ]
            }
        ],
        "userModified": false,
        "replaceAll": false
    }
}