Private Message

index.js

@@ -13,6 +13,7 @@ const fs = require('fs');
 const activeUsers = new Map();
 const authenticationRoute = require('./routes/auth');
 const { response } = require('express');
+const { resolve } = require('path');
 
 
 //DB Connection
@@ -61,11 +62,10 @@ io.on('connection', (socket) => {
 async function addUserToActiveUsers(response, socket) {
 
   return new Promise(resolve => {
-    console.log("Response: " + response);
+
     activeUsers.set(socket.id, response.name);
     
     var userArr = Array.from(activeUsers.values());
-    console.log("UserArr: " + userArr);
     
     io.emit('updateUserlist', {
       userList : userArr
@@ -78,7 +78,6 @@ async function deleteUserFromActiveUsers(response, socket) {
   return new Promise(resolve => {
     activeUsers.delete(socket.id);
     var userArr = Array.from(activeUsers.values());
-    console.log("activeUsers: ", activeUsers);
 
     io.emit('updateUserlist', {
       userList : userArr
@@ -104,32 +103,55 @@ io.on('connection', (socket) => {
 
 io.on('connection', (socket) => {
   socket.on('private message', (response) => {
+
     var private_msg = response.private_msg;
     var receiver = response.receiver;
     var sender = response.name;
     
-    activeUsers.
+    recieverSocketID = getKeyFromVal(receiver);
+
+    if(recieverSocketID == "false"){
+      io.to(socket.id).emit('test', {
+        status : 401
+       }) 
+    }
 
-    io.emit(receiver, {
+    io.to(recieverSocketID).emit('test', function(){console.log("emit priv. msg")} /* {
       private_msg: private_msg,
       receiver: receiver,
       sender: sender
+    } */)
   })
 })
+
+async function getKeyFromVal(receiver){
+  return new Promise( () => {
+    var array = Array.from(activeUsers);
+    console.log("usersArray: " + array);
+    var receiverSocketId;
+    for(var i = 0; i<array.length; i++){
+      console.log("array[i] ", array[i][0]);
+      if(array[i][1] == receiver){
+        receiverSocketId = array[i][0];
+        console.log("Receiver ID in if: ",  receiverSocketId);
+        resolve(receiverSocketId);
+      }else{
+        resolve("false");
+      }
+    }
   })
+}
 
 //Logs message from Socket to Console
 io.on('connection', (socket) => {
   socket.on('chat message', (response) => {
     var msg = response.msg;
-    console.log('message: ' + msg);
   });
 });
 
 //Send Image File
 io.on("connection", (socket) => {
   socket.on('sendImage', (file, callback) => {
-    console.log(file);
     io.emit('image', file);
   });
 });
@@ -137,7 +159,6 @@ io.on("connection", (socket) => {
 //Send Video File
 io.on("connection", (socket) => {
   socket.on('sendVideo', (file, callback) => {
-    console.log(file);
     io.emit('video', file);
   });
 });
@@ -145,7 +166,6 @@ io.on("connection", (socket) => {
 //Send Audio File
 io.on("connection", (socket) => {
   socket.on('sendAudio', (file, callback) => {
-    console.log(file);
     io.emit('audio', file);
   });
 });

routes/auth.js

@@ -14,7 +14,6 @@ router.get('/', async(req, res) => {
 
         try{
             const verify = jwt.verify(authHeader, process.env.ACCESS_TOKEN_SECRET);
-            console.log(verify);
             res.sendStatus(200);
         } catch(err){
             console.log(err);

views/index.html

@@ -62,7 +62,6 @@
 
       var username = getCookie("username");
 
-
       socket.emit('userLogin', {
         name : username
       });
@@ -84,7 +83,8 @@
       })
 
       //Receive private Messages
-      socket.on(username, function(response){
+      socket.on('test' ,function(response){
+        console.log("Received priv. msg.");
         var private_msg =  response.private_msg;
         var sender = response.sender;
         var private_msg = response.private_msg;