FOMO WebSocket API quick start

# pip install "websockets>=13"   (Python 3.9+)
import asyncio, json, os
from websockets.asyncio.client import connect

# ws_url: GET /v1/dashboard -> "ws_url". The same key works for REST and the WebSocket.
WS_URL = os.environ["FOMO_WS_URL"] + "?key=" + os.environ["FOMO_API_KEY"]

def handle(event):
    if event.get("status") == "LIVE_MODE_ACTIVATED":
        print("connected")
        return
    op = event.get("op")
    d = event.get("d") or {}
    coin = d.get("coin") or {}
    if op == "thesis":
        author = d.get("author") or {}
        text = (d.get("thesis") or {}).get("text") or ""
        print("thesis", author.get("username"), coin.get("symbol"), text[:80])
    elif op == "trade":
        user = d.get("user") or {}
        print("trade", user.get("username"), d.get("side"), coin.get("symbol"),
              (d.get("trade") or {}).get("usdAmount"))
    else:
        print(op, coin.get("symbol") or (d.get("user") or {}).get("username"))

async def main():
    backoff = 1
    while True:
        try:
            async with connect(WS_URL) as ws:
                backoff = 1
                async for raw in ws:
                    try:
                        event = json.loads(raw)
                    except ValueError:
                        continue
                    if isinstance(event, dict):
                        handle(event)
        except Exception as exc:
            print("disconnected:", exc)
        await asyncio.sleep(backoff)
        backoff = min(backoff * 2, 30)

asyncio.run(main())

// npm install ws, save as consumer.mjs, run: node consumer.mjs   (Node 18+)
import WebSocket from "ws"

// ws_url: GET /v1/dashboard -> "ws_url". The same key works for REST and the WebSocket.
const BASE_URL = process.env.FOMO_WS_URL
const API_KEY = process.env.FOMO_API_KEY
if (!BASE_URL || !API_KEY) throw new Error("Set FOMO_WS_URL and FOMO_API_KEY")
const WS_URL = BASE_URL + "?key=" + encodeURIComponent(API_KEY)

function handle(event) {
  if (event.status === "LIVE_MODE_ACTIVATED") return console.log("connected")
  const d = event.d ?? {}
  const coin = d.coin ?? {}
  if (event.op === "thesis") {
    console.log("thesis", d.author?.username, coin.symbol, (d.thesis?.text ?? "").slice(0, 80))
  } else if (event.op === "trade") {
    console.log("trade", d.user?.username, d.side, coin.symbol, d.trade?.usdAmount)
  } else {
    console.log(event.op, coin.symbol ?? d.user?.username)
  }
}

let backoff = 1000

function connect() {
  const ws = new WebSocket(WS_URL)
  ws.on("open", () => { backoff = 1000 })
  ws.on("message", (raw) => {
    let event
    try { event = JSON.parse(raw.toString()) } catch { return }
    if (event && typeof event === "object" && !Array.isArray(event)) handle(event)
  })
  ws.on("error", (err) => console.error("socket error:", err.message))
  ws.on("close", () => {
    setTimeout(connect, backoff)
    backoff = Math.min(backoff * 2, 30000)
  })
}

connect()

{
  "v": 1,
  "t": "account",
  "op": "thesis",
  "id": "fomo:thesis:5c0e2a91-7d43-4b8e-9f21-3a6d8e4b1c70",
  "ts": 1760537001412,
  "d": {
    "platform": "fomo",
    "author": {
      "id": "8b3f1d2e-4a6c-4e9b-a1d7-2f5c9e0b3a48",
      "username": "exampletrader",
      "displayName": "Example Trader",
      "url": "https://fomo.family/profile/exampletrader"
    },
    "coin": {
      "networkId": 1399811149,
      "network": "solana",
      "address": "Exmp1eCoinMint4Fake9aBcDeFgHjKmNpQrStUvWxYz",
      "symbol": "EXMPL",
      "priceUsd": "0.00412",
      "marketCapUsd": "4120000"
    },
    "thesis": {
      "id": "5c0e2a91-7d43-4b8e-9f21-3a6d8e4b1c70",
      "text": "Volume is building into the weekly level. Adding here.",
      "createdAt": 1760537000981,
      "marketCapAtCreation": "4050000",
      "likes": 12,
      "replies": 3
    },
    "position": {
      "usdValue": "1250.5",
      "unrealizedPnlUsd": "84.2",
      "unrealizedPnlPercent": "7.21"
    }
  }
}

curl "https://fomo.1322.io/v1/dashboard" \
  -H "X-Api-Key: $FOMO_API_KEY"

curl -X POST "https://fomo.1322.io/v1/users" \
  -H "Content-Type: application/json" \
  -H "X-Api-Key: $FOMO_API_KEY" \
  -d '{ "input": "exampletrader" }'

curl -X DELETE "https://fomo.1322.io/v1/users" \
  -H "Content-Type: application/json" \
  -H "X-Api-Key: $FOMO_API_KEY" \
  -d '{ "input": "exampletrader" }'

curl -X POST "https://fomo.1322.io/v1/coins" \
  -H "Content-Type: application/json" \
  -H "X-Api-Key: $FOMO_API_KEY" \
  -d '{ "input": "solana:Exmp1eCoinMint4Fake9aBcDeFgHjKmNpQrStUvWxYz" }'

curl -X PUT "https://fomo.1322.io/v1/feeds" \
  -H "Content-Type: application/json" \
  -H "X-Api-Key: $FOMO_API_KEY" \
  -d '{ "feeds": [ "verified_all", "listings" ] }'

curl -X PUT "https://fomo.1322.io/v1/filters" \
  -H "Content-Type: application/json" \
  -H "X-Api-Key: $FOMO_API_KEY" \
  -d '{ "min_trade_usd": 500, "trade_sides": [ "buy" ], "user_events": [ "thesis", "trade" ] }'