app.js

var http = require('http');
var fs = require('fs');
var url = require('url');
var path = require('path');
// var io = require('socket.io');
var express = require('express');
// var events=require('events');
// var mongodb = require('mongodb');
// var eventEmitter=new events.EventEmitter();
var app = express();
var redis = require('redis');
// var client = redis.createClient(); //creates a new client
var nconf = require('nconf');


//*************************JUST SOME FUNCTIONS FOR FUN***********//
function isEven(n) {
   return n % 2 == 0;
}

function isOdd(n) {
   return Math.abs(n % 2) == 1;
}
//***************************************************************//

//https://console.cloud.google.com/networking/networks/details/default?project=moovo-chat
/************ db functions******************/
// client.del('userData');
// client.on('connect', function() {
//     console.log('connected');
// });

app.use('/', express.static(__dirname + '/'));
// The common path is for shared code: used by both client and server.
// app.use('/common', express.static(__dirname + '/common'));
// The root path should serve the client HTML.

app.get('/chat', function (req, res) {
    res.sendfile(__dirname + '/index1.html');
});

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

server = require('http').createServer(app);
var PORT=8081;
var IPADDRESS='0.0.0.0';
server.listen(PORT, IPADDRESS);
io = require('socket.io').listen(server);

// var server = http.createServer(function (req, res) {
	
// 	var filePath = '.' + req.url;
// 	if (filePath == './index1.htm')
// 		filePath = './index1.htm';
		
// 	var extname = path.extname(filePath);
// 	var contentType = 'text/html';
// 	switch (extname) {
// 		case '.js':
// 			contentType = 'text/javascript';
// 			break;
// 		case '.css':
// 			contentType = 'text/css';
// 			break;
// 	}
	
// 	fs.exists(filePath, function(exists) {
	
// 		if (exists) {
// 			fs.readFile(filePath, function(error, content) {
// 				if (error) {
// 					res.writeHead(500);
// 					res.end();
// 				}
// 				else {
// 					res.writeHead(200, { 'Content-Type': contentType });
// 					res.end(content, 'utf-8');
// 				}
// 			});
// 		}
// 		else {
// 			res.writeHead(404);
// 			res.end();
// 		}
// 	});

// }).listen(9999,'0.0.0.0', function() {

//     console.log('Listening at: http://0.0.0.0:9999');

// });


