HTX JavaScript SDK

1/* eslint-disable @typescript-eslint/no-unused-vars */2import {3  DefaultLogger,4  LogParams,5  WebsocketClient,6  WS_KEY_MAP,7} from '@siebly/htx-api';8 9// Install from npm in your own project:10// import { WebsocketClient, WS_KEY_MAP, WSTopicRequest } from '@siebly/htx-api';11 12function isRecord(value: unknown): value is Record<string, unknown> {13  return typeof value === 'object' && value !== null;14}15 16function isMutedTrace(params: LogParams): boolean {17  const [message, details] = params;18 19  if (message === 'Received PING event') {20    return true;21  }22 23  if (message === 'onWsMessage().emit(message)') {24    return true;25  }26 27  if (28    typeof message === 'string' &&29    message.startsWith('getFinalEmittable()->pre()')30  ) {31    return true;32  }33 34  if (35    message === 'Sending upstream ws message: ' &&36    isRecord(details) &&37    typeof details.wsMessage === 'string'38  ) {39    // return false;40    return !details.wsMessage.includes('"pong"');41  }42 43  return false;44}45 46const customLogger: DefaultLogger = {47  trace: (...params: LogParams): void => {48    // if (isMutedTrace(params)) {49    //   return;50    // }51    // console.log('trace', params);52  },53  info: (...params: LogParams): void => {54    console.log('info', ...params);55  },56  error: (...params: LogParams): void => {57    console.error('error', ...params);58  },59};60 61async function start() {62  const account = {63    key: process.env.API_KEY || '',64    secret: process.env.API_SECRET || '',65  };66 67  const client = new WebsocketClient(68    {69      apiKey: account.key,70      apiSecret: account.secret,71    },72    customLogger,73  );74 75  client76    .on('open', (data) => console.log('open:', data.wsKey))77    .on('authenticated', (data) => console.log('authenticated:', data.wsKey))78    .on('message', (data) => console.info('message:', JSON.stringify(data)))79    .on('response', (data) => console.info('response:', JSON.stringify(data)))80    .on('reconnecting', (data) => console.log('reconnecting:', data.wsKey))81    .on('reconnected', (data) => console.log('reconnected:', data.wsKey))82    .on('close', (data) => console.log('close:', data.wsKey))83    .on('exception', (data) => console.error('exception:', data));84 85  /**86   * Spot private websocket: wss://api-aws.huobi.pro/ws/v2 by default.87   *88   * The SDK signs and sends the auth request automatically before subscribing.89   */90 91  client.subscribe(92    [93      // not specifying "mode", Only update when account balance changed;94      'accounts.update',95      // Specify "mode" as 0, Only update when account balance changed;96      'accounts.update#0',97      // Specify "mode" as 1, Update when either account balance changed or available balance changed.98      'accounts.update#1',99      // Specify "mode" as 2, Whenever account balance or available balance changed, it will be updated together.100      'accounts.update#2',101      // Subscribe to order updates for all symbols (wildcard allowed)102      'orders#*',103      // Subscribe to order updates for btcusdt only104      'orders#btcusdt',105      // Subscribe to trade clearing for all symbols (wildcard allowed) (mode is optional)106      'trade.clearing#*',107      // Subscribe to trade clearing for btcusdt only (mode is optional)108      'trade.clearing#btcusdt',109      // Subscribe to trade clearing for all symbols, mode 0 (trade event only (default))110      'trade.clearing#*#0',111      // Subscribe to trade clearing for all symbols, mode 1 (trade & cancellation events)112      'trade.clearing#*#1',113    ],114    WS_KEY_MAP.spotPrivateV2,115  );116}117 118start();