import { FillsFeed } from '../src';

const RECONNECT_INTERVAL_MS = 1000;
const RECONNECT_ATTEMPTS_MAX = -1;

// Subscribe on connection
const fillsFeed = new FillsFeed('wss://api.mngo.cloud/fills/v1/', {
  reconnectionIntervalMs: RECONNECT_INTERVAL_MS,
  reconnectionMaxAttempts: RECONNECT_ATTEMPTS_MAX,
  subscriptions: {
    accountIds: ['9XJt2tvSZghsMAhWto1VuPBrwXsiimPtsTR8XwGgDxK2'],
  },
});

// Subscribe after connection
fillsFeed.onConnect(() => {
  console.log('connected');
  fillsFeed.subscribe({
    marketIds: ['ESdnpnNLgTkBCZRuTJkZLi5wKEZ2z47SG3PJrhundSQ2'],
    headUpdates: true,
  });
});

fillsFeed.onDisconnect(() => {
  console.log(`disconnected, reconnecting in ${RECONNECT_INTERVAL_MS}...`);
});

fillsFeed.onFill((update) => {
  console.log('fill', update);
});

fillsFeed.onHead((update) => {
  console.log('head', update);
});

fillsFeed.onStatus((update) => {
  console.log('status', update);
});