Стриминг котировок, живые курсы и price alerts

Три источника, три ритма

Чтение потока

const res = await fetch(sseURL, {
  headers: { "X-API-Key": key, Accept: "text/event-stream" },
});
const reader = res.body.pipeThrough(new TextDecoderStream()).getReader();

let buf = "";
for (;;) {
  const { value, done } = await reader.read();
  if (done) break;
  buf += value;

  let i;
  while ((i = buf.indexOf("\n\n")) !== -1) {          // один SSE-фрейм
    const frame = buf.slice(0, i); buf = buf.slice(i + 2);
    const event = /^event:\s*(.+)$/m.exec(frame)?.[1];
    const data = JSON.parse(/^data:\s*(.+)$/m.exec(frame)?.[1] ?? "null");

    if (event === "offer") render(data);             // рисуйте сразу по приходу
    if (event === "provider_error") log(data);       // в лог, но не на экран
    if (event === "done") rerank(data.deviations);   // финальный рейтинг нарисованного
  }
}

Как собрать price alerts

1. Опрашивайте фид, а не эндпоинт котировок

   /v1/export/rates.xml отдаётся без ключа, кэшируется и покрывает все направления сразу — одного запроса хватает на все ваши алерты. Отдельная котировка на пару каждого пользователя — верный способ попасть под троттлинг провайдеров.

2. Сравнивайте по направлению вместе с лимитами

   Алерт на BTC → USDTTRC20 имеет смысл только внутри minamount и maxamount. Храните оба значения рядом с порогом, чтобы не уведомлять человека о курсе, которым он не сможет воспользоваться.

3. Гасите дребезг до уведомления

   Курсы колеблются. Требуйте, чтобы порог держался два чтения подряд, и перевзводите алерт только после отхода курса на запас — иначе спокойный рынок пришлёт сотню уведомлений.

4. Превращайте алерт в предложение

   Как только пользователь решил действовать, считайте нормальную котировку через /quotes или /quotes-sse: фид говорит о том, что было доступно несколько секунд назад, а исполнимо только предложение — и то пять минут.

Статусные алерты устроены зеркально: один цикл опроса на открытый ордер и ваша собственная рассылка туда, где слушают пользователи, — websocket, ваш собственный вебхук или сообщение в Telegram.

Что не в реальном времени

Кто на этом работает

• Мониторинги и агрегаторы, читающие rates.xml в формате, который они и так разбирают.
• Боты-алерты — Telegram, Discord, почта — срабатывающие по исполнимому курсу, а не по биржевому тикеру.
• B2B-партнёры с дашбордами, раздающие статусы ордеров своих клиентов из одного цикла опроса.
• Кошельки и калькуляторы, где число на экране должно двигаться, пока пользователь думает.

Вопросы