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