{
"event": "PreToolUse",
"tool_name": "Read",
"tool_input": {
"file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/KiProtokollRepository.php"
}
}
{
"tool_response": {
"type": "text",
"file": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/KiProtokollRepository.php",
"content": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Persistence;\n\n\/\/ @responsibility: Persistenz für KI-Protokoll (Claude-Konversationen)\n\nuse Domain\\Repository\\KiProtokollRepositoryInterface;\n\nclass KiProtokollRepository implements KiProtokollRepositoryInterface\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 protokoll WHERE id = ?');\n $stmt->execute([$id]);\n $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n return $result !== false ? $result : null;\n }\n\n public function findLatest(int $limit = 20): array\n {\n $stmt = $this->pdo->prepare(\n 'SELECT id, timestamp, client_name, request, status, duration_ms\n FROM protokoll ORDER BY id DESC LIMIT ?'\n );\n $stmt->bindValue(1, $limit, \\PDO::PARAM_INT);\n $stmt->execute();\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function findPaginated(\n ?string $search = null,\n ?string $status = null,\n ?string $model = null,\n int $limit = 50,\n int $offset = 0\n ): array {\n $sql = 'SELECT id, timestamp, client_name, model_name, status, tokens_total, duration_ms,\n LEFT(request, 200) as request_preview\n FROM protokoll WHERE 1=1';\n $params = [];\n\n if ($search !== null && $search !== '') {\n $sql .= ' AND (request LIKE ? OR response LIKE ? OR client_name LIKE ?)';\n $params[] = '%' . $search . '%';\n $params[] = '%' . $search . '%';\n $params[] = '%' . $search . '%';\n }\n\n if ($status !== null && $status !== '') {\n $sql .= ' AND status = ?';\n $params[] = $status;\n }\n\n if ($model !== null && $model !== '') {\n $sql .= ' AND model_name = ?';\n $params[] = $model;\n }\n\n $sql .= ' ORDER BY timestamp DESC LIMIT ? OFFSET ?';\n\n $stmt = $this->pdo->prepare($sql);\n $paramIndex = 1;\n foreach ($params as $value) {\n $stmt->bindValue($paramIndex++, $value);\n }\n $stmt->bindValue($paramIndex++, $limit, \\PDO::PARAM_INT);\n $stmt->bindValue($paramIndex, $offset, \\PDO::PARAM_INT);\n $stmt->execute();\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function countFiltered(?string $search = null, ?string $status = null, ?string $model = null): int\n {\n $sql = 'SELECT COUNT(*) FROM protokoll WHERE 1=1';\n $params = [];\n\n if ($search !== null && $search !== '') {\n $sql .= ' AND (request LIKE ? OR response LIKE ? OR client_name LIKE ?)';\n $params[] = '%' . $search . '%';\n $params[] = '%' . $search . '%';\n $params[] = '%' . $search . '%';\n }\n\n if ($status !== null && $status !== '') {\n $sql .= ' AND status = ?';\n $params[] = $status;\n }\n\n if ($model !== null && $model !== '') {\n $sql .= ' AND model_name = ?';\n $params[] = $model;\n }\n\n $stmt = $this->pdo->prepare($sql);\n $stmt->execute($params);\n\n return (int) $stmt->fetchColumn();\n }\n\n public function getStatistics(): array\n {\n $stmt = $this->pdo->query(\n 'SELECT\n COUNT(*) as total,\n SUM(CASE WHEN status = \"completed\" THEN 1 ELSE 0 END) as completed,\n SUM(CASE WHEN status = \"error\" THEN 1 ELSE 0 END) as errors,\n COALESCE(SUM(tokens_total), 0) as tokens_total,\n COALESCE(SUM(duration_ms), 0) as duration_total\n FROM protokoll'\n );\n\n return $stmt->fetch(\\PDO::FETCH_ASSOC);\n }\n\n public function getDistinctModels(): array\n {\n $stmt = $this->pdo->query(\n 'SELECT DISTINCT model_name FROM protokoll WHERE model_name IS NOT NULL ORDER BY model_name'\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_COLUMN);\n }\n\n public function findPreviousId(int $id): ?int\n {\n $stmt = $this->pdo->prepare('SELECT id FROM protokoll WHERE id < ? ORDER BY id DESC LIMIT 1');\n $stmt->execute([$id]);\n $result = $stmt->fetchColumn();\n\n return $result !== false ? (int) $result : null;\n }\n\n public function findNextId(int $id): ?int\n {\n $stmt = $this->pdo->prepare('SELECT id FROM protokoll WHERE id > ? ORDER BY id ASC LIMIT 1');\n $stmt->execute([$id]);\n $result = $stmt->fetchColumn();\n\n return $result !== false ? (int) $result : null;\n }\n}\n",
"numLines": 154,
"startLine": 1,
"totalLines": 154
}
}
}