Example: app.okx.com.ts

Example Path

OKX/Websocket/app.okx.com.ts

Source Link

Repository source: https://github.com/sieblyio/crypto-api-examples/blob/master/examples/OKX/Websocket/app.okx.com.ts

Code Snapshot

import { RestClient, WebsocketClient } from 'okx-api';

const client = new RestClient({
  /**
   * To use "app.okx.com", set market to "US"
   *
   * Note: your available functionality may differ, refer to the corresponding API docs for more details:
   * https://app.okx.com/docs-v5/en/#overview-production-trading-services
   */
  market: 'US',
});

const wsClient = new WebsocketClient({
  market: 'US',
});

/**
 * This is a simple script wrapped in a immediately invoked function expression, designed to make public API calls without credentials
 */
(async () => {
  try {
    const results = await client.getInstruments({ instType: 'SPOT' });

    console.log(
      'result: ',
      results.filter((row) => row.baseCcy === 'SUI'),
    );
  } catch (e) {
    console.error('request failed: ', e);
  }

  // Raw data will arrive on the 'update' event
  wsClient.on('update', (data) => {
    // console.log(
    //   new Date(),
    //   'ws update (raw data received)',
    //   JSON.stringify(data, null, 2),
    // );
    // console.log('ws update (raw data received)', JSON.stringify(data, null, 2));
    console.log(
      new Date(),
      'ws update (raw data received)',
      JSON.stringify(data),
    );
  });
  wsClient.on('open', (data) => {
    console.log('ws connection opened open:', data.wsKey);
  });
  wsClient.on('reconnected', (data) => {
    console.log('ws has reconnected ', data?.wsKey);
  });
  wsClient.on('exception', (data) => {
    console.error('ws exception: ', data);
  });
  wsClient.subscribe([
    {
      channel: 'instruments',
      instType: 'SPOT',
    },
    {
      channel: 'tickers',
      instId: 'ETH-BTC',
    },
  ]);
})();