Spaces:
Running
Running
| from fastapi import Request | |
| from fastapi.responses import JSONResponse | |
| import traceback | |
| import random | |
| from llm_model import Message, LLMModel | |
| from intent_api import execute_intent | |
| from intent_utils import validate_variable_formats | |
| from parse_llm_blocks import parse_llm_blocks | |
| from log import log | |
| async def handle_chat(msg: Message, request: Request, app, service_config, session, llm_model: LLMModel): | |
| try: | |
| user_input = msg.user_input.strip() | |
| log(f"💬 Kullanıcı input'u: '{user_input}'") | |
| project_name = session.project_name | |
| project_config = service_config.get_project_llm_config(project_name) | |
| system_prompt = service_config.system_prompt # 👉 system_prompt buradan alınıyor | |
| # Chat history'ye user mesajını ekle | |
| session.chat_history.append({"role": "user", "content": user_input}) | |
| # === LLM çağrısı | |
| llm_response = await llm_model.generate_response_with_messages(session.chat_history, project_config, system_prompt) | |
| log(f"🤖 LLM cevabı: {llm_response}") | |
| # === LLM cevabını parse et | |
| parsed = parse_llm_blocks(llm_response) | |
| intent = parsed["intent"] | |
| params = parsed["params"] | |
| missing = parsed["missing"] | |
| action_json = parsed["action_json"] | |
| # Chat history'ye assistant cevabını ekle | |
| session.chat_history.append({"role": "assistant", "content": llm_response}) | |
| # === INTENT yok → havadan sudan konuşma | |
| if intent == "NONE": | |
| session.awaiting_variable = None | |
| session.last_intent = None | |
| session.variables.clear() | |
| return {"response": llm_response} | |
| # === INTENT varsa | |
| session.last_intent = intent | |
| session.variables.update(params) | |
| # Eksik parametre varsa | |
| if missing: | |
| session.awaiting_variable = missing[0] | |
| return {"response": f"Lütfen {', '.join(missing)} bilgisini belirtir misiniz?"} | |
| # === API çağrısı yap | |
| intent_definitions = {i["name"]: i for i in service_config.get_project_intents(project_name)} | |
| data_formats = service_config.data_formats | |
| # Parametreleri validasyonla kontrol et (backend güvenlik katmanı) | |
| variable_format_map = intent_definitions.get(intent, {}).get("variable_formats", {}) | |
| is_valid, validation_errors = validate_variable_formats(session.variables, variable_format_map, data_formats) | |
| if not is_valid: | |
| session.awaiting_variable = list(validation_errors.keys())[0] | |
| return {"response": list(validation_errors.values())[0]} | |
| log("🚀 execute_intent() çağrılıyor...") | |
| result = execute_intent( | |
| intent, | |
| user_input, | |
| session.__dict__, | |
| intent_definitions, | |
| data_formats, | |
| project_name, | |
| service_config | |
| ) | |
| if "reply" in result: | |
| return {"reply": result["reply"]} | |
| elif "errors" in result: | |
| return {"response": list(result["errors"].values())[0]} | |
| else: | |
| return {"response": random.choice(project_config["fallback_answers"])} | |
| except Exception as e: | |
| traceback.print_exc() | |
| return JSONResponse(content={"error": str(e)}, status_code=500) | |