Liquidity Waves
Alerts API

// npm install telegraf eventsource
const { Telegraf } = require('telegraf');
const EventSource = require('eventsource');

const bot = new Telegraf(process.env.BOT_TOKEN);
const API_KEY = process.env.LW_API_KEY;
const API_SECRET = process.env.LW_API_SECRET;
const subscribers = new Set(); // simpan di DB Anda di production

bot.start(ctx => {
    subscribers.add(ctx.from.id);
    ctx.reply('🌊 Selamat datang! Anda berlangganan signal alert.');
});

bot.command('signals', async ctx => {
    const r = await fetch('https://bot.liquiditywaves.com/api/v1/signals/recent?limit=5', {
        headers: {
            'Authorization': `Bearer ${API_KEY}`,
            'X-API-Secret': API_SECRET
        }
    });
    const { signals } = await r.json();
    const msg = signals.map(s =>
        `▤ ${s.pair} ${s.side}\nEntry: ${s.entry} | SL: ${s.sl} | TP: ${s.tp1}`
    ).join('\n\n');
    ctx.reply(msg || 'No recent signals.');
});

// SSE live stream — push ke semua subscribers
const es = new EventSource('https://bot.liquiditywaves.com/api/v1/stream?topics=signals', {
    headers: {
        'Authorization': `Bearer ${API_KEY}`,
        'X-API-Secret': API_SECRET
    }
});

es.addEventListener('signal:new', evt => {
    const s = JSON.parse(evt.data);
    const text = `⚠ SIGNAL BARU\n${s.pair} ${s.side} @ ${s.entry}\nSL: ${s.sl} | TP1: ${s.tp1}`;
    for (const userId of subscribers) {
        bot.telegram.sendMessage(userId, text).catch(() => {});
    }
});

es.addEventListener('signal:tp_hit', evt => {
    const s = JSON.parse(evt.data);
    for (const userId of subscribers) {
        bot.telegram.sendMessage(userId, `✅ TP${s.tp} hit di ${s.pair} (+${s.rr}R)`).catch(() => {});
    }
});

bot.launch();
console.log('White-label bot running...');

# pip install python-telegram-bot requests sseclient-py
import os, json, asyncio, requests, sseclient
from telegram import Bot

bot = Bot(token=os.environ['BOT_TOKEN'])
HEADERS = {
    'Authorization': f"Bearer {os.environ['LW_API_KEY']}",
    'X-API-Secret': os.environ['LW_API_SECRET']
}

async def listen_stream(subscribers):
    resp = requests.get(
        'https://bot.liquiditywaves.com/api/v1/stream?topics=signals',
        headers=HEADERS, stream=True
    )
    client = sseclient.SSEClient(resp)
    for event in client.events():
        if event.event == 'signal:new':
            s = json.loads(event.data)
            msg = f"⚠ {s['pair']} {s['side']} @ {s['entry']}"
            for uid in subscribers:
                await bot.send_message(uid, msg)