{
"event": "PreToolUse",
"tool_name": "Write",
"tool_input": {
"file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/PipelineConfigRepository.php",
"content": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Persistence;\n\n\/\/ @responsibility: Persistenz für Pipeline-Konfigurationen\n\nuse Domain\\Repository\\PipelineConfigRepositoryInterface;\n\nclass PipelineConfigRepository implements PipelineConfigRepositoryInterface\n{\n private \\PDO $pdo;\n\n public function __construct(\\PDO $pdo)\n {\n $this->pdo = $pdo;\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\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\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 if ($stmt === false) {\n return null;\n }\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\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 if ($stmt === false) {\n return [];\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 create(array $data): int\n {\n $extensions = is_array($data['extensions'] ?? null)\n ? json_encode($data['extensions'])\n : ($data['extensions'] ?? '[]');\n\n $stmt = $this->pdo->prepare(\n 'INSERT INTO pipeline_configs (name, description, is_default, source_path, extensions)\n VALUES (?, ?, ?, ?, ?)'\n );\n $stmt->execute([\n $data['name'],\n $data['description'] ?? null,\n $data['is_default'] ?? 0,\n $data['source_path'] ?? '\/var\/www\/nextcloud\/data\/root\/files\/Documents',\n $extensions,\n ]);\n\n return (int) $this->pdo->lastInsertId();\n }\n\n public function update(int $id, array $data): void\n {\n $sets = [];\n $params = [];\n\n if (isset($data['name'])) {\n $sets[] = 'name = ?';\n $params[] = $data['name'];\n }\n if (isset($data['description'])) {\n $sets[] = 'description = ?';\n $params[] = $data['description'];\n }\n if (isset($data['is_default'])) {\n $sets[] = 'is_default = ?';\n $params[] = $data['is_default'];\n }\n if (isset($data['source_path'])) {\n $sets[] = 'source_path = ?';\n $params[] = $data['source_path'];\n }\n if (isset($data['extensions'])) {\n $sets[] = 'extensions = ?';\n $params[] = is_array($data['extensions'])\n ? json_encode($data['extensions'])\n : $data['extensions'];\n }\n\n if ($sets === []) {\n return;\n }\n\n $params[] = $id;\n $stmt = $this->pdo->prepare(\n 'UPDATE pipeline_configs SET ' . implode(', ', $sets) . ' WHERE id = ?'\n );\n $stmt->execute($params);\n }\n\n public function delete(int $id): void\n {\n $stmt = $this->pdo->prepare('DELETE FROM pipeline_configs WHERE id = ?');\n $stmt->execute([$id]);\n }\n\n public function getStatistics(): array\n {\n $stmt = $this->pdo->query(\n 'SELECT\n (SELECT COUNT(*) FROM pipeline_configs) as pipelines,\n (SELECT COUNT(*) FROM pipeline_runs) as runs_total,\n (SELECT COUNT(*) FROM pipeline_runs WHERE status = \"completed\") as runs_completed,\n (SELECT COUNT(*) FROM pipeline_runs WHERE status = \"failed\") as runs_failed,\n (SELECT COALESCE(SUM(documents_processed), 0) FROM pipeline_runs) as documents_processed,\n (SELECT COALESCE(SUM(chunks_created), 0) FROM pipeline_runs) as chunks_created'\n );\n\n if ($stmt === false) {\n return [\n 'pipelines' => 0,\n 'runs_total' => 0,\n 'runs_completed' => 0,\n 'runs_failed' => 0,\n 'documents_processed' => 0,\n 'chunks_created' => 0,\n ];\n }\n\n $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n return [\n 'pipelines' => (int) ($result['pipelines'] ?? 0),\n 'runs_total' => (int) ($result['runs_total'] ?? 0),\n 'runs_completed' => (int) ($result['runs_completed'] ?? 0),\n 'runs_failed' => (int) ($result['runs_failed'] ?? 0),\n 'documents_processed' => (int) ($result['documents_processed'] ?? 0),\n 'chunks_created' => (int) ($result['chunks_created'] ?? 0),\n ];\n }\n}\n"
}
}
{
"tool_response": {
"type": "create",
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/PipelineConfigRepository.php",
"content": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Persistence;\n\n\/\/ @responsibility: Persistenz für Pipeline-Konfigurationen\n\nuse Domain\\Repository\\PipelineConfigRepositoryInterface;\n\nclass PipelineConfigRepository implements PipelineConfigRepositoryInterface\n{\n private \\PDO $pdo;\n\n public function __construct(\\PDO $pdo)\n {\n $this->pdo = $pdo;\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\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\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 if ($stmt === false) {\n return null;\n }\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\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 if ($stmt === false) {\n return [];\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 create(array $data): int\n {\n $extensions = is_array($data['extensions'] ?? null)\n ? json_encode($data['extensions'])\n : ($data['extensions'] ?? '[]');\n\n $stmt = $this->pdo->prepare(\n 'INSERT INTO pipeline_configs (name, description, is_default, source_path, extensions)\n VALUES (?, ?, ?, ?, ?)'\n );\n $stmt->execute([\n $data['name'],\n $data['description'] ?? null,\n $data['is_default'] ?? 0,\n $data['source_path'] ?? '\/var\/www\/nextcloud\/data\/root\/files\/Documents',\n $extensions,\n ]);\n\n return (int) $this->pdo->lastInsertId();\n }\n\n public function update(int $id, array $data): void\n {\n $sets = [];\n $params = [];\n\n if (isset($data['name'])) {\n $sets[] = 'name = ?';\n $params[] = $data['name'];\n }\n if (isset($data['description'])) {\n $sets[] = 'description = ?';\n $params[] = $data['description'];\n }\n if (isset($data['is_default'])) {\n $sets[] = 'is_default = ?';\n $params[] = $data['is_default'];\n }\n if (isset($data['source_path'])) {\n $sets[] = 'source_path = ?';\n $params[] = $data['source_path'];\n }\n if (isset($data['extensions'])) {\n $sets[] = 'extensions = ?';\n $params[] = is_array($data['extensions'])\n ? json_encode($data['extensions'])\n : $data['extensions'];\n }\n\n if ($sets === []) {\n return;\n }\n\n $params[] = $id;\n $stmt = $this->pdo->prepare(\n 'UPDATE pipeline_configs SET ' . implode(', ', $sets) . ' WHERE id = ?'\n );\n $stmt->execute($params);\n }\n\n public function delete(int $id): void\n {\n $stmt = $this->pdo->prepare('DELETE FROM pipeline_configs WHERE id = ?');\n $stmt->execute([$id]);\n }\n\n public function getStatistics(): array\n {\n $stmt = $this->pdo->query(\n 'SELECT\n (SELECT COUNT(*) FROM pipeline_configs) as pipelines,\n (SELECT COUNT(*) FROM pipeline_runs) as runs_total,\n (SELECT COUNT(*) FROM pipeline_runs WHERE status = \"completed\") as runs_completed,\n (SELECT COUNT(*) FROM pipeline_runs WHERE status = \"failed\") as runs_failed,\n (SELECT COALESCE(SUM(documents_processed), 0) FROM pipeline_runs) as documents_processed,\n (SELECT COALESCE(SUM(chunks_created), 0) FROM pipeline_runs) as chunks_created'\n );\n\n if ($stmt === false) {\n return [\n 'pipelines' => 0,\n 'runs_total' => 0,\n 'runs_completed' => 0,\n 'runs_failed' => 0,\n 'documents_processed' => 0,\n 'chunks_created' => 0,\n ];\n }\n\n $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n return [\n 'pipelines' => (int) ($result['pipelines'] ?? 0),\n 'runs_total' => (int) ($result['runs_total'] ?? 0),\n 'runs_completed' => (int) ($result['runs_completed'] ?? 0),\n 'runs_failed' => (int) ($result['runs_failed'] ?? 0),\n 'documents_processed' => (int) ($result['documents_processed'] ?? 0),\n 'chunks_created' => (int) ($result['chunks_created'] ?? 0),\n ];\n }\n}\n",
"structuredPatch": [],
"originalFile": null
}
}