Eksekusi Institusional.
Tanpa Kompromi.

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

const bot = new Telegraf(process.env.BOT_TOKEN);
const subscribers = new Set();

bot.start(ctx => subscribers.add(ctx.from.id));

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

es.addEventListener('signal:new', evt => {
  const s = JSON.parse(evt.data);
  const msg = `⚠ ${s.pair} ${s.side} @ ${s.entry}`;
  for (const id of subscribers) {
    bot.telegram.sendMessage(id, msg);
  }
});

bot.launch();