var usernames = {};
var userid={}
var userroom={}
var rooms = ['room1','room2','room3'];
var sockets={};
var status={}
io.sockets.on('connection', function (socket) {

	socket.on('adduser', function(userNum){
		// store the username in the socket session for this client
		// socket.emit('client_id',username,"r4nd0m");
		socket.userNum = userNum;
		// store the room name in the socket session for this client
		socket.room = 'room1';
		// add the client's username to the global list
		usernames[userNum] = userNum;
		// send client to room 1
		socket.join('room1');
		// echo to client they've connected
		// socket.emit('updatechat', 'SERVER', 'you have connected to room1');
		// echo to room 1 that a person has connected to their room
		// socket.broadcast.to('room1').emit('updatechat', 'SE = new ArrayList<>()RVER', username + ' has connected to this room');
		// socket.emit('updaterooms', rooms, 'room1');
		userid[userNum]=socket.id;
		console.log(userNum + " ---- "+userid[userNum]);
		io.sockets.emit('connected',{"msg":"SERVER: "+userNum+" has coonected"})
		// console.log(usernames)
		// client.hmset('userData', userNum, socket.id);
		// client.sadd(['users',userNum]);
		socket.talk_to="admin";
		sockets[userNum]=socket;
		var talked_with=userNum+'talked_with'
		socket.talked_with=talked_with
		socket.dbName='set_later'
		socket.contactsDB=userNum+'-contacts'
		status[userNum]="online"

		// client.smembers(socket.contactsDB, function(err, reply) {
		// 	reply.forEach(function (rep, i) {
  //   			socket.emit('addcontact',{"contact":rep});
  //   			console.log(rep)
  //   		});
		// });
		// client.sdd([socket.talked_with,userNum])

		// client.rpush([userNum], function(err, reply) {
		//     console.log(reply); //prints 3
		// });
	});

	socket.on('talk_to',function(friend){
		// client.sadd([socket.contactsDB, friend])
		console.log(socket.userNum+" talking to "+ friend);
		socket.talk_to=friend;
		// client.sdd([socket.talked_with,friend])
		//send previous texts to render
		
		if (socket.userNum<socket.talk_to){
			socket.dbName=socket.userNum+socket.talk_to
		}else {
			socket.dbName=socket.talk_to+socket.userNum
		}
		// client.rpush([x])

		var sent_by=''
		var mess=''
		// client.lrange(socket.dbName, 0, -1, function(err, reply) {
		//    	reply.forEach(function (rep, i) {
		//    		if (isEven(i)==true){
		//    			sent_by=rep	
		//    		}
		//    		else {
		//    			mess=rep
		//    			socket.emit('render',{"sent_by":sent_by,"mess":mess})
		//    			// console.log("sent_by: "+sent_by+" mess:"+mess)
		//    		}
		//    	});
		// });


	});
	socket.on('new_msg',function(message){
		// console.log(socket.userNum+'::::'+message);
		// socket.emit('updatechat',{"who":socket.username,"msg":message});
		// io.sockets.in(socket.room).emit('updatechat',{"who":socket.username,"msg":message})
		// socket.broadcast.to(socket.room).emit('updatechat', {"who":socket.username,"msg":message});
		socket.emit('updatechat', {"who":socket.userNum,"msg":message});
		// socket.broadcast.to(socket.room).emit('updatechat',{"who":socket.userNum,"msg":message});
		// console.log(message);
		if (status[socket.talk_to]=="online"){
			sockets[socket.talk_to].emit('updatechat', {"who":socket.userNum,"msg":message});
		}else {
			//notify receiver is offline
			socket.emit('offline',{"who":socket.talk_to})
			//store to send later
		}
		// io.sockets.in(socket.room).emit('updatechat',{"who":socket.username,"msg":message})

		// client.lpush('messages', JSON.stringify(message)); // push into redis
		// client.lrange('messages', 0, -1, function(err, reply) {
		//   //reply contains all messages
		//   console.log(reply)
		// });
		// client.rpush([socket.userNum,socket.userNum,message])
		// client.rpush([socket.talk_to,socket.userNum,message])
		// client.rpush([socket.dbName,socket.userNum,message])

	});

//send to only sender and recipient. 
	socket.on('new_msg1',function(message){
		console.log(socket.userNum+'::::'+message);
		// socket.emit('updatechat',{"who":socket.username,"msg":message});
		// io.sockets.in(socket.room).emit('updatechat',{"who":socket.username,"msg":message})
		// socket.broadcast.to(socket.room).emit('updatechat', {"who":socket.username,"msg":message});
		socket.emit('updatechat', {"who":socket.userNum,"msg":message});
		socket.broadcast.to(socket.room).emit('updatechat',{"who":socket.userNum,"msg":message});
		// io.sockets.in(socket.room).emit('updatechat',{"who":socket.username,"msg":message})
	});

	socket.on('typing',function(){
		sockets[socket.talk_to].emit('typing',{"who":socket.userNum});
	});

	// socket.on('sendchat', function (data) {
	// 	// we tell the client to execute 'updatechat' with 2 parameters
	// 	// io.sockets.in(socket.room).emit('updatechat', socket.username, data);
	// 	// if (data2=="all"){
	// 		console.log(socket.username+' wants to send')
	// 		// socket.broadcast.to(socket.room).emit('updatechat', socket.username, data);
	// 	// }
	// 	// else {
	// 	// 	var send_to=userid[data2].substring(2);
	// 	// 	socket.broadcast.to(socket.room).emit('updatechatRoom', socket.username, data, send_to);
	// 	// }
	// 	// io.sockets.in(socket.room).emit('updatechat', socket.username, data);

	// });

	// socket.on('switchRoom', function(newroom){
	// 	// leave the current room (stored in session)
	// 	socket.leave(socket.room);
	// 	// join new room, received as function parameter
	// 	socket.join(newroom);
	// 	socket.emit('updatechat', 'SERVER', 'you have connected to '+ newroom);
	// 	// sent message to OLD room
	// 	socket.broadcast.to(socket.room).emit('updatechat', 'SERVER', socket.username+' has left this room');
	// 	// update socket session room title
	// 	socket.room = newroom;
	// 	socket.broadcast.to(newroom).emit('updatechat', 'SERVER', socket.username+' has joined this room');
	// 	socket.emit('updaterooms', rooms, newroom);
	// });

	socket.on('disconnect', function(){
		// // remove the username from global usernames listd
		// status[userNum]="offline"
		// console.log(socket.userNum + ' has disconnected');
		// delete usernames[socket.userNum];
		// // update list of users in chat, client-side
		// // io.sockets.emit('updateusers', usernames);
		// // sockets[socket.talk_to].emit('updatechat',{"who":"SERVER","msg":message})
		// // echo globally that this client has left
		// // socket.broadcast.emit('updatechat', 'SERVER', socket.username + ' has disconnected');
		// socket.leave(socket.room);
		// client.quit()
		console.log("disconnected user")
	});

 //    socket.on('message', function (msg) {

 //        console.log('Message Received: ', msg);

 //        socket.broadcast.emit('message', msg);
	// // io.listen(server).emit('updatechat', socket.username, msg);

 //    });

	// socket.on('message',function(data)){

	// 	});




   //  socket.on('private message', function (from, msg) {
   //  	console.log('I received a private message by ', from, ' saying ', msg);
  	// });

  	// socket.on('disconnect', function () {
   //  	io.emit('user disconnected');
  	// });

});