Trades Live WebSocket

import WebSocket from 'ws';

const TOKEN_ADDRESS = 'Dfa6ja8wC18CKHem5QDuS3iV1H2ktqDkJqdgjWhJpump';
const API_KEY = 'your-api-key-here';

console.log(`Starting TradesLive WebSocket client for token: ${TOKEN_ADDRESS}`);

// Create WebSocket connection with API key
const ws = new WebSocket('wss://api.solapi.live/ws/trades-live', {
    headers: {
        'x-api-key': API_KEY
    }
});

ws.on('open', () => {
    console.log('Connected to WebSocket server');
    // Send subscription message
    const message = {
        tokenAddress: TOKEN_ADDRESS
    };
    ws.send(JSON.stringify(message));
});

ws.on('message', (data) => {
    try {
        const message = JSON.parse(data.toString());
        
        // Handle different message types
        if (message.type === 'connected' || message.type === 'subscriptionConfirmed') {
            console.log(message.message);
        } else if (message.type === 'error') {
            console.error('Error:', message.message);
        } else if (message.event === 'trade') {
            // Format trade data nicely
            console.log('\nNew Trade:');
            console.log('==========');
            console.log(`Type: ${message.type}`);
            console.log(`Time: ${message.datetime}`);
            
            // Price information
            console.log('\nPrice:');
            console.log(`SOL: ${message.price.sol}`);
            console.log(`USD: $${message.price.usd}`);
            
            // Amount information
            console.log('\nAmount:');
            console.log(`Tokens: ${message.amount.token}`);
            console.log(`Quote (SOL): ${message.amount.quote}`);
            console.log(`USD Value: $${message.amount.usd}`);
            
            // Transaction details
            console.log('\nTransaction:');
            console.log(`Hash: ${message.transaction.hash}`);
            console.log(`Block: ${message.transaction.blockNumber}`);
            
            // Market information
            console.log('\nMarket:');
            console.log(`Protocol: ${message.market.protocol}`);
            console.log(`Pool: ${message.market.poolAddress}`);
            
            console.log('\n' + '-'.repeat(50));
        }
    } catch (error) {
        console.error('Error parsing message:', error.message);
    }
});

ws.on('error', (error) => {
    console.error('WebSocket error:', error.message);
});

ws.on('close', (code, reason) => {
    console.log('Disconnected');
});

// Handle SIGINT for graceful shutdown
process.on('SIGINT', () => {
    console.log('Closing connection...');
    ws.close();
    process.exit(0);
});

{
  "type": "error",
  "message": "Error description"
}