Connect to Coinbase WS

socket.js

const CoinbasePro = require('coinbase-pro');
const subscriptions = ['BTC-USD', 'ETH-EUR'];
let groups = {};
let beat = {};

startCoinbaseSocket = (subscriptions, groupid) => {
      let websocket = new CoinbasePro.WebsocketClient(
          subscriptions,
          'wss://ws-feed.pro.coinbase.com',
          {
              key: '*',
              secret: '*',
              passphrase: '*',
          },
          { channels: ['full', 'level2', 'ticker'] });
          websocket.on('message', data => {
              handleMessage(data);
          });
          websocket.on('error', (err) => {
              console.log(err)
          });
          websocket.on('close', (data) => {
              console.log(`Websocket Error: websocket closed unexpectedly with data: ${data}. Attempting to re-connect.`);
              groups[groupid] = {
                  ...groups[groupid],
                  client: startCoinbaseSocket(subscriptions, groupid),
                  launchTime: getTime(),
              }
          });
      return websocket
  
  
 handleMessage = (msg) => {
     switch(msg.type) {
        case 'l2update':
            break;

        case 'ticker':
            let lastRecord = getTime();
            updateTicker(msg);
            beats[msg.product_id] = msg.sequence;
            break;

        default:
            beat[msg.product_id] = msg.sequence;
            break;
      }
}
 
groups[1] = {
    client: startCoinbaseSocket(subscriptions, 1),
    launchTime: getTime(),
  }