Управление несколькими клиентскими подключениями Websocket с помощью node.js

Question

Я реализую клиент websocket в узле, и мой webhook пытается обработать несколько соединений из службы chatbot.Например: доход нового пользователя, соединение веб-сокета устанавливается на внешнем сервисе чат-бота.URL-адрес веб-сокета получен через XMLHttpRequest в моем коде.И затем я использую этот URL для подключения к сервису chatbot с помощью объекта ws (new WebSocket('wssUrlObtainedThroughAjaxRequest','default-protocol')).Таким образом, у каждого пользователя есть WebSocket.Вопрос в том, что мой код работает последовательно.Так что, если два человека отправляют сообщение на мой узел webhook, вещи не работают должным образом из-за параллелизма.Хорошо, я выложу здесь пример кода, чтобы его было легче понять.

const express = require('express');
const PORT = process.env.PORT || 8002;
let WebSocket = require('ws');
let CONNECTIONS = new Map();
...
...
...
const app = express()
    .use(bodyparser.urlencoded({extended: false}))
    .use(bodyparser.json());

app.post('/', (req, res) => { 
...
...
...
    } else if (req.body.type === 'MESSAGE') {

    let DM = req.body.space.name;
    let msg = req.body.message.text;

    ws = (CONNECTIONS.get(DM)!=null) ? CONNECTIONS.get(DM) : null;

    if(ws==null || ws.readyState==3){
      controlws.gerarURLWS();
      ws = new WebSocket(controlws.urlws, 'talk-protocol');
      CONNECTIONS.set(DM,ws);
    }

    // Executes on websocket openning
    ws.onopen = function (event) {
      console.log('Canal aberto;');
      keepAliveWS();
      ws.send(JSON.stringify(msgKoreAi(msg))); 
    }

    if(ws.readyState==1)
      ws.send(JSON.stringify(msgKoreAi(msg))); 

    ws.onmessage = async function (event) {
      let resp = JSON.parse(event.data);

      if (resp.type == "bot_response") {
        text = resp.message[0].component.payload.text;

        if(text==null){ // tem quick reply
          //mount card hangouts response 
          let qreplies = resp.message[0].component.payload.payload.quick_replies; 
          card = '{"sections": [{"widgets": [{"buttons": [';
          for(let i=0; i<qreplies.length; i++){
            if(i!=qreplies.length-1)
              card+='{"textButton": {"text": "'+qreplies[i].payload+'","onClick": {"action": {"actionMethodName": "'+qreplies[i].payload+'"}}}},';
            else
              card+='{"textButton": {"text": "'+qreplies[i].payload+'","onClick": {"action": {"actionMethodName": "'+qreplies[i].payload+'"}}}}';
          }      
          card+=']}]}],"name": "respostas"}';
          card = JSON.parse(card);

          text = resp.message[0].component.payload.payload.text; 
          {
            await assyncMessage(DM, text);
            await assyncMessage(DM, card);
          }
          return;
        }

        //Send assync messages if synchronous was already sent
        if(res.headersSent){
          {
            return await assyncMessage(DM, text);
          }
        }
        else
          return res.json({text});
      }
    }
    return;
  }
...
...
...
app.listen(PORT, () => {
  console.log(`Server is running in port - ${PORT}`);
});