Mirage

import json
from websocket import create_connection

ws = create_connection("wss://www.getavenir.co/ws")
token = "paste_clerk_jwt_here"

ws.send(json.dumps({
    "action": "userConnected",
    "token": token,
    "applicationType": "mirage",
}))

ready = False
while True:
    msg = json.loads(ws.recv())
    if msg.get("type") == "orderBook" and not ready:
        ready = True
        ws.send(json.dumps({
            "action": "mirageStartSession",
            "sessionDurationSeconds": 60,
        }))
    elif msg.get("type") == "mirageSession":
        for order in msg.get("brokerMessages") or []:
            print(order["type"], order["orderQty"], "@", order["orderPrice"])
        print("countdown", msg.get("countdownSecondsLeft"))
    elif msg.get("type") == "countdown":
        print("countdown", msg.get("value"))

const token = "paste_clerk_jwt_here";
const ws = new WebSocket("wss://www.getavenir.co/ws");
let ready = false;

ws.onopen = () => {
  ws.send(JSON.stringify({
    action: "userConnected",
    token,
    applicationType: "mirage",
  }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "orderBook" && !ready) {
    ready = true;
    ws.send(JSON.stringify({
      action: "mirageStartSession",
      sessionDurationSeconds: 60,
    }));
  }
  if (msg.type === "mirageSession") {
    for (const order of msg.brokerMessages || []) {
      console.log(order.type, order.orderQty, "@", order.orderPrice);
    }
    console.log("countdown", msg.countdownSecondsLeft);
  }
  if (msg.type === "countdown") {
    console.log("countdown", msg.value);
  }
};