import httpx from app.config.config import settings from app.utils.rsa_crypto import RagflowCrypto class RagflowService: def __init__(self, base_url: str): self.base_url = base_url async def register(self, username: str, password: str): password = RagflowCrypto(settings.PUBLIC_KEY, settings.PRIVATE_KEY).encrypt(password) async with httpx.AsyncClient() as client: response = await client.post( f"{self.base_url}/v1/user/register", json={"nickname": username, "email": f"{username}@example.com", "password": password}, headers={'Content-Type': 'application/json'} ) if response.status_code != 200: raise Exception(f"Ragflow registration failed: {response.text}") async def login(self, username: str, password: str) -> str: password = RagflowCrypto(settings.PUBLIC_KEY, settings.PRIVATE_KEY).encrypt(password) async with httpx.AsyncClient() as client: response = await client.post( f"{self.base_url}/v1/user/login", json={"email": f"{username}@example.com", "password": password}, headers={'Content-Type': 'application/json'} ) if response.status_code != 200: raise Exception(f"Ragflow login failed: {response.text}") # 从响应头中提取 Authorization 字段 authorization = response.headers.get('Authorization') if not authorization: raise Exception("Authorization header not found in response") return authorization async def chat(self, token: str, chat_id: str, chat_history: list): data = { "conversation_id": chat_id, "messages": chat_history } target_url = f"{self.base_url}/v1/conversation/completion" async with httpx.AsyncClient() as client: headers = { 'Content-Type': 'application/json', 'Authorization': token } # 创建流式请求 async with client.stream("POST", target_url, json=data, headers=headers) as response: # 检查响应状态码 if response.status_code == 200: # 流式读取响应 try: async for answer in response.aiter_text(): yield answer except GeneratorExit as e: print(e) return else: yield f"Error: {response.status_code}" async def get_chat_sessions(self, token: str, dialog_id: str) -> list: url = f"{self.base_url}/v1/conversation/list?dialog_id={dialog_id}" headers = { "Authorization": token } async with httpx.AsyncClient() as client: response = await client.get(url, headers=headers) if response.status_code != 200: raise Exception(f"Failed to fetch data from Ragflow API: {response.text}") data = response.json().get("data", []) result = [ { "id": item["id"], "name": item["name"], "updated_time": item["update_time"] } for item in data ] return result async def set_session(self, token: str, dialog_id: str, name: str, chat_id: str, is_new: bool) -> list: url = f"{self.base_url}/v1/conversation/set?dialog_id={dialog_id}" headers = { "Authorization": token } data = { "dialog_id": dialog_id, "name": name, "is_new": is_new, "conversation_id": chat_id, } async with httpx.AsyncClient() as client: response = await client.post(url, headers=headers, json=data) if response.status_code != 200: return [] ret_code = response.json().get("retcode") if ret_code != 0: return [] return [ { "content": "你好! 我是你的助理,有什么可以帮到你的吗?", "role": "assistant" }, { "content": name, "doc_ids": [], "role": "user" } ]