The live stream

const socket = new WebSocket('wss://cirrus.pocketful.in/v1/stream');
socket.onopen = () =>
  socket.send(JSON.stringify({ type: 'auth', token: process.env.CIRRUS_API_KEY }));
socket.onmessage = (event) => {
  const message = JSON.parse(event.data);
  // message.type: hello | snapshot | snapshot_done | order_update | portfolio | error
  console.log(message.seq, message.type, message.account);
};
socket.onclose = (event) => console.log('closed', event.code, event.reason);

import asyncio, json, os

import websockets  # pip install websockets


async def main():
    async with websockets.connect("wss://cirrus.pocketful.in/v1/stream") as socket:
        await socket.send(json.dumps({"type": "auth", "token": os.environ["CIRRUS_API_KEY"]}))
        async for raw in socket:
            message = json.loads(raw)
            # hello, snapshot, snapshot_done, order_update, portfolio, error
            print(message["seq"], message["type"], message.get("account"))


asyncio.run(main())