alevor657 / bth-socketio-broadcast-server

var io = require('socket.io')();

class SocketChat {

    constructor(port) {

        this.connections = [];

        this.users = [];

        this.onDisconnect = this.onDisconnect.bind(this);

        this.onLogin = this.onLogin.bind(this);

        this.onConnection = this.onConnection.bind(this);

        io.on('connection', this.onConnection);

        io.listen(port);

        console.log('==> 🌎  Sockets server listens on port %s', port);

    }

    onChatMsg(data) {

        io.emit('chat msg', data);

    }

    onNewUser(data) {

        io.emit('new user', data);

    }

    onLogin(data) {

        this.users.push({

            user: data.nick,

            id: data.socketId

        });

        io.emit('update users', JSON.stringify(this.users));

    }

    onDisconnect(socket) {

        this.connections.splice(this.connections.indexOf(socket), 1);

        this.users = this.users.filter(user => user.id !== socket.id);

        io.emit('update users', JSON.stringify(this.users));

        console.log('User disconnected');

        console.log('Clients connected: ', this.connections.length);

    }

    onConnection(socket) {

        this.connections.push(socket);

        console.log('Clients connected: ', this.connections.length);

        socket.on('chat msg', this.onChatMsg);

        socket.on('new user', this.onNewUser);

        socket.on('login', this.onLogin);

        socket.on('disconnect', () => {

            this.onDisconnect(socket);

        });

    }

}

module.exports = SocketChat;