From 5db58fd87f230fbe5bae599bb4b120ab42cad3be Mon Sep 17 00:00:00 2001
From: "t.me/xtekky" <98614666+xtekky@users.noreply.github.com>
Date: Sat, 24 Jun 2023 03:47:00 +0200
Subject: gpt4free v2, first release

---
 g4f/.v1/unfinished/gptbz/README.md   |  4 ++++
 g4f/.v1/unfinished/gptbz/__init__.py | 46 ++++++++++++++++++++++++++++++++++++
 2 files changed, 50 insertions(+)
 create mode 100644 g4f/.v1/unfinished/gptbz/README.md
 create mode 100644 g4f/.v1/unfinished/gptbz/__init__.py

(limited to 'g4f/.v1/unfinished/gptbz')

diff --git a/g4f/.v1/unfinished/gptbz/README.md b/g4f/.v1/unfinished/gptbz/README.md
new file mode 100644
index 00000000..05bc2770
--- /dev/null
+++ b/g4f/.v1/unfinished/gptbz/README.md
@@ -0,0 +1,4 @@
+https://chat.gpt.bz
+
+to do:
+- code refractoring
\ No newline at end of file
diff --git a/g4f/.v1/unfinished/gptbz/__init__.py b/g4f/.v1/unfinished/gptbz/__init__.py
new file mode 100644
index 00000000..e95d5716
--- /dev/null
+++ b/g4f/.v1/unfinished/gptbz/__init__.py
@@ -0,0 +1,46 @@
+from json import dumps, loads
+
+import websockets
+
+
+# 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:
+
+        # 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:
+                # 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)
+
+                # 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
-- 
cgit v1.2.3