Get Realtime Arbitrage Stream

/v1/realtime/arbitrage

curl --location --no-buffer \
  -H "Accept: text/event-stream" \
  -H "Cache-Control: no-cache" \
  'localhost:8080/v1/realtime/arbitrage'

const source = new EventSource('/v1/realtime/arbitrage');

source.onmessage = (event) => {
    const opportunity = JSON.parse(event.data);
    console.log('Nova oportunidade:', opportunity);
};

source.onerror = (err) => {
    console.error('Erro SSE, reconectando...', err);
    // EventSource reconecta automaticamente
};

// Ao desmontar o componente React:
// source.close();

data: {"ticker":"BTC-USDT","buyExchange":"Binance","sellExchange":"OKX",...}

data: {"ticker":"ETH-USDT","buyExchange":"Bybit","sellExchange":"Binance",...}

{
  "ticker": "BTC-USDT",
  "buyExchange": "Binance",
  "sellExchange": "OKX",
  "buyPrice": 43250.50,
  "sellPrice": 43380.00,
  "profitPercentAskBid": 0.30,
  "volume": 1523.45,
  "timestamp": "2025-03-18T12:00:00.000Z"
}

Cliente → GET /v1/realtime/arbitrage
Server  → 200 OK (headers SSE)
          Connection mantida aberta
          ↓
Server  → data: {...oportunidade...}\n\n   (quando detectada)
Server  → data: {...oportunidade...}\n\n   (quando detectada)
          ...
Cliente → Fecha conexão (ou perde rede)
Server  → Remove cliente do broadcaster

import { useEffect, useRef, useState } from 'react';

const BASE_API_URL = import.meta.env.VITE_API_URL;
const MAX_OPPORTUNITIES = 50;

function useRealtimeArbitrage() {
    const [opportunities, setOpportunities] = useState([]);
    const sourceRef = useRef(null);

    useEffect(() => {
        const source = new EventSource(`${BASE_API_URL}/v1/realtime/arbitrage`);
        sourceRef.current = source;

        source.onmessage = (event) => {
            const data = JSON.parse(event.data);
            setOpportunities(prev => [data, ...prev].slice(0, MAX_OPPORTUNITIES));
        };

        return () => source.close();
    }, []);

    return opportunities;
}