Interface KumaEventBase

import {
  WebSocketClient,
  MessageEventType,
  SubscriptionNamePublic,
  type KumaMessageEvent,
  type KumaTickerEventData,
  type KumaSubscribeType,
} from '@kumabid/kuma-sdk';

const client = new WebSocketClient();

function handleSubscriptions(subscriptions: KumaSubscribeType[]) {
  // all subscribed subscriptions
  console.log('Active Subscriptions: ', subscriptions);
}

function handleTickersUpdate(message: KumaTickerEventData) {
  // handle the updated data
  console.log('Ticker: ', message);
}

client.onMessage((message: KumaMessageEvent) => {
  switch (message.type) {
    case MessageEventType.error:
      console.error(
        `[${message.data.code}] | Error received from WebSocketServer: ${message.data.message}`,
      );
      break;
    case MessageEventType.subscriptions:
      return handleSubscriptions(message.subscriptions);
    // narrows the type to the specific Kuma<name>Event type
    case MessageEventType.tickers:
      return handleTickersUpdate(message.data);
    default:
      break;
  }
});

async function main() {
  await client.connect();

  client.subscribePublic([
    {
      name: SubscriptionNamePublic.tickers,
      markets: ['ETH-USD'],
    },
  ]);
}

main().catch((error) => {
  console.error('Error During Startup: ', error);
});
Copy