import asyncio
import websockets
websocket_url = "wss://likurgus.com"
async def filter_websocket_traffic():
async with websockets.connect(websocket_url) as ws:
while True:
try:
data = await ws.recv()
print(f"Received data: {data}")
if len(data) == 148:
print("Filtered data:", data)
except websockets.ConnectionClosedError:
print("WebSocket connection closed.")
break
asyncio.run(filter_websocket_traffic())