Atlas

import json
from websocket import create_connection

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

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

ready = False
while True:
    msg = json.loads(ws.recv())
    if msg.get("type") == "atlasFeedState":
        companies = msg.get("companies") or []
        print("companies", companies, "playing", msg.get("isPlaying"))
        if not ready:
            ready = True
            ws.send(json.dumps({"action": "atlasStartFeed"}))
    elif msg.get("type") == "headline":
        text = msg.get("text") or ""
        subject = next((c for c in sorted(companies, key=len, reverse=True) if c and text.startswith(c)), None)
        print(msg.get("id"), subject or "noise", text)

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

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

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "atlasFeedState") {
    companies = msg.companies || [];
    console.log("companies", companies, "playing", msg.isPlaying);
    if (!ready) {
      ready = true;
      ws.send(JSON.stringify({ action: "atlasStartFeed" }));
    }
  }
  if (msg.type === "headline") {
    const text = msg.text || "";
    const subject = [...companies]
      .filter((c) => c && text.startsWith(c))
      .sort((a, b) => b.length - a.length)[0] || null;
    console.log(msg.id, subject || "noise", text);
  }
};