TypeScript Settlement Stream

import { PolyNode } from 'polynode-sdk';

const apiKey = process.env.POLYNODE_API_KEY;
if (!apiKey) throw new Error('Set POLYNODE_API_KEY');
const pn = new PolyNode({ apiKey });

const sub = await pn.ws
  .subscribe('settlements')
  .status('all')
  .minSize(100)
  .send();

console.log({
  subscriptionId: sub.id,
  warnings: sub.warnings,
});

sub.on('settlement', (event) => {
  console.log('pending', event.tx_hash, event.taker_size);
});

sub.on('status_update', (event) => {
  console.log('confirmed', event.tx_hash, event.block_number);
});

sub.on('*', (event) => {
  if (event.event_type === 'unknown') {
    console.log('new event type', event.wire_event_type, event.raw);
  }
});

sub.onOverflow((notice) => {
  console.error('consumer fell behind', notice);
});

pn.ws.onReplay((notice) => {
  console.warn('reconnect replay', notice);
});

const fills = await pn.ws
  .subscribe('fills')
  .wallets(['0x...'])
  .conditionIds(['0x...'])
  .since(Date.now() - 30_000)
  .send();

sub.unsubscribe();
pn.ws.disconnect();