Coinbase JavaScript SDK

1import {2  // DefaultLogger,3  WebsocketClient,4  // WS_KEY_MAP,5  WsTopicRequest,6} from 'coinbase-api';7 8async function start() {9  // key name & private key, as returned by coinbase when creating your API keys.10  // Note: the below example is a dummy key and won't actually work11 12  // Optional: fully customise the logging experience by injecting a custom logger13  // const logger: typeof DefaultLogger = {14  //   ...DefaultLogger,15  //   trace: (...params) => {16  //     if (17  //       [18  //         'Sending ping',19  //         'Sending upstream ws message: ',20  //         'Received pong, clearing pong timer',21  //         'Received ping, sending pong frame',22  //       ].includes(params[0])23  //     ) {24  //       return;25  //     }26  //     console.log('trace', params);27  //   },28  // };29 30  const client = new WebsocketClient(31    {32      // Either pass the full JSON object that can be downloaded when creating your API keys33      // cdpApiKey: advancedTradeCdpAPIKey,34 35      // initialise the client36      /**37       *38       * You can add both ED25519 and ECDSA keys, client will recognize both types of keys39       *40       * ECDSA:41       *42       * {43       *   apiKey: 'organizations/your_org_id/apiKeys/your_api_key_id',44       *   apiSecret:45       *     '-----BEGIN EC PRIVATE KEY-----\nMHcCAQEEIPT/TTZPxw0kDGvpuCENJp9A4/2INAt9/QKKfyidTWM8oAoGCCqGSM49\nAwEHoUQDQgAEd+cnxrKl536ly5eYBi+8dvXt1MJXYRo+/v38h9HrFKVGBRndU9DY\npV357xIfqeJEzb/MBuk3EW8cG9RTrYBwjg==\n-----END EC PRIVATE KEY-----\n',46       * }47       *48       * ED25519:49       * {50       *   apiKey: 'your-api-key-id',51       *   apiSecret: 'yourExampleApiSecretEd25519Version==',52       * }53       *54       *55       */56      apiKey: process.env.API_KEY_NAME || 'insert_api_key_here',57      apiSecret: process.env.API_PRIVATE_KEY || 'insert_api_secret_here',58    },59    // logger,60  );61 62  client.on('open', (data) => {63    console.log('open: ', data?.wsKey);64  });65 66  // Data received67  client.on('update', (data) => {68    console.info(new Date(), 'data received: ', JSON.stringify(data));69  });70 71  // Something happened, attempting to reconnect72  client.on('reconnect', (data) => {73    console.log('reconnect: ', data);74  });75 76  // Reconnect successful77  client.on('reconnected', (data) => {78    console.log('reconnected: ', data);79  });80 81  // Connection closed. If unexpected, expect reconnect -> reconnected.82  client.on('close', (data) => {83    console.error('close: ', data);84  });85 86  // Reply to a request, e.g. "subscribe"/"unsubscribe"/"authenticate"87  client.on('response', (data) => {88    console.info('response: ', JSON.stringify(data, null, 2));89    // throw new Error('res?');90  });91 92  client.on('exception', (data) => {93    console.error('exception: ', data);94  });95 96  try {97    /**98     * Use the client subscribe(topic, market) pattern to subscribe to any websocket topic.99     *100     * You can subscribe to topics one at a time or many in one request.101     *102     * Topics can be sent as simple strings, if no parameters are required.103     *104     * Any subscribe requests on the "advTradeUserData" market are automatically authenticated with the available credentials105     */106    // client.subscribe('heartbeats', 'advTradeUserData');107    client.subscribe('futures_balance_summary', 'advTradeUserData');108    // This is the same as above, but uses WS_KEY_MAP as an enum (do this if you're not sure what value to put)109    // client.subscribe('futures_balance_summary', WS_KEY_MAP.advTradeUserData);110 111    // Subscribe to the user feed for the advanced trade websocket112    client.subscribe('user', 'advTradeUserData');113 114    // /**115    //  * Or, as an array of simple strings.116    //  *117    //  * Any requests sent to the "advTradeUserData" wsKey are118    //  * automatically authenticated, if API keys are available:119    //  */120    // client.subscribe(121    //   ['futures_balance_summary', 'user'],122    //   'advTradeUserData',123    // );124 125    /**126     * Or send a more structured object with parameters, e.g. if parameters are required127     */128    // eslint-disable-next-line @typescript-eslint/no-unused-vars129    const tickerSubscribeRequest: WsTopicRequest = {130      topic: 'futures_balance_summary',131      /**132       * Anything in the payload will be merged into the subscribe "request",133       * allowing you to send misc parameters supported by the exchange (such as `product_ids: string[]`)134       */135      payload: {136        // In this case, the "futures_balance_summary" channel doesn't support any parameters137        // product_ids: ['ETH-USD', 'BTC-USD'],138      },139    };140    client.subscribe(tickerSubscribeRequest, 'advTradeUserData');141  } catch (e) {142    console.error('Subscribe exception: ', e);143  }144}145 146start();