{
"tool_response": {
"type": "text",
"file": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/ChatSessionRepository.php",
"content": "<?php\n\ndeclare(strict_types=1);\n\nnamespace Infrastructure\\Persistence;\n\n\/\/ @responsibility: Persistenz für Chat-Sessions (CRUD, UUID-Lookup)\n\nuse Domain\\Entity\\ChatSession;\nuse Domain\\Repository\\ChatSessionRepositoryInterface;\n\nclass ChatSessionRepository implements ChatSessionRepositoryInterface\n{\n private \\PDO $pdo;\n\n public function __construct(\\PDO $pdo)\n {\n $this->pdo = $pdo;\n }\n\n public function findByUuid(string $uuid): ?ChatSession\n {\n $stmt = $this->pdo->prepare('SELECT * FROM chat_sessions WHERE uuid = ?');\n $stmt->execute([$uuid]);\n $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n return $result !== false ? ChatSession::fromArray($result) : null;\n }\n\n public function findAll(int $limit = 50): array\n {\n $stmt = $this->pdo->query(\n 'SELECT * FROM chat_sessions ORDER BY last_activity DESC LIMIT ' . $limit\n );\n\n $sessions = [];\n foreach ($stmt->fetchAll(\\PDO::FETCH_ASSOC) as $row) {\n $sessions[] = ChatSession::fromArray($row);\n }\n\n return $sessions;\n }\n\n public function findAllWithStats(int $limit = 50): array\n {\n $stmt = $this->pdo->query(\n 'SELECT s.*,\n (SELECT COUNT(*) FROM chat_messages WHERE session_id = s.id) as message_count,\n (SELECT COALESCE(SUM(tokens_input), 0) FROM chat_messages WHERE session_id = s.id) as total_input_tokens,\n (SELECT COALESCE(SUM(tokens_output), 0) FROM chat_messages WHERE session_id = s.id) as total_output_tokens,\n (SELECT COALESCE(SUM(end_microtime - start_microtime), 0) FROM chat_messages WHERE session_id = s.id AND start_microtime IS NOT NULL) as total_duration,\n (SELECT model FROM chat_messages WHERE session_id = s.id AND role = \"assistant\" ORDER BY id DESC LIMIT 1) as last_model\n FROM chat_sessions s\n ORDER BY s.last_activity DESC\n LIMIT ' . $limit\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function save(ChatSession $session): int\n {\n if ($session->getId() !== null) {\n \/\/ Update\n $stmt = $this->pdo->prepare(\n 'UPDATE chat_sessions SET\n title = ?, model = ?, collections = ?, context_limit = ?,\n temperature = ?, max_tokens = ?, author_profile_id = ?,\n system_prompt_id = ?, updated_at = NOW()\n WHERE id = ?'\n );\n $stmt->execute([\n $session->getTitle(),\n $session->getModel(),\n json_encode($session->getCollections()),\n $session->getContextLimit(),\n $session->getTemperature(),\n $session->getMaxTokens(),\n $session->getAuthorProfileId(),\n $session->getSystemPromptId(),\n $session->getId(),\n ]);\n\n return $session->getId();\n }\n\n \/\/ Insert\n $stmt = $this->pdo->prepare(\n 'INSERT INTO chat_sessions (uuid, model, collections, context_limit, temperature, max_tokens)\n VALUES (?, ?, ?, ?, ?, ?)'\n );\n $stmt->execute([\n $session->getUuid(),\n $session->getModel(),\n json_encode($session->getCollections()),\n $session->getContextLimit(),\n $session->getTemperature(),\n $session->getMaxTokens(),\n ]);\n\n return (int) $this->pdo->lastInsertId();\n }\n\n public function create(string $uuid, string $model, string $collections, int $contextLimit): int\n {\n $stmt = $this->pdo->prepare(\n 'INSERT INTO chat_sessions (uuid, model, collections, context_limit) VALUES (?, ?, ?, ?)'\n );\n $stmt->execute([$uuid, $model, $collections, $contextLimit]);\n\n return (int) $this->pdo->lastInsertId();\n }\n\n public function updateTitle(int $sessionId, string $title): void\n {\n $stmt = $this->pdo->prepare('UPDATE chat_sessions SET title = ? WHERE id = ?');\n $stmt->execute([$title, $sessionId]);\n }\n\n public function updateSettings(\n int $sessionId,\n string $model,\n array $collections,\n int $contextLimit,\n ?int $authorProfileId,\n float $temperature,\n int $maxTokens\n ): void {\n $collectionsJson = json_encode($collections);\n $stmt = $this->pdo->prepare(\n 'UPDATE chat_sessions SET model = ?, collections = ?, context_limit = ?, author_profile_id = ?, temperature = ?, max_tokens = ? WHERE id = ?'\n );\n $stmt->execute([\n $model,\n $collectionsJson,\n $contextLimit,\n $authorProfileId > 0 ? $authorProfileId : null,\n $temperature,\n $maxTokens,\n $sessionId,\n ]);\n }\n\n public function updateSystemPrompt(int $sessionId, ?string $systemPrompt): void\n {\n $stmt = $this->pdo->prepare('UPDATE chat_sessions SET system_prompt = ? WHERE id = ?');\n $stmt->execute([$systemPrompt !== '' ? $systemPrompt : null, $sessionId]);\n }\n\n public function delete(int $sessionId): void\n {\n $stmt = $this->pdo->prepare('DELETE FROM chat_sessions WHERE id = ?');\n $stmt->execute([$sessionId]);\n }\n\n public function touch(int $sessionId): void\n {\n $stmt = $this->pdo->prepare('UPDATE chat_sessions SET updated_at = NOW() WHERE id = ?');\n $stmt->execute([$sessionId]);\n }\n\n public function generateUuid(): string\n {\n $data = random_bytes(16);\n $data[6] = chr(ord($data[6]) & 0x0f | 0x40);\n $data[8] = chr(ord($data[8]) & 0x3f | 0x80);\n\n return vsprintf('%s%s-%s-%s-%s-%s%s%s', str_split(bin2hex($data), 4));\n }\n}\n",
"numLines": 171,
"startLine": 1,
"totalLines": 171
}
}
}