uWS server with subscribe on quotes from QuikClient

uWSserver.mjs

import uWS from "uWebSockets.js";
import { QuikClient } from './QuikClient.mjs'

const connection = new QuikClient({
  host: "10.211.55.3",
  port: 34130
});

connection.connect();

connection.on('onQuote', (data) => {
  app.publish('onQuote', JSON.stringify(["onQuote", data]));
});

// server
const app = uWS.App({})
  .ws('/*', {
    maxBackpressure: 10 * 1024 * 1024,
    open: (ws) => {
       ws.subscribe('onQuote');
    },
    close: (ws) => {
      ws.closed = true;

    },
    drain: (ws) => {
      if (!ws.closed)
        return ws.send(
          JSON.stringify([{ T: 'error', code: 407, msg: 'slow client' }])
        );
    },
    message: async (ws, message) => {
      if (ws.closed) return;
      try {
        const payload = JSON.parse(Buffer.from(message).toString());

        console.log(payload);
      } catch (e) {
        console.error(e);

        !ws.closed &&
          ws.send(
            JSON.stringify([{ T: 'error', code: 400, msg: 'invalid syntax' }])
          );
      }
    },
  })
  .get('/ping', async (res, req) => {
    res
      .writeStatus('200 OK')
      .writeHeader('Content-Type', 'text/plain;charset=UTF-8')
      .end('pong');
  })
  .listen(9003, (listenSocket) => {
    if (listenSocket) {
      console.log('Listening to port 9003');
    }
  });