index.js

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var mysql = require('mysql'); 

var port = process.env.PORT || 1337; 

var con = mysql.createConnection({
    host: 'hg-db.mysql.database.azure.com',
    user: 'hg@hg-db',
    password: 'Slaptazodis1',
    database: 'hg'
});

/*
  profile: {
    name : string,
    email : string, 
    tags : [ {name : string, ratings : []} ], 
    socketId : string  - if entered, the user is logged in  
  }
}
 */
// var allProfiles = []; 
// con.connect(function(err) {        
//     con.query("SELECT * FROM Profiles", function (err, profiles) {
//         profiles.forEach(profile => {
//             var id = allProfiles.push({name: profile.Name, email: profile.Email, tags: [], socketId: ""}) - 1; 
//             con.query("SELECT * FROM Tags WHERE ProfileID = " + profile.ProfileID, function (err, tags) {
//                 allProfiles[id].tags = tags.length ? tags.map(x => Object({id: x.TagID, name: x.Name, ratings: []})) : []; 
//                 allProfiles[id].tags.forEach(tag => {   
                    
//                         con.query("SELECT Score FROM Ratings WHERE TagID = " + tag.id, function (err, ratings) {
//                             tag.ratings = ratings.length ? ratings.map(x => x.Score) : []; 
                            
//                         });
                      
//                 });
                
//             });             
//         })
//     });
// });

/*
user {
  profile: {
    name : string,
    tags : [],
    rating : int,
    ratingCount : int,
  },
  sockedId : string
}
 */

var allProfiles = [];

var connectedUsers = []; 
var requestMessages = [];

// connectedUsers.push({profile:{name:'Tadas',tags:[{name:'cooking', rating:5, ratingCount:1},{name:'developing', rating:4, ratingCount:2}]},socketId:'fgsdgsrgs'});
// connectedUsers.push({profile:{name:'Mantas',tags:[{name:'cooking', rating:3, ratingCount:2},{name:'treking', rating:10, ratingCount:2}]},socketId:'ugiuog'});
// connectedUsers.push({profile:{name:'Jons',tags:[{name:'racing',rating:16, ratingCount:4},{name:'treking', rating:16, ratingCount:6}]},socketId:'uhoiugpoigp'});
// connectedUsers.push({profile:{name:'Karlassss',tags:[]},socketId:'uiogoiugpoiugupogupo'});

// requestMessages.push({userId: 'fgsdgsrgs', requestMessages: [{socketId: '123', message: 'Please talk to me'}, {socketId: 'heyheyho', message: 'I want to talk to you'}]})
// requestMessages.push({userId: 'ugiuog', requestMessages: [{socketId: '345', message: 'Please talk to me'}, {socketId: 'heyheyho', message: 'I want to talk to you'}]})

app.get('/', function(req, res){
  res.sendFile(__dirname + '/index.html');  
});

io.on('connection', function(socket){
  var data = getConnectedUsers();
  socket.emit('user list', data);

  socket.on('chat message', function(msg){    
    var t = getConnectedUsers();
    io.emit('chat message', msg + socket.id + " " + allProfiles[0].name + " " + t ); 
  });

  socket.on('private message', function(receiverId, message){ 
    console.log(receiverId + " " + message);
    socket.broadcast.to(receiverId).emit('private message', {senderId: socket.id, message: message}); 
  });

  socket.on('rate', function(rating){ 
    // TODO update rating on both all users and db 

    console.log(rating.receiverId + " was rated " + rating.score);
    // calculate rating
    console.log(connectedUsers);
    var receiver = connectedUsers.find(receiver => receiver.socketId === rating.receiverId);

    for (var key in rating.score) {
      console.log(key);
      var tag = receiver.profile.tags.find(t => t.name === key);
      if (tag !== undefined) {
        tag.rating += rating.score[key];
        tag.ratingCount++;
      }

      console.log(tag);
    }

    // if(receiver.profile.rating && receiver.profile.ratingCount) {
    //   receiver.profile.rating += rating.score;
    //   receiver.profile.ratingCount++;
    // }
    // else{
    //   receiver.profile.rating = rating.score;
    //   receiver.profile.ratingCount = 1;  
    // }
    var data = getConnectedUsers();
    io.emit('user list', data);
  });

  socket.on('disconnect', function(){ 
    logout(socket);
  });

  socket.on('logout', function(){ 
    logout(socket);
  });

  socket.on('login', function(profile){
    // TODO. 1. check if the user is in allUsers. 
    // if exists, just add socketid attribute to the user 
    // if not, create a new user, add it to both allUsers and db 
    
    connectedUsers.push({profile : profile, socketId : socket.id})
    console.log('User logged in. Profile:')
    console.log(profile);
    var data = getConnectedUsers();
    io.emit('user list', data);
  });

  
  socket.on('send request message', function(mentorSocketId, requesterSocketId, reqMessage, topic) {

    //TODO: add reqMessage to DB
    //message should not be a duplicate
    var selectedMentor;
    selectedMentor = requestMessages.find(x => x.userId === mentorSocketId);
    if (!selectedMentor) {
        selectedMentor = {userId: mentorSocketId, requestMessages: []};
        requestMessages.push(selectedMentor);
    }
    selectedMentor.requestMessages.unshift({
        socketId: requesterSocketId, 
        message: reqMessage,
        userName: getUserNameBySocketId(requesterSocketId),
        topic: topic
    });
    socket.broadcast.to(mentorSocketId).emit('request messages', selectedMentor.requestMessages);
  })

  socket.on('reject message', function(mentorSocketId, requesterSocketId) {
    console.log(requestMessages);
    var mentor = requestMessages.find(x => x.userId === mentorSocketId);
    var rejectedMessageIndex = mentor.requestMessages.findIndex(x => x.socketId === requesterSocketId);
    mentor.requestMessages.splice(rejectedMessageIndex, 1);
    socket.emit('request messages', mentor.requestMessages);
  })

  socket.on('notify accept', function(requesterSocketId, mentorSocketId){
    socket.broadcast.to(requesterSocketId).emit('notify accept', mentorSocketId);
  })
});

function logout(socket) {
  // TODO change user loggedin field to false in allUsers list 

  console.log(connectedUsers);
  console.log("client id=" + socket.id + " disconnected"); 
  connectedUsers = connectedUsers.filter(x => x.socketId !== socket.id); 
  var data = getConnectedUsers();
  io.emit('user list', data);
}

http.listen(port, function(){
  console.log('listening on *:' + port);
});

function getConnectedUsers(){  
    // TODO do a mapping from allProfiles where loggedin attribute in true 

    // return allProfiles.filter(x => x.socketId === "")
    //                   .map(profile => Object({
    //                         name: profile.name, 
    //                         email: profile.email, 
    //                         tags : generateTags(profile.tags), 
    //                         socketId : profile.socketId}));
    return connectedUsers;
}

function generateTags(tags) {   
    tags = tags.map(x => Object({name: x.name, rating: x.ratings.length ? precisionRound(x.ratings.reduce((a, b) => a + b, 0) / x.ratings.length, 2) : 0}));
    console.log(tags);;
    return tags; 
}

function getRating(profile){
    if(profile.rating && profile.ratingCount)
      return precisionRound(profile.rating / profile.ratingCount, 2);
    else
      return 0;
}

function precisionRound(number, precision) {
  var factor = Math.pow(10, precision);
  return Math.round(number * factor) / factor;
}

function getUserNameBySocketId(socketId) {
    var user = connectedUsers.find(x => x.socketId === socketId);
    return user.profile.name;
}