Spaces:
Runtime error
Runtime error
| import asyncio | |
| import websockets | |
| async def send_wss_request(): | |
| uri = "wss://clone3-imagex-clone-advance.hf.space/queue/join" | |
| uri2 = "wss://clone3-imagex-clone-advance.hf.space/queue/join" | |
| while True: | |
| try: | |
| async with websockets.connect(uri) 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}") | |
| 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}") | |
| # Sleep for 30 minutes before the next iteration | |
| await asyncio.sleep(30 * 60) | |
| # Run the event loop | |
| asyncio.get_event_loop().run_until_complete(send_wss_request()) |