WebSocket Stream

const ws = new WebSocket(
  "wss://polychadsbot.xyz/ws/alerts?api_key=YOUR_KEY_HERE"
);

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);

  switch (msg.type) {
    case "connected":
      console.log(`🔌 Wired in! Running on ${msg.tier} tier.`);
      break;
    case "alert":
      const a = msg.data;
      console.log(`🚨 WHALE ALERT: ${a.side} ${a.outcome} on '${a.event_title}'`);
      console.log(`Size: $${a.usdc_value} @ ${a.entry_price}¢`);
      console.log(`Conviction Score: ${a.signal_score}/100`);
      break;
  }
};

// CRITICAL: Send a ping every 25 seconds to keep the socket alive
setInterval(() => {
  if (ws.readyState === WebSocket.OPEN) ws.send("ping");
}, 25000);

import asyncio, json, websockets

async def listen_for_whales():
    uri = "wss://polychadsbot.xyz/ws/alerts?api_key=YOUR_KEY_HERE"
    
    async with websockets.connect(uri) as ws:
        async for message in ws:
            msg = json.loads(message)
            
            if msg["type"] == "alert":
                a = msg["data"]
                print(f"🚨 ALERT: {a['side']} {a['outcome']} @ {a['entry_price']}¢")
                print(f"Size: ${a['usdc_value']} | Score: {a['signal_score']}")
                print(a["event_title"], "\n")

# Run the event loop
asyncio.run(listen_for_whales())