See RestClient for further information, or the examples for lots of usage examples.
WebSockets
All available WebSockets can be used via a shared WebsocketClient. The WebSocket client will automatically open/track/manage connections as needed. Each unique connection (one per server URL) is tracked using a WsKey (each WsKey is a string - see WS_KEY_MAP for a list of supported values).
Any subscribe/unsubscribe events will need to include a WsKey, so the WebSocket client understands which connection the event should be routed to. See examples below or in the examples folder on GitHub.
Data events are emitted from the WebsocketClient via the update event, see example below:
const { WebsocketClient } = require('gateio-api');
constAPI_KEY = 'xxx';
constPRIVATE_KEY = 'yyy';
const wsConfig = {
apiKey: API_KEY,
apiSecret: PRIVATE_KEY,
/*
The following parameters are optional:
*/// Livenet is used by default, use this to enable testnet:// useTestnet: true// how long to wait (in ms) before deciding the connection should be terminated & reconnected// pongTimeout: 1000,// how often to check (in ms) that WS connection is still alive// pingInterval: 10000,// how long to wait before attempting to reconnect (in ms) after connection is closed// reconnectTimeout: 500,// config options sent to RestClient (used for time sync). See RestClient docs.// restOptions: { },// config for axios used for HTTP requests. E.g for proxy support// requestOptions: { }
};
const ws = newWebsocketClient(wsConfig);
/**
* Subscribing to data:
**/const userOrders = {
topic: 'spot.orders',
payload: ['BTC_USDT', 'ETH_USDT', 'MATIC_USDT'],
};
const userTrades = {
topic: 'spot.usertrades',
payload: ['BTC_USDT', 'ETH_USDT', 'MATIC_USDT'],
};
const userPriceOrders = {
topic: 'spot.priceorders',
payload: ['!all'],
};
// subscribe to multiple topics at once
ws.subscribe([userOrders, userTrades, userPriceOrders], 'spotV4');
// and/or subscribe to individual topics on demand
ws.subscribe(
{
topic: 'spot.priceorders',
payload: ['!all'],
},
'spotV4',
);
// Some topics don't need params, for those you can just subscribe with a string (or use a topic + payload object as above)
ws.subscribe('spot.balances', 'spotV4');
/**
* Handling events:
**/// Listen to events coming from websockets. This is the primary data source
ws.on('update', (data) => {
console.log('data', data);
});
// Optional: Listen to websocket connection open event (automatic after subscribing to one or more topics)
ws.on('open', ({ wsKey, event }) => {
console.log('connection open for websocket with ID: ' + wsKey);
});
// Optional: Listen to responses to websocket queries (e.g. the reply after subscribing to a topic)
ws.on('response', (response) => {
console.log('response', response);
});
// Optional: Listen to connection close event. Unexpected connection closes are automatically reconnected.
ws.on('close', () => {
console.log('connection closed');
});
// Optional: listen to internal exceptions. Useful for debugging if something weird happens
ws.on('exception', (data) => {
console.error('exception: ', data);
});
// Optional: Listen to raw error events.
ws.on('error', (err) => {
console.error('ERR', err);
});
See WebsocketClient for further information and make sure to check the examples folder for much more detail.
Websocket API
The WebsocketClient supports this exchange's Websocket API. There are two ways to use the WS API, depending on individual preference:
event-driven:
send requests via client.sendWSAPIRequest(wsKey, channel, params), fire and forget, don't use await
handle async replies via event handlers on client.on('exception', cb) and client.on('response', cb)
promise-driven:
send requests via const result = await client.sendWSAPIRequest(wsKey, channel, params), which returns a promise
await each call
use try/catch blocks to handle promise rejections
The below example demonstrates the promise-driven approach, which behaves similar to a REST API. For more detailed examples, refer to the examples folder (e.g the ws-private-spot-wsapi.ts example).
const { WebsocketClient } = require('gateio-api');
constAPI_KEY = 'xxx';
constPRIVATE_KEY = 'yyy';
asyncfunctionstart() {
const client = newWebsocketClient({
apiKey: API_KEY,
apiSecret: PRIVATE_KEY,
// Automatically re-auth WS API, if we were auth'd before and get reconnectedreauthWSAPIOnReconnect: true,
});
/**
* Setup basic event handlers for core connectivity events.
* Note for this approach, the `response` and `update` events are not needed (but you can use them too/instead if you prefer).
**/// Successfully connected
client.on('open', (data) => {
console.log(newDate(), 'ws connected ', data?.wsKey);
});
// Something happened, attempting to reconnect
client.on('reconnect', (data) => {
console.log(newDate(), 'ws reconnect: ', data);
});
// Reconnect successful
client.on('reconnected', (data) => {
console.log(newDate(), 'ws reconnected: ', data);
});
// Connection closed. If unexpected, expect reconnect -> reconnected.
client.on('close', (data) => {
console.error(newDate(), 'ws close: ', data);
});
client.on('exception', (data) => {
console.error(newDate(), 'ws exception: ', data);
});
client.on('authenticated', (data) => {
console.error(newDate(), 'ws authenticated: ', data);
});
try {
/**
* All WebSocket API (WS API) messaging should be done via the sendWSAPIRequest method.
*/// The WSKey identifies which connection this request is for.// (e.g. "spotV4" | "perpFuturesUSDTV4" | "perpFuturesBTCV4" | "deliveryFuturesUSDTV4" | "deliveryFuturesBTCV4" | "optionsV4")const wsKey = 'spotV4';
/**
* To authenticate, send an empty request to "spot.login". The SDK will handle all the parameters.
*
* By default (reauthWSAPIOnReconnect: true), if we get reconnected later on (e.g. connection temporarily lost), we will try to re-authenticate the WS API automatically when the connection is restored.
*/console.log(newDate(), 'try authenticate');
const loginResult = await client.sendWSAPIRequest(wsKey, 'spot.login');
console.log(newDate(), 'authenticated!', loginResult);
/**
* For other channels, you should include any parameters for the request (the payload) in your call.
*
* Note that internal parameters such as "signature" etc are all handled automatically by the SDK. Only the core request parameters are needed.
*/console.log(newDate(), 'try get order status');
const orderStatus = await client.sendWSAPIRequest(
wsKey,
'spot.order_status',
{
order_id: '600995435390',
currency_pair: 'BTC_USDT',
},
);
console.log(newDate(), 'orderStatus result!', orderStatus);
} catch (e) {
console.error(`WS API Error: `, e);
}
}
start();
Customise Logging
Pass a custom logger which supports the log methods silly, debug, notice, info, warning and error, or override methods from the default logger as desired.
const { WebsocketClient, DefaultLogger } = require('gateio-api');
// Disable all logging on the silly levelDefaultLogger.silly = () => {};
const ws = newWebsocketClient({ key: 'xxx', secret: 'yyy' }, DefaultLogger);
Contributions & Thanks
Have my projects helped you? Share the love, there are many ways you can show your thanks:
Complete & robust Node.js SDK for Gate.io's REST APIs, WebSockets & WebSocket APIs, with TypeScript declarations.
The npm package gateio-api receives a total of 92 weekly downloads. As such, gateio-api popularity was classified as not popular.
We found that gateio-api demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago.It has 0 open source maintainers collaborating on the project.
Package last updated on 10 Feb 2025
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Newly introduced telemetry in devenv 1.4 sparked a backlash over privacy concerns, leading to the removal of its AI-powered feature after strong community pushback.
TC39 met in Seattle and advanced 9 JavaScript proposals, including three to Stage 4, introducing new features and enhancements for a future ECMAScript release.