{
"event": "PreToolUse",
"tool_name": "Edit",
"tool_input": {
"file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/KiProtokollRepository.php",
"old_string": " public function fail(int $id, string $errorMessage): void\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET\n response_timestamp = NOW(6),\n status = \\'error\\',\n error_message = :error\n WHERE id = :id'\n );\n\n $stmt->execute([\n 'error' => $errorMessage,\n 'id' => $id,\n ]);\n }",
"new_string": " public function fail(int $id, string $errorMessage): void\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET\n response_timestamp = NOW(6),\n status = \\'error\\',\n error_message = :error\n WHERE id = :id'\n );\n\n $stmt->execute([\n 'error' => $errorMessage,\n 'id' => $id,\n ]);\n }\n\n public function updateRequest(int $id, string $fullRequest): void\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET request = :request WHERE id = :id'\n );\n\n $stmt->execute([\n 'request' => $fullRequest,\n 'id' => $id,\n ]);\n }"
}
}
{
"tool_response": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/KiProtokollRepository.php",
"oldString": " public function fail(int $id, string $errorMessage): void\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET\n response_timestamp = NOW(6),\n status = \\'error\\',\n error_message = :error\n WHERE id = :id'\n );\n\n $stmt->execute([\n 'error' => $errorMessage,\n 'id' => $id,\n ]);\n }",
"newString": " public function fail(int $id, string $errorMessage): void\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET\n response_timestamp = NOW(6),\n status = \\'error\\',\n error_message = :error\n WHERE id = :id'\n );\n\n $stmt->execute([\n 'error' => $errorMessage,\n 'id' => $id,\n ]);\n }\n\n public function updateRequest(int $id, string $fullRequest): void\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET request = :request WHERE id = :id'\n );\n\n $stmt->execute([\n 'request' => $fullRequest,\n 'id' => $id,\n ]);\n }",
"originalFile": "<?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 public function insert(\n string $clientName,\n string $request,\n string $model,\n string $requestIp\n ): int {\n $stmt = $this->pdo->prepare(\n 'INSERT INTO protokoll (request_ip, client_name, request, request_timestamp, model_name, status)\n VALUES (:ip, :client, :request, NOW(6), :model, \\'pending\\')'\n );\n\n $stmt->execute([\n 'ip' => $requestIp,\n 'client' => $clientName,\n 'request' => $request,\n 'model' => $model,\n ]);\n\n return (int) $this->pdo->lastInsertId();\n }\n\n public function complete(\n int $id,\n string $response,\n int $durationMs,\n ?int $tokensInput,\n ?int $tokensOutput\n ): void {\n \/\/ Guard: duration never negative\n $durationMs = max(0, $durationMs);\n\n \/\/ Calculate tokens_total in repository (contract)\n $tokensTotal = ($tokensInput ?? 0) + ($tokensOutput ?? 0);\n\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET\n response = :response,\n response_timestamp = NOW(6),\n duration_ms = :duration,\n tokens_input = :ti,\n tokens_output = :to,\n tokens_total = :tt,\n status = \\'completed\\'\n WHERE id = :id'\n );\n\n $stmt->execute([\n 'response' => $response,\n 'duration' => $durationMs,\n 'ti' => $tokensInput,\n 'to' => $tokensOutput,\n 'tt' => $tokensTotal > 0 ? $tokensTotal : null,\n 'id' => $id,\n ]);\n }\n\n public function fail(int $id, string $errorMessage): void\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET\n response_timestamp = NOW(6),\n status = \\'error\\',\n error_message = :error\n WHERE id = :id'\n );\n\n $stmt->execute([\n 'error' => $errorMessage,\n 'id' => $id,\n ]);\n }\n\n public function cleanupStale(int $minutesOld = 10): int\n {\n $stmt = $this->pdo->prepare(\n 'UPDATE protokoll SET\n status = \\'error\\',\n error_message = \\'Timeout: No response within configured minutes\\'\n WHERE status = \\'pending\\'\n AND request_timestamp < NOW() - INTERVAL :minutes MINUTE'\n );\n\n $stmt->execute(['minutes' => $minutesOld]);\n\n return $stmt->rowCount();\n }\n}\n",
"structuredPatch": [
{
"oldStart": 223,
"oldLines": 6,
"newStart": 223,
"newLines": 18,
"lines": [
" ]);",
" }",
" ",
"+ public function updateRequest(int $id, string $fullRequest): void",
"+ {",
"+ $stmt = $this->pdo->prepare(",
"+ 'UPDATE protokoll SET request = :request WHERE id = :id'",
"+ );",
"+",
"+ $stmt->execute([",
"+ 'request' => $fullRequest,",
"+ 'id' => $id,",
"+ ]);",
"+ }",
"+",
" public function cleanupStale(int $minutesOld = 10): int",
" {",
" $stmt = $this->pdo->prepare("
]
}
],
"userModified": false,
"replaceAll": false
}
}