index.js

const socketio = require('socket.io');
const mysql = require('mysql');
const { response, Router } = require('express');
var conn = mysql.createConnection({
  host:"localhost",
  user:"root",
  password:"password",
  database:"guess_who"
});
var express = require('express'),
    app = express(),
    session = require('express-session');
app.use(session({
    cookie: {
      path    : '/',
      httpOnly: false,
      maxAge  : 24*60*60*1000
    },
    secret: '2C44-4D44-WppQ38S',
    resave: true,
    saveUninitialized: true
}));
app.use(express.json());

conn.connect((err)=>{
  if(err){ 
    console.log('Error in DB Connection');
    throw err;
  } else{
    console.log('Connected to the DB!');
  }
})

// Login endpoint
app.post('/login', function (req, res) {
  let usuario = req.body.usuario;
  let pass = req.body.password;
  console.log(req.body);
  conn.query(`SELECT * FROM usuarios WHERE id_usu='${usuario}' and passwd='${pass}'`, function (err, result) {
    console.log(result);
    if (err || result[0] == undefined){
      //throw err;
      res.send('{"mensaje":"login failed"}');
    } else{
      res.send('{"mensaje":"login success!"}');
    }

  });
});


app.post('/registro', (req, res)=>{
  let nombre = req.body.name;
  let nombreUsuario = req.body.username;
  let pais = req.body.country;
  let passwd = req.body.password;
  console.log(req.body);
  conn.query(`SELECT * FROM paises WHERE nombre='${pais}'`, (err, result)=>{
    console.log(result);
    if (err || result[0] == undefined){
      //throw err;
      res.send('{"message":"Pais No encontrado"}');
    } else{
      let idPais = result[0].id_p;
      conn.query(`INSERT INTO usuarios VALUES('${nombreUsuario}','${nombre}','${idPais}',null,'D','${passwd}')`,(err2, result2)=>{
        console.log(result2);
        if (err2){
          console.log(err2);
          res.send('{"message":"sign up failed"}');
        } else{
          res.send('{"message":"success!"}');
        }
      });
      
    }
  })
  
});

app.post('/buscar_puntuacion', (req,res)=>{
  //let id_jugador = req.session.user;
  let id_jugador = req.body.id;
  console.log(req.body);
    conn.query(`SELECT abreviacion,usuarios.nombre,total_partidas,total_victorias,total_derrotas,total_puntos 
      FROM puntuaciones,usuarios,paises WHERE paises.id_p=usuarios.id_pais && puntuaciones.id_punt=usuarios.id_puntuacion and usuarios.id_usu='${id_jugador}'`,(err,result)=>{
        console.log(result);
        res.send(`{"nacionalidad":"${result[0].abreviacion}","total_partidas":"${result[0].total_partidas}","total_derrotas":"${result[0].total_derrotas}","total_victorias":"${result[0].total_victorias}","total_puntos":"${result[0].total_puntos}"}`);
      });

});

app.post('/newGame', (req, res)=>{
  let id_usuario1 = req.body.username;
  console.log('New Game');
  console.log(req.body);
  conn.query(`INSERT INTO partidas (id_usuario1, id_usuario2, id_usuario1_personaje, id_usuario2_personaje, id_usuario_ganador) VALUES ('${id_usuario1}', NULL, NULL, NULL, NULL)`, (err, result)=>{
    if(err) throw err;
    console.log(result);
    res.send(`{"gameId":"${result.insertId}"}`);
  });
});

app.post('/joinGame',(req,res)=>{
  let id_usuario2 = req.body.username;
  let id = req.body.gameId;
  console.log('Join');
  console.log(req.body);
  conn.query(`UPDATE partidas SET id_usuario2 = '${id_usuario2}' WHERE id_game = '${id}'`,(err, result)=>{
    if(err) throw err;
    console.log(result);
    res.send(`{"message":"Unido a la partida"}`);
  });
});

app.post('/getPersonaje', (req,res)=>{
  let username = req.body.usuario;
  let chatId = req.body.chatId;
  console.log(req.body);
  conn.query(`SELECT asignacion_personaje(${chatId},'${username}') as personaje`, (err, result)=>{
    if(err) throw err;
    console.log(result[0]);
    conn.query(`SELECT * FROM personajes WHERE id = '${result[0].personaje}'`, (err2, result2)=>{
      if(err2) throw err2;
      console.log(result2[0]);
      res.send(`{"personaje":"${result2[0].nombre}"}`);
    });
  });
});

app.post('/adivinarPersonaje', (req, res)=>{
  let username = req.body.usuario;
  let chatId = req.body.chatId;
  let personaje = req.body.personaje;
  console.log(req.body);
  console.log(`SELECT adivinar_personaje('${username}',${chatId},'${personaje}') as resultado`);
  conn.query(`SELECT adivinar_personaje('${username}',${chatId},'${personaje}') as resultado`, (err, result)=>{
    if(err) throw err;
    console.log(result[0]);
    res.send(`{"result":"${result[0].resultado}"}`);
  });

});

app.post('/getPersonajeCPU', (req, res)=>{
  conn.query(`CALL asignacion_personaje`, (err, result)=>{
    if(err) throw err;
    console.log(result[0][0]);
    console.log(`{"id_personaje":"${result[0][0].personaje_asignado}"}`)
    res.send(`{"id_personaje":"${result[0][0].personaje_asignado}"}`);
  })
});


