Token Feed WebSocket Service

import WebSocket from 'ws';

const API_KEY = 'YOUR_API_KEY';

// Define comprehensive filters
const filters = {
    "Bot users": { min: 0, max: 50 },
    "Buys": { min: 0, max: 1000 },
    "Dev holding %": { min: 0, max: 20 },
    "Exclude": { text: "rug,scam,honeypot" },
    "Holders": { min: 10, max: 1000 },
    "Insider wallets supply": { min: 0, max: 50 },
    "Liquidity": { min: 5000, max: 100000 },
    "Market Cap": { min: 10000, max: 1000000 },
    "Search": { text: "coin,token" },
    "Sells": { min: 0, max: 500 },
    "Sniper wallets": { min: 0, max: 20 },
    "Token Age (mins)": { min: 0, max: 60 },
    "Top 10 Holders": false,
    "Txns": { min: 0, max: 1000 },
    "Volume": { min: 1000, max: 100000 },
    "With at least 1 social": false
};

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

ws.on('open', () => {
    console.log('Connected to WebSocket server');
    // Send filter configuration
    const message = {
        type: "setFilters",
        filters: filters
    };
    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 === 'token') {
            // Format token data nicely
            message.data.forEach(token => {
                console.log('\nNew Token Update:');
                console.log('----------------');
                console.log(`Name: ${token.name} (${token.symbol})`);
                console.log(`Address: ${token.address}`);
                console.log(`Price: ${token.price}`);
                console.log(`Market Cap: $${token.marketCapUSD}`);
                console.log(`Liquidity: $${token.liquidityUSD}`);
                console.log(`Volume (24h): $${token.totalVolume}`);
                console.log(`Holders: ${token.holders}`);
                console.log(`Created: ${token.createdAt}`);
                console.log(`Risk Score: ${token.riskScore}`);
                console.log(`Type: ${token.type}`);
                console.log(`Protocol: ${token.protocol}`);
                
                // Trading stats
                console.log('\nTrading Stats:');
                console.log(`Buys: ${token.buys}`);
                console.log(`Sells: ${token.sells}`);
                console.log(`Total Txns: ${token.totalTxns}`);
                console.log(`Buy Tax: ${token.buyTax}%`);
                console.log(`Sell Tax: ${token.sellTax}%`);
                
                // Wallet stats
                console.log('\nWallet Stats:');
                console.log(`Bot Users: ${token.botsTotalCount}`);
                console.log(`Sniper Wallets: ${token.sniperWalletsCount}`);
                console.log(`Dev Holding: ${token.devHoldingSupplyPerc}%`);
                console.log(`Insider Supply: ${token.insiderWalletsSupplyPerc}%`);
                
                // Links
                if (token.links) {
                    console.log('\nLinks:');
                    Object.entries(token.links).forEach(([key, value]) => {
                        console.log(`${key}: ${value}`);
                    });
                }
                
                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"
}

Common errors:

• Invalid filter configuration
• Invalid JSON format
• Missing required fields
• Authentication failure
• Rate limit exceeded