Update app.py

app.py

@@ -1,5 +1,7 @@
+import gradio as gr
 import asyncio
 import websockets
+import threading
 
 async def send_wss_request():
     uri = "wss://clone3-imagex-clone-advance.hf.space/queue/join"
@@ -11,59 +13,25 @@ async def send_wss_request():
                 # Receive the response
                 response = await websocket.recv()
                 print(f"Received: {response}")
-
-                # Send a message
-                message = '{"fn_index":2,"session_hash":"kb46puzhzr"}'
-                await websocket.send(message)
-                print(f"Sent: {message}")
-
-                # Receive the response
-                response = await websocket.recv()
-                print(f"Received: {response}")
-
-                # Receive the response
-                response = await websocket.recv()
-                print(f"Received: {response}")
-
-                message='{"data":["spiderman",1683852825,8,4,true],"event_data":null,"fn_index":2,"session_hash":"kb46puzhzr"}'
-                await websocket.send(message)
-                print(f"Sent: {message}")
-
-                # Receive the response
-                response = await websocket.recv()
-                print(f"Received: {response}")
-
             
             async with websockets.connect(uri2) as websocket:
                 # Receive the response
                 response = await websocket.recv()
                 print(f"Received: {response}")
 
-                # Send a message
-                message = '{"fn_index":2,"session_hash":"kb46puzhzr"}'
-                await websocket.send(message)
-                print(f"Sent: {message}")
-
-                # Receive the response
-                response = await websocket.recv()
-                print(f"Received: {response}")
-
-                # Receive the response
-                response = await websocket.recv()
-                print(f"Received: {response}")
-
-                message='{"data":["spiderman",1683852825,8,4,true],"event_data":null,"fn_index":2,"session_hash":"kb46puzhzr"}'
-                await websocket.send(message)
-                print(f"Sent: {message}")
-
-                # Receive the response
-                response = await websocket.recv()
-                print(f"Received: {response}")
-                
         except websockets.exceptions.ConnectionClosed:
             print("Connection closed. Reconnecting in 30 minutes.")
             
         # Sleep for 30 minutes before the next iteration
         await asyncio.sleep(30 * 60)
 
-asyncio.get_event_loop().run_until_complete(send_wss_request())
+def run_websocket():
+    asyncio.get_event_loop().run_until_complete(send_wss_request())
+
+# Create a thread for the WebSocket function
+websocket_thread = threading.Thread(target=run_websocket)
+websocket_thread.start()
+
+# Define your Gradio interface here
+iface = gr.Interface(fn=None, live=True)
+iface.launch()