mirror of https://github.com/xtekky/gpt4free
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
105 lines
4.0 KiB
Python
105 lines
4.0 KiB
Python
from __future__ import annotations
|
|
|
|
import uuid
|
|
from aiohttp import ClientSession
|
|
from ...errors import ResponseStatusError
|
|
from ...requests import raise_for_status
|
|
|
|
class Conversation:
|
|
"""
|
|
Represents a conversation with specific attributes.
|
|
"""
|
|
def __init__(self, conversationId: str, clientId: str, conversationSignature: str) -> None:
|
|
"""
|
|
Initialize a new conversation instance.
|
|
|
|
Args:
|
|
conversationId (str): Unique identifier for the conversation.
|
|
clientId (str): Client identifier.
|
|
conversationSignature (str): Signature for the conversation.
|
|
"""
|
|
self.conversationId = conversationId
|
|
self.clientId = clientId
|
|
self.conversationSignature = conversationSignature
|
|
|
|
async def create_conversation(session: ClientSession, proxy: str = None) -> Conversation:
|
|
"""
|
|
Create a new conversation asynchronously.
|
|
|
|
Args:
|
|
session (ClientSession): An instance of aiohttp's ClientSession.
|
|
proxy (str, optional): Proxy URL. Defaults to None.
|
|
|
|
Returns:
|
|
Conversation: An instance representing the created conversation.
|
|
"""
|
|
url = 'https://www.bing.com/search?toncp=0&FORM=hpcodx&q=Bing+AI&showconv=1&cc=en'
|
|
headers = {
|
|
"cookie": "; ".join(f"{c.key}={c.value}" for c in session.cookie_jar)
|
|
}
|
|
async with session.get(url, headers=headers) as response:
|
|
await raise_for_status(response)
|
|
headers = {
|
|
"accept": "application/json",
|
|
"sec-fetch-dest": "empty",
|
|
"sec-fetch-mode": "cors",
|
|
"sec-fetch-site": "same-origin",
|
|
"x-ms-client-request-id": str(uuid.uuid4()),
|
|
"x-ms-useragent": "azsdk-js-api-client-factory/1.0.0-beta.1 core-rest-pipeline/1.12.3 OS/Windows",
|
|
"referer": "https://www.bing.com/search?toncp=0&FORM=hpcodx&q=Bing+AI&showconv=1&cc=en",
|
|
"cookie": "; ".join(f"{c.key}={c.value}" for c in session.cookie_jar)
|
|
}
|
|
url = "https://www.bing.com/turing/conversation/create?bundleVersion=1.1634.0-service-contracts"
|
|
async with session.get(url, headers=headers, proxy=proxy) as response:
|
|
if response.status == 404:
|
|
raise ResponseStatusError(f"Response {response.status}: Can't create a new chat")
|
|
await raise_for_status(response)
|
|
data = await response.json()
|
|
conversationId = data.get('conversationId')
|
|
clientId = data.get('clientId')
|
|
conversationSignature = response.headers.get('X-Sydney-Encryptedconversationsignature')
|
|
if not conversationId or not clientId or not conversationSignature:
|
|
raise Exception('Failed to create conversation.')
|
|
return Conversation(conversationId, clientId, conversationSignature)
|
|
|
|
async def list_conversations(session: ClientSession) -> list:
|
|
"""
|
|
List all conversations asynchronously.
|
|
|
|
Args:
|
|
session (ClientSession): An instance of aiohttp's ClientSession.
|
|
|
|
Returns:
|
|
list: A list of conversations.
|
|
"""
|
|
url = "https://www.bing.com/turing/conversation/chats"
|
|
async with session.get(url) as response:
|
|
response = await response.json()
|
|
return response["chats"]
|
|
|
|
async def delete_conversation(session: ClientSession, conversation: Conversation, proxy: str = None) -> bool:
|
|
"""
|
|
Delete a conversation asynchronously.
|
|
|
|
Args:
|
|
session (ClientSession): An instance of aiohttp's ClientSession.
|
|
conversation (Conversation): The conversation to delete.
|
|
proxy (str, optional): Proxy URL. Defaults to None.
|
|
|
|
Returns:
|
|
bool: True if deletion was successful, False otherwise.
|
|
"""
|
|
url = "https://sydney.bing.com/sydney/DeleteSingleConversation"
|
|
json = {
|
|
"conversationId": conversation.conversationId,
|
|
"conversationSignature": conversation.conversationSignature,
|
|
"participant": {"id": conversation.clientId},
|
|
"source": "cib",
|
|
"optionsSets": ["autosave"]
|
|
}
|
|
try:
|
|
async with session.post(url, json=json, proxy=proxy) as response:
|
|
response = await response.json()
|
|
return response["result"]["value"] == "Success"
|
|
except:
|
|
return False |