WebSocket Real-Time Streaming

import WebSocket from 'ws';

// Step 1: Generate JWT token via REST API
const response = await fetch('https://api.tradingviewapi.com/api/token/generate', {
    method: 'POST',
    headers: {
        'X-RapidAPI-Key': 'YOUR_RAPIDAPI_KEY',
        'X-RapidAPI-Host': 'tradingview-data1.p.rapidapi.com'
    }
});

const { token, wsUrl, expiresAt } = await response.json();

// Step 2: Connect to WebSocket with token
const ws = new WebSocket(`${wsUrl}?token=${token}`);

ws.on('open', () => {
    console.log('Connected to TradingView WebSocket');

    // Subscribe to price updates
    ws.send(JSON.stringify({
        action: 'subscribe',
        id: 'price_btc',
        symbol: 'BINANCE:BTCUSDT',
        timeframe: '5'
    }));

    // Subscribe to real-time quotes
    ws.send(JSON.stringify({
        action: 'subscribe_quote',
        id: 'quote_btc',
        symbol: 'BINANCE:BTCUSDT'
    }));
});

ws.on('message', (data) => {
    const message = JSON.parse(data);

    if (message.type === 'price') {
        console.log('Price update:', message.data);
    } else if (message.type === 'quote') {
        console.log('Quote update:', message.data);
    }
});

// Heartbeat to keep connection alive
setInterval(() => {
    ws.send(JSON.stringify({ action: 'ping' }));
}, 30000);