';
}
}
/**
* POST /chat/{uuid}/title (HTMX)
* Update session title
*/
public function updateTitle(string $uuid): void
{
$session = $this->getSession($uuid);
if ($session === null) {
http_response_code(404);
echo '';
return;
}
$title = trim($_POST['title'] ?? '');
// Validate title
if ($title === '') {
$title = 'Neuer Chat';
}
// Max 100 characters
$title = mb_substr($title, 0, 100);
// Save to database
$this->updateSessionTitle($session['id'], $title);
// Return updated title HTML
echo htmlspecialchars($title);
}
/**
* POST /chat/{uuid}/system-prompt (HTMX)
* Update session system prompt
*/
public function systemPrompt(string $uuid): void
{
$session = $this->getSession($uuid);
if ($session === null) {
http_response_code(404);
echo '
Session nicht gefunden.
';
return;
}
$systemPrompt = trim($_POST['system_prompt'] ?? '');
// Validate and sanitize system prompt
$systemPrompt = $this->validateSystemPrompt($systemPrompt);
// Save to database
$this->updateSystemPrompt($session['id'], $systemPrompt);
// Return success message
echo '
System-Prompt gespeichert.
';
}
/**
* GET /chat/{uuid}/system-prompt (HTMX)
* Get system prompt form
*/
public function getSystemPrompt(string $uuid): void
{
$session = $this->getSession($uuid);
if ($session === null) {
http_response_code(404);
echo '
Session nicht gefunden.
';
return;
}
$defaultPrompt = $this->getDefaultSystemPrompt();
$currentPrompt = $session['system_prompt'] ?? '';
$this->view('chat.partials.system-prompt-modal', [
'session' => $session,
'currentPrompt' => $currentPrompt,
'defaultPrompt' => $defaultPrompt,
]);
}
/**
* DELETE /chat/{uuid}
* Delete a session
*/
public function delete(string $uuid): void
{
$session = $this->getSession($uuid);
if ($session !== null) {
$stmt = $this->db->prepare('DELETE FROM chat_sessions WHERE id = ?');
$stmt->execute([$session['id']]);
}
// Return success for HTMX
header('HX-Redirect: /chat');
echo 'OK';
}
// ========== Private Helper Methods ==========
/**
* Initialize database connection
*/
private function initializeDatabase(): \PDO
{
$credentials = $this->loadCredentials();
return new \PDO(
'mysql:host=localhost;dbname=ki_content;charset=utf8mb4',
'root',
$credentials['db_password'],
[\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION]
);
}
/**
* Load credentials from file
*/
private function loadCredentials(): array
{
$file = '/var/www/docs/credentials/credentials.md';
$content = file_get_contents($file);
$password = '';
foreach (explode("\n", $content) as $line) {
if (str_contains($line, 'MariaDB') && str_contains($line, 'root')) {
$parts = explode('|', $line);
if (count($parts) >= 4) {
$password = trim($parts[3]);
break;
}
}
}
return ['db_password' => $password];
}
/**
* Create a new chat session
*/
private function createSession(): string
{
$uuid = $this->generateUuid();
$stmt = $this->db->prepare(
'INSERT INTO chat_sessions (uuid, model, collection, context_limit) VALUES (?, ?, ?, ?)'
);
$stmt->execute([$uuid, 'claude-opus-4-5-20251101', 'documents', 5]);
return $uuid;
}
/**
* Get session by UUID
*/
private function getSession(string $uuid): ?array
{
$stmt = $this->db->prepare('SELECT * FROM chat_sessions WHERE uuid = ?');
$stmt->execute([$uuid]);
$result = $stmt->fetch(\PDO::FETCH_ASSOC);
return $result !== false ? $result : null;
}
/**
* Get all sessions ordered by most recent
*/
private function getSessions(): array
{
$stmt = $this->db->query(
'SELECT s.*,
(SELECT COUNT(*) FROM chat_messages WHERE session_id = s.id) as message_count,
(SELECT COALESCE(SUM(tokens_input), 0) FROM chat_messages WHERE session_id = s.id) as total_input_tokens,
(SELECT COALESCE(SUM(tokens_output), 0) FROM chat_messages WHERE session_id = s.id) as total_output_tokens,
(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,
(SELECT model FROM chat_messages WHERE session_id = s.id AND role = "assistant" ORDER BY id DESC LIMIT 1) as last_model
FROM chat_sessions s
ORDER BY s.updated_at DESC
LIMIT 50'
);
return $stmt->fetchAll(\PDO::FETCH_ASSOC);
}
/**
* Get author profiles from ki_content database
*/
private function getAuthorProfiles(): array
{
$credentials = $this->loadCredentials();
$dbSystem = new \PDO(
'mysql:host=localhost;dbname=ki_content;charset=utf8mb4',
'root',
$credentials['db_password'],
[\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION]
);
$stmt = $dbSystem->query('SELECT id, name, slug, config FROM author_profiles WHERE is_active = 1 ORDER BY id');
return $stmt->fetchAll(\PDO::FETCH_ASSOC);
}
/**
* Get author profile by ID
*/
private function getAuthorProfile(int $profileId): ?array
{
$profiles = $this->getAuthorProfiles();
foreach ($profiles as $profile) {
if ((int) $profile['id'] === $profileId) {
return $profile;
}
}
return null;
}
/**
* Get messages for a session
*/
private function getMessages(int $sessionId): array
{
$stmt = $this->db->prepare(
'SELECT * FROM chat_messages WHERE session_id = ? ORDER BY created_at ASC'
);
$stmt->execute([$sessionId]);
return $stmt->fetchAll(\PDO::FETCH_ASSOC);
}
/**
* Save a message to the database
*/
private function saveMessage(
int $sessionId,
string $role,
string $content,
string $model,
?int $tokensInput = null,
?int $tokensOutput = null,
array $sources = [],
?float $startMicrotime = null,
?float $endMicrotime = null,
?int $authorProfileId = null,
?int $systemPromptId = null,
?string $collection = null,
?int $contextLimit = null
): void {
$stmt = $this->db->prepare(
'INSERT INTO chat_messages
(session_id, role, content, model, tokens_input, tokens_output, sources,
start_microtime, end_microtime, author_profile_id, system_prompt_id, collection, context_limit)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)'
);
$stmt->execute([
$sessionId,
$role,
$content,
$model,
$tokensInput,
$tokensOutput,
$sources !== [] ? json_encode($sources) : null,
$startMicrotime,
$endMicrotime,
$authorProfileId,
$systemPromptId,
$collection,
$contextLimit,
]);
// Update session timestamp
$this->db->prepare('UPDATE chat_sessions SET updated_at = NOW() WHERE id = ?')
->execute([$sessionId]);
}
/**
* Update session title
*/
private function updateSessionTitle(int $sessionId, string $title): void
{
$stmt = $this->db->prepare('UPDATE chat_sessions SET title = ? WHERE id = ?');
$stmt->execute([$title, $sessionId]);
}
/**
* Generate UUID v4
*/
private function generateUuid(): string
{
$data = random_bytes(16);
$data[6] = chr(ord($data[6]) & 0x0f | 0x40);
$data[8] = chr(ord($data[8]) & 0x3f | 0x80);
return vsprintf('%s%s-%s-%s-%s-%s%s%s', str_split(bin2hex($data), 4));
}
/**
* Initialize ChatService with all required AI services
*/
private function initializeChatService(): ChatService
{
$config = AIConfig::fromCredentialsFile();
return $config->createChatService();
}
/**
* Validate model parameter
* Format: claude-* or ollama:*
*/
private function validateModel(string $model): string
{
if (str_starts_with($model, 'claude-') || str_starts_with($model, 'ollama:')) {
return $model;
}
return 'claude-opus-4-5-20251101';
}
/**
* Validate collection parameter against allowed values
*/
private function validateCollection(string $collection): string
{
$allowedCollections = ['documents', 'entities', 'dokumentation', 'dokumentation_chunks', 'mail'];
return in_array($collection, $allowedCollections, true) ? $collection : 'documents';
}
/**
* Validate context limit parameter against allowed values
*/
private function validateContextLimit(int $limit): int
{
$allowedLimits = [3, 5, 10, 15];
return in_array($limit, $allowedLimits, true) ? $limit : 5;
}
/**
* Validate author profile ID (0 = no profile)
*/
private function validateAuthorProfileId(int $profileId): int
{
if ($profileId === 0) {
return 0;
}
$profile = $this->getAuthorProfile($profileId);
return $profile !== null ? $profileId : 0;
}
/**
* Generate style prompt from author profile config
*/
private function getStylePromptFromProfile(int $profileId): ?string
{
if ($profileId === 0) {
return null;
}
$profile = $this->getAuthorProfile($profileId);
if ($profile === null) {
return null;
}
$config = json_decode($profile['config'], true);
if ($config === null) {
return null;
}
$parts = [];
// Build style instructions from config
if (isset($config['stimme']['ton'])) {
$parts[] = 'Ton: ' . $config['stimme']['ton'];
}
if (isset($config['stimme']['perspektive'])) {
$parts[] = 'Perspektive: ' . $config['stimme']['perspektive'];
}
if (isset($config['stil']['fachsprache']) && $config['stil']['fachsprache']) {
$parts[] = 'Verwende Fachsprache';
}
if (isset($config['stil']['beispiele']) && $config['stil']['beispiele'] === 'häufig') {
$parts[] = 'Nutze häufig Beispiele';
}
if (isset($config['stil']['listen']) && $config['stil']['listen'] === 'bevorzugt') {
$parts[] = 'Bevorzuge Listen und Bullet-Points';
}
if (isset($config['tabus']) && is_array($config['tabus'])) {
$parts[] = 'Vermeide: ' . implode(', ', $config['tabus']);
}
if ($parts === []) {
return null;
}
return 'Schreibstil (' . $profile['name'] . '): ' . implode('. ', $parts) . '.';
}
/**
* Update session model, collection, context limit and author profile settings
*/
private function updateSessionSettings(int $sessionId, string $model, string $collection, int $contextLimit = 5, int $authorProfileId = 0): void
{
$stmt = $this->db->prepare('UPDATE chat_sessions SET model = ?, collection = ?, context_limit = ?, author_profile_id = ? WHERE id = ?');
$stmt->execute([$model, $collection, $contextLimit, $authorProfileId > 0 ? $authorProfileId : null, $sessionId]);
}
/**
* Validate and sanitize system prompt
*/
private function validateSystemPrompt(string $prompt): string
{
// Max length: 2000 characters
$prompt = mb_substr($prompt, 0, 2000);
// Remove potentially dangerous patterns
$dangerousPatterns = [
'/ignore\s+(all\s+)?previous\s+instructions/i',
'/forget\s+(all\s+)?previous/i',
'/disregard\s+(all\s+)?instructions/i',
'/system\s*:\s*override/i',
];
foreach ($dangerousPatterns as $pattern) {
$prompt = preg_replace($pattern, '[removed]', $prompt) ?? $prompt;
}
return trim($prompt);
}
/**
* Update session system prompt
*/
private function updateSystemPrompt(int $sessionId, string $systemPrompt): void
{
$stmt = $this->db->prepare('UPDATE chat_sessions SET system_prompt = ? WHERE id = ?');
$stmt->execute([$systemPrompt !== '' ? $systemPrompt : null, $sessionId]);
}
/**
* Get default system prompt from ClaudeService
*/
private function getDefaultSystemPrompt(): string
{
return <<<'PROMPT'
Du bist ein hilfreicher Assistent für Fragen zu systemischem Teamcoaching und Teamentwicklung.
Beantworte die Frage des Nutzers basierend auf dem bereitgestellten Kontext.
- Antworte auf Deutsch
- Sei präzise und hilfreich
- Wenn der Kontext die Frage nicht beantwortet, sage das ehrlich
- Verweise auf die Quellen wenn passend
PROMPT;
}
/**
* Ask chat question using ChatService
*/
private function askChat(string $question, string $model, string $collection, int $limit, ?string $stylePrompt = null, ?string $customSystemPrompt = null): array
{
try {
return $this->chatService->chat($question, $model, $collection, $limit, $stylePrompt, $customSystemPrompt);
} catch (\RuntimeException $e) {
throw new \RuntimeException('Chat-Service konnte nicht ausgeführt werden: ' . $e->getMessage(), 0, $e);
}
}
/**
* Render chat response HTML
*/
private function renderResponse(string $question, array $result, string $model): void
{
$answer = $result['answer'] ?? '';
$sources = $result['sources'] ?? [];
$usage = $result['usage'] ?? null;
$modelLabel = str_starts_with($model, 'ollama:') ? substr($model, 7) : $model;
// Convert markdown-style formatting to HTML
$answer = $this->formatAnswer($answer);
echo '