| | |
| | | response = await client.post( |
| | | f"{self.base_url}/v1/user/register", |
| | | headers={'Content-Type': 'application/json'}, |
| | | json={"nickname": username, "email": f"{username}@example.com", "password": password} |
| | | json={"nickname": username, "email": f"{username}@example.com", "password": password} |
| | | ) |
| | | if response.status_code != 200: |
| | | raise Exception(f"Ragflow registration failed: {response.text}") |
| | |
| | | response = await client.get(url, headers=headers) |
| | | data = self._handle_response(response) |
| | | session_log = { |
| | | "dialog_id": data.get("dialog_id"), |
| | | "id": data.get("id"), |
| | | "message": [ |
| | | "session_log": [ |
| | | { |
| | | "content": message.get("content"), |
| | | "message": message.get("content"), |
| | | "role": message.get("role"), |
| | | } |
| | | for message in data.get("message", []) |
| | | ], |
| | | "name": data.get("name"), |
| | | "reference": data.get("reference"), |
| | | } |
| | | return session_log |