Starkex

# Clone the repository
git clone https://github.com/astraly-labs/pragma-node

# Run the example
cargo run --example starkex

import asyncio
import websockets
import json
from websockets.exceptions import ConnectionClosedError

async def connect_and_subscribe():
    uri = "wss://ws.devnet.pragma.build/node/v1/data/subscribe"
    
    try:
        # Connect to the websocket
        async with websockets.connect(uri) as websocket:
            # Subscribe to TIA/USD price
            subscribe_msg = {
                "msg_type": "subscribe", 
                "pairs": ["TIA/USD"]
            }
            
            await websocket.send(json.dumps(subscribe_msg))
            print("Subscribed to TIA/USD")
            
            # Handle incoming messages
            while True:
                message = await websocket.recv()
                data = json.loads(message)
                print(f"Received price update: {data}")
                
    except ConnectionClosedError:
        print("Connection closed unexpectedly")
    except Exception as e:
        print(f"Error: {e}")

# Run the connection
if __name__ == "__main__":
    asyncio.run(connect_and_subscribe())