Every Pump.fun token, scored in real-time.

curl -sS -H "Authorization: Bearer $API_KEY" \
  https://api.cookin.fun/v1/tokens/BgNrWZKAaZAa...

const WebSocket = require("ws");

const API_KEY = process.env.API_KEY;
const url = `wss://api.cookin.fun/socket/websocket?vsn=2.0.0&api_key=${API_KEY}`;
const ws  = new WebSocket(url);

ws.on("open", () => {
  // Join frames:live (ref="1", join_ref="1").
  ws.send(JSON.stringify(["1", "1", "frames:live", "phx_join", {}]));

  // Heartbeat every 25s so Phoenix doesn't drop us.
  let n = 2;
  setInterval(() => {
    ws.send(JSON.stringify([null, String(n++), "phoenix", "heartbeat", {}]));
  }, 25_000);
});

ws.on("message", (buf) => {
  const [_joinRef, _ref, _topic, event, payload] = JSON.parse(buf);
  if (event === "frame") {
    const trade = payload.data.trades[0];
    console.log(payload.data.signature, trade.mint, trade.sol_amount);
  }
});