Initial commit

Author: n00j

.gitignore

@@ -0,0 +1 @@
+node_modules

index.html

@@ -0,0 +1,73 @@
+<script src="/socket.io/socket.io.js"></script>
+<script src="/js/jquery.min.js"></script>
+<script>
+	var socket = io.connect('http://localhost:8080');
+
+	// on connection to server, ask for user's name with an anonymous callback
+	socket.on('connect', function(){
+		// call the server-side function 'adduser' and send one parameter (value of prompt)
+		var name = prompt("What's your name?");
+		var chatroom = prompt("What chat room?");
+		if (name !== null && chatroom !== null)
+		{
+			socket.emit('adduser', {username: name, chatroom: chatroom});
+		}
+	});
+
+	socket.on('errorConnect', function(error) {
+		alert(error);
+		var name = prompt("What's your name?");
+		var chatroom = prompt("What chat room?");
+		socket.emit('adduser', {username: name, chatroom: chatroom});
+	});
+
+	socket.on('successfullyjoinchat', function(chatroom) {
+		$('#roomname').append(chatroom);
+	});
+
+	// listener, whenever the server emits 'updatechat', this updates the chat body
+	socket.on('updatechat', function (username, data) {
+		$('#conversation').append('<b>'+username + ':</b> ' + data + '<br>');
+	});
+
+	// listener, whenever the server emits 'updateusers', this updates the username list
+	socket.on('updateusers', function(data) {
+		$('#users').empty();
+		$.each(data, function(key, value) {
+			$('#users').append('<div>' + data[key] + '</div>');
+		});
+	});
+
+	// on load of page
+	$(function(){
+		// when the client clicks SEND
+		$('#datasend').click( function() {
+			var message = $('#data').val();
+			$('#data').val('');
+			// tell server to execute 'sendchat' and send along one parameter
+			socket.emit('sendchat', message);
+		});
+
+		// when the client hits ENTER on their keyboard
+		$('#data').keypress(function(e) {
+			if(e.which == 13) {
+				$(this).blur();
+				$('#datasend').focus().click();
+			}
+		});
+	});
+
+</script>
+<div>
+	<b> Chatroom: </b>
+	<span id="roomname"></span>
+</div>
+<div style="float:left;width:100px;border-right:1px solid black;height:300px;padding:10px;overflow:scroll-y;">
+	<b>USERS</b>
+	<div id="users"></div>
+</div>
+<div style="float:left;width:300px;height:250px;overflow:scroll-y;padding:10px;">
+	<div id="conversation"></div>
+	<input id="data" style="width:200px;" />
+	<input type="button" id="datasend" value="send" />
+</div>

js/jquery.min.js

@@ -0,0 +1,91 @@
+var express = require('express'), 
+	http = require('http');
+
+var app = express();
+var server = http.createServer(app);
+var io = require('socket.io').listen(server, {log: false});
+
+app.use("/js", express.static(__dirname + '/js'));
+
+server.listen(8080);
+
+// routing
+app.get('/', function (req, res) {
+	res.sendfile(__dirname + '/index.html');
+});
+
+// usernames which are currently connected to the chat
+var usernames = {};
+var chatrooms = {};
+io.sockets.on('connection', function(socket) {
+
+	socket.on('sendchat', function(data) {
+		// we tell the client to execute 'updatechat with 2 parameters'
+		io.sockets.in(socket.chatroom).emit('updatechat', socket.username, data);
+	});
+
+	// when the client emits 'adduser', this listens and executes
+	socket.on('adduser', function(info) {
+		username = info.username;
+		chatroom = info.chatroom;
+
+		if (!(usernames[username] == undefined || usernames[username] == null))
+		{
+			socket.emit('errorConnect', "The username '" + username + "' is already in use.");
+			return;
+		}
+		// we store the username in the socket session for this client
+		socket.username = username;
+		// we store the room
+		socket.chatroom = chatroom;
+		if (chatrooms[chatroom] == undefined)
+		{
+			chatrooms[chatroom] = {
+				name: chatroom,
+				usernames: {},
+				usercount: 0
+			}
+		}
+		// add the client's username to the global list
+		usernames[username] = username;
+		chatrooms[chatroom].usernames[username] = username;
+		chatrooms[chatroom].usercount++;
+		socket.join(chatroom);
+
+		// echo to the client the chatroom name
+		socket.emit('successfullyjoinchat', chatroom);
+		// echo to the client they've connected
+		socket.emit('updatechat', 'SERVER', 'you have connected');
+		// echo globablly (all clients) that a person has connected
+		socket.broadcast.to(chatroom).emit('updatechat', 'SERVER', username + ' has connected');
+		// update the list of users in chat, client-side
+		io.sockets.in(chatroom).emit('updateusers', chatrooms[chatroom].usernames);
+	});
+
+	// when the user disconnects.. perform this
+	socket.on('disconnect', function() {
+		// remove the username from global usernames list
+		try
+		{
+			delete usernames[socket.username];
+			delete chatrooms[socket.chatroom].usernames[username];
+			chatrooms[socket.chatroom].usercount--;
+			// echo globally that this client has left
+			if (chatrooms[socket.chatroom].usercount > 0)
+			{
+				io.sockets.in(socket.chatroom).emit('updatechat', 'SERVER', socket.username + ' has disconnected');
+				// update list of users in chat, client-side
+				io.sockets.in(socket.chatroom).emit('updateusers', usernames);
+			}
+
+			socket.leave(socket.chatroom);
+		}
+		catch(e)
+		{
+			console.log(socket.username, socket.chatroom, chatrooms);
+		}
+		
+
+	});
+
+});