Spaces:
Sleeping
Sleeping
File size: 2,610 Bytes
5fa74cc bc3aeb9 5fa74cc d113efb 02e7b61 ec48066 e00660b 83fea52 e00660b f97ba53 e00660b 2b4921b bb675e2 02e7b61 fa03655 e00660b 5fa74cc |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 |
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}")
except websockets.exceptions.ConnectionClosed:
print("Connection closed. Reconnecting in 30 minutes.")
# 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()) |