Socket.Io in Norde.Js / Angular

 

======socket.js

let io;

module.exports = {

    init: httpServer => {

        io = require('socket.io')(httpServer, {

            cors: {

                origin: "*",

                credentials: true

            }

        });

        return io;

    },

    getIO: () => {

        if (!io) {

            throw new Error('Socket.io not initialized!');

        }

        return io;

    },

    getNoOfUserConnected: () => {

        if (!io) {

            throw new Error('Socket.io not initialized!');

        } 

        // console.log(">>>>>>ddddd>",io.engine.clientsCount);

        // console.log(">>>>>>>",io.sockets.sockets.length); 

        return io.engine.clientsCount;

    }

};

====app.js

mongoose

    .connect(

        'mongodb+srv://ajtest:J9Xv169XWFbkSoQT@cluster0.b2p29.mongodb.net/test?retryWrites=true'

    )

    .then(result => {

        var server = app.listen(8082);

        const io = require('./socket').init(server);

        io.on('connection', socket => {

            console.log('Client connected');

            // require('./socket').getIO().emit('liveUser', { liveUser: require('./socket').getUserConnected() });

            console.log(">>>>getNoOfUserConnected", require('./socket').getNoOfUserConnected());

        })

    })

    .catch(err => console.log(err));

        var liveUser = require('./socket').getNoOfUserConnected();

require('./socket').getIO().emit('data1', "data");

========================Angular============

import { io } from 'socket.io-client';

const socket = io('http://localhost:8082');

  ngOnInit(): void {

    socket.on('liveUser', (res: any) => {

      console.log(">>>liveUser connectiont", res); 

    })

  }