app.post('/actualizarPuntuacionVictoria', (req, res)=>{
  let username = req.body.usuario;
  console.log(req.body)
  conn.query(`SELECT * FROM usuarios WHERE id_usu = '${username}'`,(err, result)=>{
    if(err) throw err;
    let id_puntuacion = result[0].id_puntuacion;
    conn.query(`CALL actualizar_puntuacion_victoria('${id_puntuacion}')`,(err2, result2)=>{
    if(err2){ 
      res.send('{"result":"error"}')
      throw err2;
    }
    console.log(result2);
    res.send('{"result":"correcto"}');
    });
  });
  
});

app.post('/actualizarPuntuacionDerrota', (req, res)=>{
  let username = req.body.usuario;
  console.log(req.body)
  conn.query(`SELECT * FROM usuarios WHERE id_usu = '${username}'`,(err, result)=>{
    if(err) throw err;
    let id_puntuacion = result[0].id_puntuacion;
    conn.query(`CALL actualizar_puntuacion_derrota('${id_puntuacion}')`,(err2, result2)=>{
    if(err2){ 
      res.send('{"result":"error"}')
      throw err2;
    }
    console.log(result2);
    res.send('{"result":"correcto"}');
    });
  });
});

app.post('/respuestas',(req,res)=>{

  let name_pregunta = req.body.pregunta;
  let personaje_id = req.body.id_personaje
  console.log(req.body);
  
  //con este query obtenemos la descripcion y la categoria de la pregunta
  conn.query(`SELECT preguntas.categoria,preguntas.descripcion FROM preguntas WHERE preguntas.pregunta='${name_pregunta}'`,(err,result)=>{
    //inicio del switch dependiendo de la categoria se llama  a la funcion correspondiente
    switch(result[0].categoria){
      case "nombre" : conn.query(`SELECT adivinar_nombre(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result1)=>{
        res.send(`{"respuesta":"${result1[0].respuesta}"}`);
      }); break;

      case "nombre_letra" : conn.query(`SELECT adivinar_letra_nombre(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result2)=>{
        res.send(`{"respuesta":"${result2[0].respuesta}"}`);
      }); break;
    
      case "color_cabello" : conn.query(`SELECT adivinar_color_cabello(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result3)=>{
        res.send(`{"respuesta":"${result3[0].respuesta}"}`);
      }); break;
    
      case "color_vestimenta" : conn.query(`SELECT adivinar_color_vestimenta(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result4)=>{
        res.send(`{"respuesta":"${result4[0].respuesta}"}`);
      }); break;
    
      case "tipo_de_cabello" : conn.query(`SELECT adivinar_tipo_cabello(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result5)=>{
        res.send(`{"respuesta":"${result5[0].respuesta}"}`);
      }); break;
    
      case "titulo_del_videojuego" : conn.query(`SELECT adivinar_videojuego(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result6)=>{
        res.send(`{"respuesta":"${result6[0].respuesta}"}`);
      }); break;
    
      case "genero" : conn.query(`SELECT adivinar_genero(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result7)=>{
        res.send(`{"respuesta":"${result7[0].respuesta}"}`);
      }); break;
    
      case "rol" : conn.query(`SELECT adivinar_rol(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result8)=>{
        res.send(`{"respuesta":"${result8[0].respuesta}"}`);
      }); break;
    
      case "accesorio" : conn.query(`SELECT adivinar_accesorio(${personaje_id},'${result[0].descripcion}') as respuesta`,(err,result9)=>{
        res.send(`{"respuesta":"${result9[0].respuesta}"}`);
      }); break;
    
    }
    //fin del switch
  });
  
});


var server = app.listen(3000);
console.log("app running at http://localhost:3000");

var io = socketio(server);
//socket.io connection for the chat
var users = new Map();
io.on('connection', (socket)=>{
  var user = '';
  console.log("New chat connection: "+ socket.id);
  socket.on('chat', (data)=>{
    console.log(data);
    let username = data.user;
    let chatId = data.chatId;
    socket.join(`${chatId}`);
    console.log(`Username : ${username} joined Chat ID : ${chatId}`);
    user = username;
    users.set(username,chatId);
    console.log(users);
    for (const [key, value] of users) {
      console.log(key + ' = ' + value)
      if(value == chatId)
        io.to(`${chatId}`).emit('newUserToChatRoom',key);
    }
    
  });

  socket.on('victoria',(data)=>{
    console.log(data)
    let username = data.user;
    let chatId = data.chatId;
    for (const [key, value] of users) {
      console.log(key + ' = ' + value)
      if(value == chatId)
        io.to(`${chatId}`).emit('derrota',username);
    }
  });

  socket.on('leave', (data)=>{
    let chat_data = JSON.parse(data);
    let username = chat_data.user;
    let chatId = chat_data.chatId;

    console.log(`Username : ${username} leaved Room Name : ${chatId}`);
    socket.broadcast.to(`${chatId}`).emit('userLeftChatRoom',user);
    socket.leave(`${chatId}`);
  });

  socket.on('newMessage',(data)=> {
    let messageContent = data.message
    let username = data.username
    let chatId = data.chatId

    console.log(`[Room Number ${chatId}] ${username} : ${messageContent}`)
    
    // Just pass the data that has been passed from the writer socket
    const chatData = {
        user : username,
        messageContent : messageContent,
        chatId : chatId
    }
    socket.broadcast.to(`${chatId}`).emit('updateChat',JSON.stringify(chatData));
  });

});