Bybit TypeScript SDK example: ws-public-allLiquidations.ts

Bybit WebSocket Public websocket public all liquidations example for the Siebly Bybit SDK, with TypeScript source for exchange REST API and WebSocket integration, setup, and production SDK docs.

What This Example Covers

Bybit WebSocket stream example in TypeScript.
Uses the Siebly Bybit SDK package bybit-api instead of hand-written WebSocket plumbing.
Source path: Bybit/Websocket/Public/ws-public-allLiquidations.ts.
Example category: WebSocket Public.
Imports SDK symbols including RestClientV5, WebsocketClient.
Calls SDK methods such as on(), subscribeV5().

How To Use This Example

Start here for the specific request or stream pattern, then check the matching SDK guide for install, credentials, and operational notes.
For WebSocket examples, keep reconnect, resubscribe, heartbeat, and event-handler behavior explicit in your service.
Open the repository source when you need the latest committed version: GitHub source file.

Example Path

Bybit/Websocket/Public/ws-public-allLiquidations.ts

Source Link

Repository source: https://github.com/sieblyio/crypto-api-examples/blob/master/examples/Bybit/Websocket/Public/ws-public-allLiquidations.ts

Related SDK Docs

Example Source

import {
  isWsAllLiquidationEvent,
  RestClientV5,
  WebsocketClient,
} from 'bybit-api';

//   RestClientV5,
//   WebsocketClient,
//   isWsAllLiquidationEvent,
// } from 'bybit-api';

function onAllLiquidationEvent(event: unknown) {
  console.log(
    new Date(),
    'allLiquidationEvent',
    JSON.stringify(event, null, 2),
  );
}

const wsClient = new WebsocketClient({});

wsClient.on('update', (data) => {
  if (isWsAllLiquidationEvent(data)) {
    return onAllLiquidationEvent(data);
  }

  console.log('raw unahndled message received ', JSON.stringify(data));
});

wsClient.on('open', (data) => {
  console.log('connection opened open:', data.wsKey);
});
wsClient.on('response', (data) => {
  console.log('log response: ', JSON.stringify(data, null, 2));
});
wsClient.on('reconnect', ({ wsKey }) => {
  console.log('ws automatically reconnecting.... ', wsKey);
});
wsClient.on('reconnected', (data) => {
  console.log('ws has reconnected ', data?.wsKey);
});

wsClient.on('exception', (data) => {
  console.error('ws exception: ', data);
});

/**
 *
 * If you want to receive data for all available symbols, this websocket topic
 * requires you to subscribe to each symbol individually.
 *
 * This can be easily automated by fetching a list of symbols via the REST client,
 * generating a list of topics (one per symbol), before simply passing an
 * array of topics to the websocket client per product group (linear & inverse perps).
 *
 */
async function start() {
  const restClientV5 = new RestClientV5();

  const allSymbolsV5ResultLinear = await restClientV5.getTickers({
    category: 'linear',
  });
  const allSymbolsV5ResultInverse = await restClientV5.getTickers({
    category: 'inverse',
  });

  const allLinearSymbols = allSymbolsV5ResultLinear.result.list.map(
    (ticker) => ticker.symbol,
  );
  const allInverseSymbols = allSymbolsV5ResultInverse.result.list.map(
    (ticker) => ticker.symbol,
  );

  console.log('all v5 linear symbols: ', JSON.stringify(allLinearSymbols));
  console.log('all v5 inverse symbols: ', JSON.stringify(allInverseSymbols));

  const TOPIC_NAME = 'allLiquidation';

  // Make an array of topics ready for submission
  const allLinearTopics = allLinearSymbols.map(
    (symbol) => `${TOPIC_NAME}.${symbol}`,
  );
  const inverseTopics = allInverseSymbols.map(
    (symbol) => `${TOPIC_NAME}.${symbol}`,
  );

  // subscribe to all linear symbols
  wsClient.subscribeV5(allLinearTopics, 'linear');

  // subscribe to all inverse symbols
  wsClient.subscribeV5(inverseTopics, 'inverse');
}

start().catch((e) => console.error('exception in main logic: ', e));