Protokoll #3069

{
    "event": "PreToolUse",
    "tool_name": "Write",
    "tool_input": {
        "file_path": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/ChatMessageRepository.php",
        "content": "<?php\n\nnamespace Infrastructure\\Persistence;\n\nuse Domain\\Repository\\ChatMessageRepositoryInterface;\nuse Infrastructure\\Config\\DatabaseFactory;\n\n\/**\n * Repository for Chat Message operations.\n *\/\nclass ChatMessageRepository implements ChatMessageRepositoryInterface\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 findBySessionId(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 save(\n        int $sessionId,\n        string $role,\n        string $content,\n        string $model,\n        ?int $tokensInput = null,\n        ?int $tokensOutput = null,\n        ?array $sources = null,\n        ?float $startMicrotime = null,\n        ?float $endMicrotime = null,\n        ?int $authorProfileId = null,\n        ?int $systemPromptId = null,\n        ?string $collectionsJson = null,\n        ?int $contextLimit = null\n    ): int {\n        $stmt = $this->pdo->prepare(\n            'INSERT INTO chat_messages\n             (session_id, role, content, model, tokens_input, tokens_output, sources,\n              start_microtime, end_microtime, author_profile_id, system_prompt_id, collections, context_limit)\n             VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)'\n        );\n        $stmt->execute([\n            $sessionId,\n            $role,\n            $content,\n            $model,\n            $tokensInput,\n            $tokensOutput,\n            $sources !== null ? json_encode($sources) : null,\n            $startMicrotime,\n            $endMicrotime,\n            $authorProfileId,\n            $systemPromptId,\n            $collectionsJson,\n            $contextLimit,\n        ]);\n\n        \/\/ Update session timestamp\n        $this->pdo->prepare('UPDATE chat_sessions SET updated_at = NOW() WHERE id = ?')\n            ->execute([$sessionId]);\n\n        return (int) $this->pdo->lastInsertId();\n    }\n\n    public function delete(int $id): void\n    {\n        $stmt = $this->pdo->prepare('DELETE FROM chat_messages WHERE id = ?');\n        $stmt->execute([$id]);\n    }\n\n    public function deleteBySessionId(int $sessionId): void\n    {\n        $stmt = $this->pdo->prepare('DELETE FROM chat_messages WHERE session_id = ?');\n        $stmt->execute([$sessionId]);\n    }\n\n    public function getSessionStats(int $sessionId): array\n    {\n        $stmt = $this->pdo->prepare(\n            'SELECT\n                COUNT(*) as message_count,\n                COALESCE(SUM(tokens_input), 0) as total_input_tokens,\n                COALESCE(SUM(tokens_output), 0) as total_output_tokens,\n                COALESCE(SUM(end_microtime - start_microtime), 0) as total_duration\n             FROM chat_messages\n             WHERE session_id = ?'\n        );\n        $stmt->execute([$sessionId]);\n\n        return $stmt->fetch(\\PDO::FETCH_ASSOC);\n    }\n}\n"
    }
}

{
    "tool_response": {
        "type": "create",
        "filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/Infrastructure\/Persistence\/ChatMessageRepository.php",
        "content": "<?php\n\nnamespace Infrastructure\\Persistence;\n\nuse Domain\\Repository\\ChatMessageRepositoryInterface;\nuse Infrastructure\\Config\\DatabaseFactory;\n\n\/**\n * Repository for Chat Message operations.\n *\/\nclass ChatMessageRepository implements ChatMessageRepositoryInterface\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 findBySessionId(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 save(\n        int $sessionId,\n        string $role,\n        string $content,\n        string $model,\n        ?int $tokensInput = null,\n        ?int $tokensOutput = null,\n        ?array $sources = null,\n        ?float $startMicrotime = null,\n        ?float $endMicrotime = null,\n        ?int $authorProfileId = null,\n        ?int $systemPromptId = null,\n        ?string $collectionsJson = null,\n        ?int $contextLimit = null\n    ): int {\n        $stmt = $this->pdo->prepare(\n            'INSERT INTO chat_messages\n             (session_id, role, content, model, tokens_input, tokens_output, sources,\n              start_microtime, end_microtime, author_profile_id, system_prompt_id, collections, context_limit)\n             VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)'\n        );\n        $stmt->execute([\n            $sessionId,\n            $role,\n            $content,\n            $model,\n            $tokensInput,\n            $tokensOutput,\n            $sources !== null ? json_encode($sources) : null,\n            $startMicrotime,\n            $endMicrotime,\n            $authorProfileId,\n            $systemPromptId,\n            $collectionsJson,\n            $contextLimit,\n        ]);\n\n        \/\/ Update session timestamp\n        $this->pdo->prepare('UPDATE chat_sessions SET updated_at = NOW() WHERE id = ?')\n            ->execute([$sessionId]);\n\n        return (int) $this->pdo->lastInsertId();\n    }\n\n    public function delete(int $id): void\n    {\n        $stmt = $this->pdo->prepare('DELETE FROM chat_messages WHERE id = ?');\n        $stmt->execute([$id]);\n    }\n\n    public function deleteBySessionId(int $sessionId): void\n    {\n        $stmt = $this->pdo->prepare('DELETE FROM chat_messages WHERE session_id = ?');\n        $stmt->execute([$sessionId]);\n    }\n\n    public function getSessionStats(int $sessionId): array\n    {\n        $stmt = $this->pdo->prepare(\n            'SELECT\n                COUNT(*) as message_count,\n                COALESCE(SUM(tokens_input), 0) as total_input_tokens,\n                COALESCE(SUM(tokens_output), 0) as total_output_tokens,\n                COALESCE(SUM(end_microtime - start_microtime), 0) as total_duration\n             FROM chat_messages\n             WHERE session_id = ?'\n        );\n        $stmt->execute([$sessionId]);\n\n        return $stmt->fetch(\\PDO::FETCH_ASSOC);\n    }\n}\n",
        "structuredPatch": [],
        "originalFile": null
    }
}