Protokoll #4146

{
    "event": "PreToolUse",
    "tool_name": "Read",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/PipelineRepository.php",
        "limit": 100
    }
}

{
    "tool_response": {
        "type": "text",
        "file": {
            "filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/PipelineRepository.php",
            "content": "<?php\n\nnamespace Infrastructure\\Persistence;\n\nuse Domain\\Repository\\PipelineRepositoryInterface;\nuse Infrastructure\\Config\\DatabaseFactory;\n\n\/**\n * Repository for Pipeline operations.\n *\/\nclass PipelineRepository implements PipelineRepositoryInterface\n{\n    private \\PDO $pdo;\n\n    public function __construct(?\\PDO $pdo = null)\n    {\n        $this->pdo = $pdo ?? DatabaseFactory::content();\n    }\n\n    public function findById(int $id): ?array\n    {\n        $stmt = $this->pdo->prepare('SELECT * FROM pipeline_configs WHERE id = ?');\n        $stmt->execute([$id]);\n        $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n        if ($result === false) {\n            return null;\n        }\n\n        $result['extensions'] = json_decode($result['extensions'] ?? '[]', true);\n        $result['steps'] = $this->findSteps($id);\n\n        return $result;\n    }\n\n    public function findByName(string $name): ?array\n    {\n        $stmt = $this->pdo->prepare('SELECT * FROM pipeline_configs WHERE name = ?');\n        $stmt->execute([$name]);\n        $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n        if ($result === false) {\n            return null;\n        }\n\n        $result['extensions'] = json_decode($result['extensions'] ?? '[]', true);\n        $result['steps'] = $this->findSteps((int) $result['id']);\n\n        return $result;\n    }\n\n    public function findDefault(): ?array\n    {\n        $stmt = $this->pdo->query('SELECT * FROM pipeline_configs WHERE is_default = 1 LIMIT 1');\n        $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n        if ($result === false) {\n            return null;\n        }\n\n        $result['extensions'] = json_decode($result['extensions'] ?? '[]', true);\n        $result['steps'] = $this->findSteps((int) $result['id']);\n\n        return $result;\n    }\n\n    public function findAll(int $limit = 50): array\n    {\n        $stmt = $this->pdo->query(\n            'SELECT p.*,\n                    (SELECT COUNT(*) FROM pipeline_steps WHERE pipeline_id = p.id AND enabled = 1) as active_steps,\n                    (SELECT COUNT(*) FROM pipeline_runs WHERE pipeline_id = p.id) as total_runs,\n                    (SELECT MAX(created_at) FROM pipeline_runs WHERE pipeline_id = p.id) as last_run_at\n             FROM pipeline_configs p\n             ORDER BY p.is_default DESC, p.name ASC\n             LIMIT ' . $limit\n        );\n\n        $results = $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n\n        foreach ($results as &$row) {\n            $row['extensions'] = json_decode($row['extensions'] ?? '[]', true);\n        }\n\n        return $results;\n    }\n\n    public function findSteps(int $pipelineId): array\n    {\n        $stmt = $this->pdo->prepare(\n            'SELECT * FROM pipeline_steps WHERE pipeline_id = ? ORDER BY sort_order ASC'\n        );\n        $stmt->execute([$pipelineId]);\n        $results = $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n\n        foreach ($results as &$row) {\n            $row['config'] = json_decode($row['config'] ?? '{}', true);\n        }\n\n        return $results;",
            "numLines": 100,
            "startLine": 1,
            "totalLines": 351
        }
    }
}