// Import the WebSocket library
import WebSocket from "ws";

// --- Configuration ---
// Replace with your actual CoinPaprika API key
const API_KEY = "YOUR_API_KEY"; 
const WS_URL = "wss://streaming.coinpaprika.com/ticks";

console.log("--- CoinPaprika 5-Minute Ticker ---");
console.log("Starting connection to streaming API...");

// --- WebSocket Connection ---
try {
  // Initialize the WebSocket connection with your API key in the headers
  const ws = new WebSocket(WS_URL, {
    headers: {
      Authorization: API_KEY,
    },
  });

  let pingTimeout;

  // This function is a safeguard that terminates the connection if the server stops sending pings.
  function heartbeat() {
    clearTimeout(pingTimeout);
    console.log("Heartbeat timeout. Terminating connection.");
    ws.terminate();
  }

  // --- Event Handlers ---

  // 1. When the connection opens, subscribe to tickers.
  ws.on("open", () => {
    console.log("✅ Connection established. Subscribing to tickers...");
    pingTimeout = setTimeout(heartbeat, 130 * 1000); // Expect a ping within 130 seconds

    const subscribePayload = {
      event: "subscribe",
      ids: ["btc-bitcoin", "eth-ethereum"],
      quotes: ["USD"],
    };

    ws.send(JSON.stringify(subscribePayload));
    console.log("Subscribed to Bitcoin and Ethereum tickers");
    console.log("Waiting for live price updates...\n");
  });

  // 2. When the server sends a ping, reset the heartbeat timeout.
  ws.on("ping", () => {
    console.log("Received server ping. Connection is healthy.");
    clearTimeout(pingTimeout);
    pingTimeout = setTimeout(heartbeat, 130 * 1000);
  });

  // 3. When a message is received, log it to the console.
  ws.on("message", (data) => {
    try {
      const message = JSON.parse(data.toString());
      
      // Format the output to be more readable
      const price = message.quotes?.USD?.p;
      const volume = message.quotes?.USD?.v24h;
      const marketCap = message.quotes?.USD?.m;
      
      console.log(`📊 ${message.sym} (${message.id}):`);
      console.log(`   💲 Price: $${price?.toLocaleString() || 'N/A'}`);
      console.log(`   📈 24h Volume: $${volume?.toLocaleString() || 'N/A'}`);
      console.log(`   🏦 Market Cap: $${marketCap?.toLocaleString() || 'N/A'}`);
      console.log(`   🕐 Timestamp: ${new Date(message.ts * 1000).toLocaleString()}\n`);
      
    } catch (error) {
      console.error("Failed to parse message:", error);
    }
  });

  // 4. When the connection closes, clean up the timeout.
  ws.on("close", (code, reason) => {
    console.log(`🔌 Connection closed with code ${code}: ${reason || 'No reason provided'}`);
    clearTimeout(pingTimeout);
  });

  // 5. Handle any errors that occur.
  ws.on("error", (err) => {
    console.error("A WebSocket error occurred:", err.message);
  });

  // 6. Graceful shutdown on Ctrl+C
  process.on('SIGINT', () => {
    console.log('\nGracefully shutting down...');
    ws.close();
    process.exit(0);
  });

} catch (e) {
  console.error("Failed to create WebSocket connection:", e.message);
  process.exit(1);
}

node index.js

--- CoinPaprika 5-Minute Ticker ---
🚀 Starting connection to streaming API...
✅ Connection established. Subscribing to tickers...
📡 Subscribed to Bitcoin and Ethereum tickers
💰 Waiting for live price updates...

📊 BTC (btc-bitcoin):
   💲 Price: $118,625
   📈 24h Volume: $42,480,897,345
   🏦 Market Cap: $2,359,846,639,027
   🕐 Timestamp: 7/16/2025, 4:09:40 PM

📊 ETH (eth-ethereum):
   💲 Price: $3,191
   📈 24h Volume: $28,987,190,950
   🏦 Market Cap: $384,299,955,255
   🕐 Timestamp: 7/16/2025, 4:09:40 PM