Bybit JavaScript SDK

1/* eslint-disable @typescript-eslint/no-empty-function */2import { DefaultLogger, WebsocketClient, WS_KEY_MAP } from 'bybit-api';3 4// Create & inject a custom logger to enable the trace logging level (empty function)5const logger = {6  ...DefaultLogger,7  // trace: (...params) => console.log('trace', ...params),8};9 10const key = process.env.API_KEY_COM;11const secret = process.env.API_SECRET_COM;12 13/**14 * Prepare an instance of the WebSocket client. This client handles all aspects of connectivity for you:15 * - Connections are opened when you subscribe to topics16 * - If key & secret are provided, authentication is handled automatically17 * - If you subscribe to topics from different v5 products (e.g. spot and linear perps),18 *    subscription events are automatically routed to the different ws endpoints on bybit's side19 * - Heartbeats/ping/pong/reconnects are all handled automatically.20 *    If a connection drops, the client will clean it up, respawn a fresh connection and resubscribe for you.21 */22const wsClient = new WebsocketClient(23  {24    key: key,25    secret: secret,26    // testnet: false,27    // demoTrading: false, // set testnet to false, if you plan on using demo trading28  },29  logger,30);31 32wsClient.on('update', (data) => {33  console.log('raw message received ', JSON.stringify(data));34  // console.log('raw message received ', JSON.stringify(data, null, 2));35});36 37wsClient.on('open', (data) => {38  console.log('connection opened open:', data.wsKey);39});40wsClient.on('response', (data) => {41  console.log('log response: ', JSON.stringify(data, null, 2));42});43wsClient.on('reconnect', ({ wsKey }) => {44  console.log('ws automatically reconnecting.... ', wsKey);45});46wsClient.on('reconnected', (data) => {47  console.log('ws has reconnected ', data?.wsKey);48});49// wsClient.on('exception', (data) => {50//   console.error('ws exception: ', data);51// });52 53/**54 * For private V5 topics, us the subscribeV5() method on the ws client or use the original subscribe() method.55 *56 * Note: for private endpoints the "category" field is ignored since there is only one private endpoint57 * (compared to one public one per category).58 * The "category" is only needed for public topics since bybit has one endpoint for public events per category.59 */60 61wsClient.subscribeV5('position', 'linear');62wsClient.subscribeV5(['order', 'wallet', 'greeks'], 'linear');63 64wsClient.subscribeV5('execution', 'linear');65// wsClient.subscribeV5('execution.fast', 'linear');66// wsClient.subscribeV5('execution.fast.linear', 'linear');67// wsClient.subscribeV5('execution.fast.spot', 'spot');68// wsClient.subscribeV5('execution.fast.option', 'option');69 70/**71 * The following has the same effect as above, since there's only one private endpoint for V5 account topics:72 */73// wsClient.subscribe('position');74// wsClient.subscribe('execution');75// wsClient.subscribe(['order', 'wallet', 'greek']);76 77// To unsubscribe from topics (after a 5 second delay, in this example):78// setTimeout(() => {79//   console.log('unsubscribing');80//   wsClient.unsubscribeV5('execution', 'linear');81// }, 5 * 1000);82 83// Topics are tracked per websocket type84// Get a list of subscribed topics (e.g. for public v3 spot topics) (after a 5 second delay)85setTimeout(() => {86  const activePrivateTopics = wsClient87    .getWsStore()88    .getTopics(WS_KEY_MAP.v5Private);89  console.log('Active private v5 topics: ', activePrivateTopics);90 91  const activePublicLinearTopics = wsClient92    .getWsStore()93    .getTopics(WS_KEY_MAP.v5LinearPublic);94  console.log('Active public linear v5 topics: ', activePublicLinearTopics);95 96  const activePublicSpotTopis = wsClient97    .getWsStore()98    .getTopics(WS_KEY_MAP.v5SpotPublic);99  console.log('Active public spot v5 topics: ', activePublicSpotTopis);100 101  const activePublicOptionsTopics = wsClient102    .getWsStore()103    .getTopics(WS_KEY_MAP.v5OptionPublic);104  console.log('Active public option v5 topics: ', activePublicOptionsTopics);105}, 5 * 1000);