{
"tool_response": {
"type": "text",
"file": {
"filePath": "\/var\/www\/dev.campus.systemische-tools.de\/src\/UseCases\/Chat\/SendChatMessageUseCase.php",
"content": "<?php\n\nnamespace UseCases\\Chat;\n\nuse Infrastructure\\AI\\ChatService;\nuse Infrastructure\\Persistence\\ChatMessageRepository;\nuse Infrastructure\\Persistence\\ChatSessionRepository;\nuse Infrastructure\\Persistence\\ContentConfigRepository;\n\n\/**\n * SendChatMessageUseCase - Orchestrates sending a chat message\n *\n * Handles:\n * - Validating session exists\n * - Saving user message\n * - Auto-setting session title from first message\n * - Getting AI response with context\n * - Saving assistant message with tracking data\n *\/\nclass SendChatMessageUseCase\n{\n private ChatService $chatService;\n private ChatSessionRepository $sessionRepo;\n private ChatMessageRepository $messageRepo;\n private ContentConfigRepository $configRepo;\n\n public function __construct(\n ?ChatService $chatService = null,\n ?ChatSessionRepository $sessionRepo = null,\n ?ChatMessageRepository $messageRepo = null,\n ?ContentConfigRepository $configRepo = null\n ) {\n $this->chatService = $chatService ?? $this->createDefaultChatService();\n $this->sessionRepo = $sessionRepo ?? new ChatSessionRepository();\n $this->messageRepo = $messageRepo ?? new ChatMessageRepository();\n $this->configRepo = $configRepo ?? new ContentConfigRepository();\n }\n\n \/**\n * Execute the use case\n *\n * @param string $sessionUuid Session UUID\n * @param string $message User message text\n * @param string $model AI model identifier\n * @param array<string> $collections Qdrant collections to search\n * @param int $contextLimit Number of context chunks\n * @param int $authorProfileId Author profile ID (0 = none)\n * @param int $systemPromptId System prompt config ID\n * @param float $temperature AI temperature setting\n * @param int $maxTokens Max tokens for response\n * @return ChatResponse\n *\/\n public function execute(\n string $sessionUuid,\n string $message,\n string $model,\n array $collections = ['documents'],\n int $contextLimit = 5,\n int $authorProfileId = 0,\n int $systemPromptId = 1,\n float $temperature = 0.7,\n int $maxTokens = 4096\n ): ChatResponse {\n \/\/ 1. Validate session\n $session = $this->sessionRepo->findByUuid($sessionUuid);\n if ($session === null) {\n return ChatResponse::error('Session nicht gefunden.');\n }\n\n \/\/ 2. Validate message\n $message = trim($message);\n if ($message === '') {\n return ChatResponse::error('Bitte gib eine Frage ein.');\n }\n\n \/\/ 3. Save user message\n $this->messageRepo->save(\n sessionId: $session['id'],\n role: 'user',\n content: $message,\n model: $model\n );\n\n \/\/ 4. Auto-set title from first message\n if ($session['title'] === null) {\n $title = mb_substr($message, 0, 50) . (mb_strlen($message) > 50 ? '...' : '');\n $this->sessionRepo->updateTitle($session['id'], $title);\n }\n\n \/\/ 5. Get style prompt from author profile\n $stylePrompt = $this->getStylePromptFromProfile($authorProfileId);\n\n \/\/ 6. Get system prompt\n $systemPrompt = $this->getSystemPromptById($systemPromptId);\n\n \/\/ 7. Track timing and get AI response\n $startTime = microtime(true);\n\n try {\n $result = $this->chatService->chat(\n question: $message,\n model: $model,\n collections: $collections,\n limit: $contextLimit,\n stylePrompt: $stylePrompt,\n customSystemPrompt: $systemPrompt,\n temperature: $temperature,\n maxTokens: $maxTokens\n );\n } catch (\\Exception $e) {\n return ChatResponse::error('Chat-Service Fehler: ' . $e->getMessage());\n }\n\n $endTime = microtime(true);\n\n \/\/ 8. Prepare sources as JSON strings for storage\n \/** @var array<int, non-empty-string> $sourcesForStorage *\/\n $sourcesForStorage = array_map(\n static fn (array $source): string => json_encode($source, JSON_THROW_ON_ERROR),\n $result['sources']\n );\n\n \/\/ 9. Save assistant message with tracking\n $collectionsJson = json_encode($collections);\n $this->messageRepo->save(\n sessionId: $session['id'],\n role: 'assistant',\n content: $result['answer'],\n model: $model,\n tokensInput: $result['usage']['input_tokens'] ?? null,\n tokensOutput: $result['usage']['output_tokens'] ?? null,\n sources: $sourcesForStorage,\n startMicrotime: $startTime,\n endMicrotime: $endTime,\n authorProfileId: $authorProfileId > 0 ? $authorProfileId : null,\n systemPromptId: $systemPromptId > 0 ? $systemPromptId : null,\n collectionsJson: $collectionsJson,\n contextLimit: $contextLimit\n );\n\n \/\/ 10. Return response\n return ChatResponse::fromServiceResponse($result, $endTime - $startTime);\n }\n\n \/**\n * Create default ChatService from credentials\n *\/\n private function createDefaultChatService(): ChatService\n {\n $config = \\Infrastructure\\AI\\AIConfig::fromCredentialsFile();\n\n return $config->createChatService();\n }\n\n \/**\n * Get style prompt from author profile\n *\/\n private function getStylePromptFromProfile(int $profileId): ?string\n {\n if ($profileId === 0) {\n return null;\n }\n\n $profile = $this->configRepo->findByIdAndType($profileId, 'author_profile');\n if ($profile === null) {\n return null;\n }\n\n $config = json_decode($profile['content'] ?? '{}', true);\n if ($config === null) {\n return null;\n }\n\n $parts = [];\n\n if (isset($config['stimme']['ton'])) {\n $parts[] = 'Ton: ' . $config['stimme']['ton'];\n }\n if (isset($config['stimme']['perspektive'])) {\n $parts[] = 'Perspektive: ' . $config['stimme']['perspektive'];\n }\n if (isset($config['stil']['fachsprache']) && $config['stil']['fachsprache']) {\n $parts[] = 'Verwende Fachsprache';\n }\n if (isset($config['stil']['beispiele']) && $config['stil']['beispiele'] === 'häufig') {\n $parts[] = 'Nutze häufig Beispiele';\n }\n if (isset($config['stil']['listen']) && $config['stil']['listen'] === 'bevorzugt') {\n $parts[] = 'Bevorzuge Listen und Bullet-Points';\n }\n if (isset($config['tabus']) && is_array($config['tabus'])) {\n $parts[] = 'Vermeide: ' . implode(', ', $config['tabus']);\n }\n\n if ($parts === []) {\n return null;\n }\n\n return 'Schreibstil (' . ($profile['name'] ?? 'Profil') . '): ' . implode('. ', $parts) . '.';\n }\n\n \/**\n * Get system prompt by ID\n *\/\n private function getSystemPromptById(int $promptId): ?string\n {\n if ($promptId === 0) {\n return null;\n }\n\n $prompt = $this->configRepo->findByIdAndType($promptId, 'system_prompt');\n if ($prompt === null) {\n return null;\n }\n\n $content = json_decode($prompt['content'] ?? '{}', true);\n\n return $content['prompt'] ?? null;\n }\n}\n",
"numLines": 221,
"startLine": 1,
"totalLines": 221
}
}
}