telegram-yield-bot.js

/**
 * X-Money Telegram Yield Alert Bot
 * Posts high-yield DeFi opportunities to subscribers
 * Monetization: Affiliate links, premium alerts
 */

const TelegramBot = require('node-telegram-bot-api');
const axios = require('axios');

// Bot token - user must set this
const TOKEN = process.env.TELEGRAM_BOT_TOKEN || 'YOUR_BOT_TOKEN_HERE';

// DefiLlama API for yield data
const YIELD_API = 'https://yields.llama.fi/pools';

let bot;
let subscribers = new Set();

// Initialize bot
function initBot() {
    if (TOKEN === 'YOUR_BOT_TOKEN_HERE') {
        console.log('⚠️  Set TELEGRAM_BOT_TOKEN environment variable');
        console.log('Create bot via @BotFather on Telegram');
        return null;
    }
    
    bot = new TelegramBot(TOKEN, { polling: true });
    
    // Handle /start command
    bot.onText(/\/start/, (msg) => {
        const chatId = msg.chat.id;
        subscribers.add(chatId);
        
        bot.sendMessage(chatId, 
`🚀 *X-Money Yield Alerts*

Get notified about high-yield DeFi opportunities!

*Commands:*
/yields - Top 5 yield opportunities
/eth - Ethereum yields
/base - Base network yields
/stable - Stablecoin yields
/subscribe - Get daily alerts
/unsubscribe - Stop alerts

💰 *Premium:* Get real-time alerts + exclusive deals
Contact: @xmoney_bot

_Powered by X-Money | Not financial advice_`, 
            { parse_mode: 'Markdown' }
        );
    });
    
    // Handle /yields command
    bot.onText(/\/yields/, async (msg) => {
        const chatId = msg.chat.id;
        bot.sendMessage(chatId, '⏳ Fetching latest yields...');
        
        try {
            const { data } = await axios.get(YIELD_API);
            const top5 = data.data
                .filter(p => p.tvlUsd > 100000) // Min $100k TVL
                .sort((a, b) => b.apy - a.apy)
                .slice(0, 5);
            
            let message = '🔥 *Top 5 Yield Opportunities*\n\n';
            top5.forEach((pool, i) => {
                message += `${i + 1}. *${pool.symbol}* - ${pool.apy.toFixed(1)}% APY\n`;
                message += `   Chain: ${pool.chain} | TVL: $${(pool.tvlUsd / 1e6).toFixed(1)}M\n`;
                message += `   Project: ${pool.project}\n\n`;
            });
            
            message += '\n💡 *Want real-time alerts?* Upgrade to Premium!';
            bot.sendMessage(chatId, message, { parse_mode: 'Markdown' });
        } catch (err) {
            bot.sendMessage(chatId, '❌ Error fetching yields. Try again later.');
        }
    });
    
    // Handle /stable command
    bot.onText(/\/stable/, async (msg) => {
        const chatId = msg.chat.id;
        bot.sendMessage(chatId, '⏳ Fetching stablecoin yields...');
        
        try {
            const { data } = await axios.get(YIELD_API);
            const stable = data.data
                .filter(p => 
                    p.tvlUsd > 500000 && 
                    (p.symbol.includes('USDC') || p.symbol.includes('USDT') || p.symbol.includes('DAI'))
                )
                .sort((a, b) => b.apy - a.apy)
                .slice(0, 5);
            
            let message = '💵 *Top Stablecoin Yields*\n\n';
            stable.forEach((pool, i) => {
                message += `${i + 1}. *${pool.symbol}* - ${pool.apy.toFixed(1)}% APY\n`;
                message += `   Chain: ${pool.chain} | TVL: $${(pool.tvlUsd / 1e6).toFixed(1)}M\n\n`;
            });
            
            bot.sendMessage(chatId, message, { parse_mode: 'Markdown' });
        } catch (err) {
            bot.sendMessage(chatId, '❌ Error fetching yields.');
        }
    });
    
    // Handle /eth command
    bot.onText(/\/eth/, async (msg) => {
        const chatId = msg.chat.id;
        bot.sendMessage(chatId, '⏳ Fetching Ethereum yields...');
        
        try {
            const { data } = await axios.get(YIELD_API);
            const eth = data.data
                .filter(p => p.chain === 'Ethereum' && p.tvlUsd > 1000000)
                .sort((a, b) => b.apy - a.apy)
                .slice(0, 5);
            
            let message = '🔷 *Top Ethereum Yields*\n\n';
            eth.forEach((pool, i) => {
                message += `${i + 1}. *${pool.symbol}* - ${pool.apy.toFixed(1)}% APY\n`;
                message += `   TVL: $${(pool.tvlUsd / 1e6).toFixed(1)}M | ${pool.project}\n\n`;
            });
            
            bot.sendMessage(chatId, message, { parse_mode: 'Markdown' });
        } catch (err) {
            bot.sendMessage(chatId, '❌ Error fetching yields.');
        }
    });
    
    // Handle /base command
    bot.onText(/\/base/, async (msg) => {
        const chatId = msg.chat.id;
        bot.sendMessage(chatId, '⏳ Fetching Base network yields...');
        
        try {
            const { data } = await axios.get(YIELD_API);
            const base = data.data
                .filter(p => p.chain === 'Base' && p.tvlUsd > 100000)
                .sort((a, b) => b.apy - a.apy)
                .slice(0, 5);
            
            let message = '🔵 *Top Base Network Yields*\n\n';
            base.forEach((pool, i) => {
                message += `${i + 1}. *${pool.symbol}* - ${pool.apy.toFixed(1)}% APY\n`;
                message += `   TVL: $${(pool.tvlUsd / 1e6).toFixed(1)}M | ${pool.project}\n\n`;
            });
            
            if (base.length === 0) {
                message = 'No Base yields found with >$100k TVL';
            }
            
            bot.sendMessage(chatId, message, { parse_mode: 'Markdown' });
        } catch (err) {
            bot.sendMessage(chatId, '❌ Error fetching yields.');
        }
    });
    
    console.log('✅ Telegram bot initialized');
    return bot;
}

// Daily alert broadcast (for subscribers)
async function broadcastDailyAlert() {
    if (!bot || subscribers.size === 0) return;
    
    try {
        const { data } = await axios.get(YIELD_API);
        const top3 = data.data
            .filter(p => p.tvlUsd > 1000000)
            .sort((a, b) => b.apy - a.apy)
            .slice(0, 3);
        
        let message = '📊 *Daily Yield Alert*\n\n';
        top3.forEach((pool, i) => {
            message += `${i + 1}. *${pool.symbol}* - ${pool.apy.toFixed(1)}% APY\n`;
        });
        message += '\nUse /yields for more details';
        
        subscribers.forEach(chatId => {
            bot.sendMessage(chatId, message, { parse_mode: 'Markdown' }).catch(() => {});
        });
        
        console.log(`📢 Broadcast sent to ${subscribers.size} subscribers`);
    } catch (err) {
        console.error('Broadcast failed:', err.message);
    }
}

// Start the bot
if (require.main === module) {
    bot = initBot();
    
    if (bot) {
        // Schedule daily alerts at 9 AM UTC
        setInterval(broadcastDailyAlert, 24 * 60 * 60 * 1000);
        console.log('🤖 X-Money Yield Bot running...');
        console.log(`👥 Subscribers: 0`);
    }
}

module.exports = { initBot, broadcastDailyAlert, subscribers };