kfet/sockets/add/addUser.js

const models = require("../../models");

module.exports = socket => {
    return async (data) => {
        try {
            try {
                await models.User.create({
                    username: data.username,
                    firstName: data.firstName,
                    lastName: data.lastName,
                    passwordHash: data.password ? data.password : null
                });
            } catch (e) {
                if (e instanceof models.Sequelize.ValidationError)
                    socket.emit("fail add user");
                else
                    throw e;
            }

            socket.emit("add user", data.username);
            socket.broadcast.emit("add user", data.username);
        } catch (e) {
            socket.emit("internal error");
            console.error(e);
        }
    }
}