Отправить сообщение

server.listen(appPort, () => {
  console.log(`Server running at `);
});
 
app.post('/user/reg', auth, (req,res) =>{
    let login = req.body.login;
    let password = req.body.password;
    let confirm = req.body.confirm_password;
 
    connection.query("SELECT * FROM `users` WHERE `login` = '" + login + "'",   function(err,res){
    
        if (res.length < 1) {
            connection.query("INSERT INTO `users` (`login`,`password`) VALUES('" + login + "','" + password + "')", function(err,res) {
            
                if(err) console.log(222);
                // необходимо отправить сообщение
                else {
// необходимо отправить сообщение
                    console.log(login)
                }
 
            });
        }
        else {
//тут я хочу отправить сообщение, но разумеется ничего не отправляется, т.к. функция подключения находится ниже.
            io.sockets.emit('user_registered', 'user registered');
            console.log('user registered!');
        }
 
    });
// необходимо отправить сообщение
    return res.redirect('/log')
});
// socket.io connections
var users = 0;
var userid = "";
io.sockets.on('connection', function (socket) { 
 
}

io.sockets.emit('user_registered', 'user registered');