{
"event": "PreToolUse",
"tool_name": "Write",
"tool_input": {
"file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/ChatRepository.php",
"content": "<?php\n\nnamespace Infrastructure\\Persistence;\n\nuse Infrastructure\\Config\\DatabaseFactory;\n\nclass ChatRepository\n{\n private \\PDO $pdo;\n\n public function __construct(?\\PDO $pdo = null)\n {\n $this->pdo = $pdo ?? DatabaseFactory::content();\n }\n\n public function findSessionByUuid(string $uuid): ?array\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 ? $result : null;\n }\n\n public function findAllSessions(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 ' . (int) $limit\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function createSession(string $uuid, string $model = 'claude-opus-4-5-20251101', array $collections = ['documents'], int $contextLimit = 5): int\n {\n $stmt = $this->pdo->prepare(\n 'INSERT INTO chat_sessions (uuid, model, collections, context_limit) VALUES (?, ?, ?, ?)'\n );\n $stmt->execute([$uuid, $model, json_encode($collections), $contextLimit]);\n\n return (int) $this->pdo->lastInsertId();\n }\n\n public function findMessages(int $sessionId): array\n {\n $stmt = $this->pdo->prepare(\n 'SELECT * FROM chat_messages WHERE session_id = ? ORDER BY created_at ASC'\n );\n $stmt->execute([$sessionId]);\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function updateSessionTitle(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 updateSessionSettings(\n int $sessionId,\n string $model,\n array $collections,\n int $contextLimit = 5,\n ?int $authorProfileId = null,\n float $temperature = 0.7,\n int $maxTokens = 4096\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,\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 deleteSession(int $sessionId): void\n {\n $stmt = $this->pdo->prepare('DELETE FROM chat_sessions WHERE id = ?');\n $stmt->execute([$sessionId]);\n }\n\n public function findAuthorProfiles(): array\n {\n $stmt = $this->pdo->query(\n \"SELECT id, name, slug, content as config\n FROM content_config\n WHERE type = 'author_profile' AND status = 'active'\n ORDER BY name\"\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function findAuthorProfileById(int $profileId): ?array\n {\n $stmt = $this->pdo->prepare(\n \"SELECT id, name, slug, content as config\n FROM content_config\n WHERE id = ? AND type = 'author_profile' AND status = 'active'\"\n );\n $stmt->execute([$profileId]);\n $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n return $result !== false ? $result : null;\n }\n\n public function findSystemPrompts(): array\n {\n $stmt = $this->pdo->query(\n \"SELECT id, name, slug, content\n FROM content_config\n WHERE type = 'system_prompt' AND status = 'active'\n ORDER BY name\"\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function logSystemPromptChange(array $logData): void\n {\n try {\n $devDb = DatabaseFactory::dev();\n $stmt = $devDb->prepare(\n \"INSERT INTO mcp_log (tool, operation, parameters, result, logged_at)\n VALUES ('chat', 'system_prompt_change', :params, 'logged', NOW())\"\n );\n $stmt->execute(['params' => json_encode($logData)]);\n } catch (\\Exception $e) {\n \/\/ Silently fail - logging should not break functionality\n }\n }\n}\n"
}
}
{
"tool_response": {
"type": "create",
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/ChatRepository.php",
"content": "<?php\n\nnamespace Infrastructure\\Persistence;\n\nuse Infrastructure\\Config\\DatabaseFactory;\n\nclass ChatRepository\n{\n private \\PDO $pdo;\n\n public function __construct(?\\PDO $pdo = null)\n {\n $this->pdo = $pdo ?? DatabaseFactory::content();\n }\n\n public function findSessionByUuid(string $uuid): ?array\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 ? $result : null;\n }\n\n public function findAllSessions(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 ' . (int) $limit\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function createSession(string $uuid, string $model = 'claude-opus-4-5-20251101', array $collections = ['documents'], int $contextLimit = 5): int\n {\n $stmt = $this->pdo->prepare(\n 'INSERT INTO chat_sessions (uuid, model, collections, context_limit) VALUES (?, ?, ?, ?)'\n );\n $stmt->execute([$uuid, $model, json_encode($collections), $contextLimit]);\n\n return (int) $this->pdo->lastInsertId();\n }\n\n public function findMessages(int $sessionId): array\n {\n $stmt = $this->pdo->prepare(\n 'SELECT * FROM chat_messages WHERE session_id = ? ORDER BY created_at ASC'\n );\n $stmt->execute([$sessionId]);\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function updateSessionTitle(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 updateSessionSettings(\n int $sessionId,\n string $model,\n array $collections,\n int $contextLimit = 5,\n ?int $authorProfileId = null,\n float $temperature = 0.7,\n int $maxTokens = 4096\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,\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 deleteSession(int $sessionId): void\n {\n $stmt = $this->pdo->prepare('DELETE FROM chat_sessions WHERE id = ?');\n $stmt->execute([$sessionId]);\n }\n\n public function findAuthorProfiles(): array\n {\n $stmt = $this->pdo->query(\n \"SELECT id, name, slug, content as config\n FROM content_config\n WHERE type = 'author_profile' AND status = 'active'\n ORDER BY name\"\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function findAuthorProfileById(int $profileId): ?array\n {\n $stmt = $this->pdo->prepare(\n \"SELECT id, name, slug, content as config\n FROM content_config\n WHERE id = ? AND type = 'author_profile' AND status = 'active'\"\n );\n $stmt->execute([$profileId]);\n $result = $stmt->fetch(\\PDO::FETCH_ASSOC);\n\n return $result !== false ? $result : null;\n }\n\n public function findSystemPrompts(): array\n {\n $stmt = $this->pdo->query(\n \"SELECT id, name, slug, content\n FROM content_config\n WHERE type = 'system_prompt' AND status = 'active'\n ORDER BY name\"\n );\n\n return $stmt->fetchAll(\\PDO::FETCH_ASSOC);\n }\n\n public function logSystemPromptChange(array $logData): void\n {\n try {\n $devDb = DatabaseFactory::dev();\n $stmt = $devDb->prepare(\n \"INSERT INTO mcp_log (tool, operation, parameters, result, logged_at)\n VALUES ('chat', 'system_prompt_change', :params, 'logged', NOW())\"\n );\n $stmt->execute(['params' => json_encode($logData)]);\n } catch (\\Exception $e) {\n \/\/ Silently fail - logging should not break functionality\n }\n }\n}\n",
"structuredPatch": [],
"originalFile": null
}
}