summaryrefslogtreecommitdiffstats
path: root/unfinished/gptbz/__init__.py
diff options
context:
space:
mode:
authort.me/xtekky <98614666+xtekky@users.noreply.github.com>2023-04-27 14:29:39 +0200
committerGitHub <noreply@github.com>2023-04-27 14:29:39 +0200
commita5b4d8b10c49021949aa9ce950fa182b54c71bc4 (patch)
tree997609545bc922d63081a49ee356b747b4ecce68 /unfinished/gptbz/__init__.py
parentMerge pull request #197 from AymaneHrouch/update_syspath (diff)
parentMerge branch 'main' into main (diff)
downloadgpt4free-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 '')
-rw-r--r--unfinished/gptbz/__init__.py44
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
-