Callout alerts bot

import WebSocket from "ws";

const KEY = process.env.FOMOSCAN_KEY;
const TG = `https://api.telegram.org/bot${process.env.TELEGRAM_TOKEN}/sendMessage`;
const CHAT = process.env.TELEGRAM_CHAT_ID;
const MAX_MCAP = 250_000;
const seen = new Set();

function keep(c) {
  return c.calledOutAtMcap != null && c.calledOutAtMcap <= MAX_MCAP && c.thesis;
}

async function post(c) {
  const caller = c.xUsername ? `@${c.xUsername}` : c.userName ?? c.wallet.slice(0, 6);
  const text = [
    `${c.isVerified ? "✅ " : ""}${caller} called $${c.coinSymbol ?? c.coinMint.slice(0, 6)}`,
    `MCap at call: $${Math.round(c.calledOutAtMcap).toLocaleString()}`,
    "",
    c.thesis,
    "",
    `https://pump.fun/coin/${c.coinMint}`,
  ].join("\n");
  await fetch(TG, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ chat_id: CHAT, text, disable_web_page_preview: true }),
  });
}

function connect() {
  const ws = new WebSocket("wss://api.fomoscan.sh/v2/ws/pump", {
    headers: { Authorization: `Bearer ${KEY}` },
  });
  ws.on("open", () => {
    ws.send(JSON.stringify({ type: "subscribe", subscription: { type: "all" } }));
  });
  ws.on("message", async (raw) => {
    const frame = JSON.parse(raw.toString());
    if (frame.type !== "pump_callout") return;
    const c = frame.callout;
    if (seen.has(c.id) || !keep(c)) return;
    seen.add(c.id);
    await post(c);
  });
  ws.on("error", (err) => console.error(err.message));
  ws.on("close", (code, reason) => {
    console.log("closed", code, reason.toString());
    if (code !== 1008) setTimeout(connect, 2000);
  });
}

connect();