diff options
author | t.me/xtekky <98614666+xtekky@users.noreply.github.com> | 2023-04-27 14:29:39 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-04-27 14:29:39 +0200 |
commit | a5b4d8b10c49021949aa9ce950fa182b54c71bc4 (patch) | |
tree | 997609545bc922d63081a49ee356b747b4ecce68 /unfinished/gptbz | |
parent | Merge pull request #197 from AymaneHrouch/update_syspath (diff) | |
parent | Merge branch 'main' into main (diff) | |
download | gpt4free-a5b4d8b10c49021949aa9ce950fa182b54c71bc4.tar gpt4free-a5b4d8b10c49021949aa9ce950fa182b54c71bc4.tar.gz gpt4free-a5b4d8b10c49021949aa9ce950fa182b54c71bc4.tar.bz2 gpt4free-a5b4d8b10c49021949aa9ce950fa182b54c71bc4.tar.lz gpt4free-a5b4d8b10c49021949aa9ce950fa182b54c71bc4.tar.xz gpt4free-a5b4d8b10c49021949aa9ce950fa182b54c71bc4.tar.zst gpt4free-a5b4d8b10c49021949aa9ce950fa182b54c71bc4.zip |
Diffstat (limited to 'unfinished/gptbz')
-rw-r--r-- | unfinished/gptbz/__init__.py | 44 |
1 files changed, 29 insertions, 15 deletions
diff --git a/unfinished/gptbz/__init__.py b/unfinished/gptbz/__init__.py index ba326cf6..44bfcd19 100644 --- a/unfinished/gptbz/__init__.py +++ b/unfinished/gptbz/__init__.py @@ -1,30 +1,44 @@ import websockets from json import dumps, loads +# Define the asynchronous function to test the WebSocket connection + + async def test(): + # Establish a WebSocket connection with the specified URL async with websockets.connect('wss://chatgpt.func.icu/conversation+ws') as wss: - - await wss.send(dumps(separators=(',', ':'), obj = { - 'content_type':'text', - 'engine':'chat-gpt', - 'parts':['hello world'], - 'options':{} - } - )) - + + # Prepare the message payload as a JSON object + payload = { + 'content_type': 'text', + 'engine': 'chat-gpt', + 'parts': ['hello world'], + 'options': {} + } + + # Send the payload to the WebSocket server + await wss.send(dumps(obj=payload, separators=(',', ':'))) + + # Initialize a variable to track the end of the conversation ended = None + # Continuously receive and process messages until the conversation ends while not ended: try: - response = await wss.recv() + # Receive and parse the JSON response from the server + response = await wss.recv() json_response = loads(response) + + # Print the entire JSON response print(json_response) - - ended = json_response.get('eof') - + + # Check for the end of the conversation + ended = json_response.get('eof') + + # If the conversation has not ended, print the received message if not ended: print(json_response['content']['parts'][0]) - + + # Handle cases when the connection is closed by the server except websockets.ConnectionClosed: break - |