app/service/ragflow.py
@@ -80,3 +80,22 @@ for item in data ] return result async def set_session(self, token: str, dialog_id: str, name: str, chat_id: str, is_new: bool) -> bool: 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 False return True