adonisjs 5 websocket

socket.ts

import { WebSocket } from 'ws'
import Ws from 'App/Services/Ws'

let clientId: number = 0;
Ws.boot()

const serverIo = Ws.wss;
/**
 * Listen for incoming socket connections
 */
interface ExtWebSocket extends WebSocket {
   isAlive: boolean;
}


serverIo.on('connection', function connection(ws) {
   const extWs = ws as ExtWebSocket;
   clientId++;
   console.log(clientId + " connected");
   extWs.isAlive = true;
   ws.on('pong', () => extWs.isAlive = true);

   ws.send('hello');

   ws.on('close', function () {
      console.log(clientId + " disconnected");

   });
   ws.on('message', function message(data, isBinary) {
      serverIo.clients.forEach(function each(client) {
         if (client.readyState === WebSocket.OPEN) {
            client.send(data, { binary: isBinary });
         }
      });
   });
});
const interval = setInterval(function ping() {
   serverIo.clients.forEach(function each(ws: WebSocket) {
      const extWs = ws as ExtWebSocket;
      if (!extWs.isAlive) return ws.terminate();

      extWs.isAlive = false;
      ws.ping(null, undefined);
   });
}, 5000);

serverIo.on('close', function close() {
   console.log(clientId + " disconnected..");
   clearInterval(interval);
});

Added ping, pong. To avoid automatic shutdown of the connection. Fix isAlive typescript error