client-io.js

var conn_id = null;
var debug = true;
var nick = "";
var room = "";
var rooms = {};
var numUnread = 0;
var nick =""
var login_info = window.location.hash;
login_info = login_info.split('#')[1];
var user = login_info.split('@')[0];
var domain = login_info.split('@')[1];
nick = user;

var batches = {};

if(room == "") room = "main";

var socket = new io.Socket(null, {port: 81, rememberTransport: false});

socket.connect();

socket.on('message', function(message){
  message = JSON.parse(message);
  var data = message.msg.split(" ");

  var msg_room = "";
  if(message.room) msg_room = message.room;
  
  switch(data[0]) {
    case "/hello":
      conn_id = data[1];
      
      if(nick == ""){
		nick = "guest";
	  } 
	
		if(nick.indexOf("~") >= 0) {
			var fname = nick.split("~")[0];
			socket.send("/nick " + fname + "~" + conn_id); 		
		} else {
			socket.send("/nick " + HTMLEncode(nick) + "~" + conn_id); 
		}

      break;
    
    case "/msg":
      var text = data.slice(1).join(" ");
      if(message.room == "/pm") { // Private Message
        var id = message.to == undefined ? message.from : message.to;
        if(text != "" || message.from == conn_id) {
          if(rooms[id] == undefined) {
            rooms[id] = {};
            rooms[id]["last_user"] = "";
            rooms[id]["nb"] = 0;
            rooms[id]["type"] = "pm";
            rooms[id]["to"] = message.name;
            updateTitle("[PM] ");
			var fname = message.name.split("~")[0];
            try { $("#audio_new_pm")[0].play(); } catch(e) {}  
          	// play('new_pm');
            $('#rooms ul:first-child').append("<li class='pm' id='r_" + id + "'>@" + fname + "</li>");
            addNewRoom(id);
            room = id;
          }
          if(text != "") {
            try { $("#audio_msg")[0].play(); } catch(e) {}
          	// play('sound');

            if(rooms[id]["last_user"] != message.toname) {
              var date = new Date(),
                hour  = date.getHours(),
                min   = date.getMinutes();
              if(min < 10) min = "0" + min;
              rooms[id]["last_user"] = message.toname;
			  var fname = message.toname.split("~")[0];
              $('#chat_' + id).append("<div class='from'><div class='date'>"+hour+":"+min+"</div>" + fname + "</div>");
            }
           
			var msgtext = HTMLEncode(text)
			var msgtextlinks = msgtext.replace(/(ftp|http|https):\/\/(\w+:{0,1}\w*@)?(\S+)(:[0-9]+)?(\/|\/([\w#!:.?+=&%@!\-\/]))?/, "<a href='$1://$3' target='blank'>$1://$3</a>");

            $('#chat_' + id).append("<div>" + msgtextlinks + "</div>");
            // $('#chat_' + id).append("<div>" + HTMLEncode(text) + "</div>");
            scrollChat();
			var fname = message.name.split("~")[0];

            if(room != id) {
              addUnread();
              rooms[id]["nb"]++;
              $("#r_" + id).html("@" + fname + " (" + rooms[id]["nb"] + ")");
            } else {
              $("#r_" + id).html("@" + fname);
            }
          }
        }
      } 
      else { // Normal message
        try { $("#audio_msg")[0].play(); } catch(e) {}
      	// play('sound');

        if(rooms[message.room]["last_user"] != message.from) {
          var date = new Date(),
            hour  = date.getHours(),
            min   = date.getMinutes();
          if(min < 10) min = "0" + min;
                
          rooms[message.room]["last_user"] = message.from;
		  var fname = message.from.split("~")[0];
		  var lname = message.from.split("~")[1];
		
		if(nick == message.from) 
			$('#chat_' + message.room).append("<div class='from'><div class='date'>"+hour+":"+min+"</div>" + fname + "</div>");
		else
          	$('#chat_' + message.room).append("<div class='from'><div class='date'>"+hour+":"+min+"</div><a href='#" + fname + "' onclick='socket.send(\"/pm "+ lname+"\")'>" + fname + "</a></div>");


        }

		var msgtext = HTMLEncode(data.slice(1).join(" "))
		var msgtextlinks = msgtext.replace(/(ftp|http|https):\/\/(\w+:{0,1}\w*@)?(\S+)(:[0-9]+)?(\/|\/([\w#!:.?+=&%@!\-\/]))?/, "<a href='$1://$3' target='blank' rel=\"nofollow\">$1://$3</a>");


        $('#chat_' + message.room).append("<div>" + msgtextlinks + "</div>");
        // $('#chat_' + message.room).append("<div>" + HTMLEncode(data.slice(1).join(" ")) + "</div>");
        scrollChat();
        if(room != message.room) {
          addUnread();
          rooms[message.room]["nb"]++;
          $("#r_" + message.room).html(message.room + " (" + rooms[message.room]["nb"] + ")");
        } else {
          $("#r_" + message.room).html(message.room);
        }
      }
      break;
    
    case "/your_nick":
      nick = data.slice(1).join(" ");
      if(rooms[room] == undefined) {
        socket.send("/join " + room + " " + domain);
      } else {
        refreshList(room);
      }
      break;
    
    case "/join":
      rooms[room] = {};
      rooms[room]["last_user"] = "";
      rooms[room]["nb"] = 0;
      if(nick == message.from) {
        $('#room').html("Connected on room #" + room);
        $('#rooms ul:first-child').append("<li id='r_" + room + "'>" + room + "</li>");
        addNewRoom(room);
		var fname = nick.split("~")[0];
        notice(room, "You are connected as " + fname);
      } else {
		var fname = message.from.split("~")[0];
        batch('join_' + room, fname, function(names) {
          notice(msg_room, names + " joined this room");
        });
      }
      refreshList(room);
      
      break;
    
    case "/list":
      $('#n_' + room).html("");
      _.each(data.slice(1).join(" ").split(","), function(data) {
        n = data.split(":");
        var nh = "#n_" + room + "_" + n[0];
        var value = n[1];
		var fname = value.split("~")[0];
        
        if($(nh).html() == null) {
          if(n[1] == "undefined" || n[1] == undefined) value = n[0];
          if(n[0] == conn_id) $("#n_" + message.room).append("<div id='n_" + room + "_" +n[0]+"'>" + fname +"</div>");
          else $("#n_" + message.room).append("<div id='n_" + room + "_" +n[0]+"'><a href='#" + fname + "' onclick='socket.send(\"/pm "+ n[0]+"\")'>" + fname +"</a></div>");
        } else {
          $(nh + " a").html(fname);
          $("#r_" + n[0]).html("@" + fname);
        }
        
      });
      break;
      
    case "/quit":
      $("#n_" + msg_room + "_" + data[1]).detach();
	  var fname = message.from.split("~")[0];
      batch('part_' + msg_room, fname, function(names) {
        notice(msg_room, names + " left the room");
      });
      break;
    
    case "/leave":
      $("#n_" + msg_room + "_" + data[1]).detach();
	  var fname = message.from.split("~")[0];
      batch('part_' + msg_room, fname, function(names) {
        notice(msg_room, names + " left the room");
      });
      break;
  
    case "/writing":
      $("#n_" + msg_room + "_" + data[1]).addClass("writing");
      break;
    
    case "/notice":
      notice(msg_room, data.slice(1).join(" "));
      break;
    
    default:
      break;
  }
});

socket.on('connect', function(){
  socket.send("/whoami");
});

socket.on('disconnect', function(){
  rooms[room] = undefined;
  notice(null, "You have been disconnected");
});


function send(msg) {
  var r = room;
  if(msg[0] == "/") {
    var can_send = true;
    var data = msg.split(" ");
    switch(data[0]) {
      case "/join":
        room = data[1].replace(/\W/g, "");
        msg = "/join " + room + " "  + domain;
        console.log("Joining " + room);
        can_send = nick == "" ? false : true;
        break;
      case "/nick":
        $.cookie('username', HTMLEncode(data[1]), { expires: 700, path: '/'});
        break;
      case "/leave":
        msg = msg + " " + room;
        rooms[room] = undefined;
        $('#r_' + room).detach();
        $('#n_' + room).detach();
        $("#chat_" + room).detach();
        for(var r in rooms) {
          if(rooms[r] != undefined) {
            room = r;
            displayRoom("r_" + room);
          }
          break;
        }
        break;

      break;
    }
    if(can_send) socket.send(msg);
  }
  else {
    if(nick != "") {
      var txt = '/msg ' + room + " " + msg;
      if(rooms[room].type == "pm") {
        txt = "/pm " + room + " " + msg;
      }
      socket.send(txt);     
    }
  }
  $('#t_' + r).val("");
}

function batch(type, name, callback) {
  batches[type] || (batches[type] = {names: []});
  var names = batches[type].names;
  names.push(name);
  
  if (!batches[type].timer) {
    batches[type].timer = window.setTimeout(function() {
      var nameStr;
      if (names.length > 1) {
         nameStr = names.slice(0, -1).join(', ') + ' and ' + names.slice(-1);
      }
      else {
        nameStr = names[0];
      }

      delete batches[type].timer;
      batches[type].names = [];
      callback(nameStr);
    }, 1000);
  }
}

function notice(room, msg) {
  if (room) {
    $('#chat_' + room).append("<div class='notice'>:: " + msg + "</div>");
    scrollChat();
  }
  else {
    $('.chat').each(function() {
      var chat = $(this);
      chat.append("<div class='notice'>:: " + msg + "</div>");
      chat.scrollTop(chat.scrollHeight + chat.height());
    });
  }
}

function scrollChat() {
  var log = $("#chat_" + room);
	log.scrollTop(log[0].scrollHeight + log.height());
}

function querySt(ji) {
  hu = window.location.search.substring(1);
  gy = hu.split("&");
  for (i=0;i<gy.length;i++) {
    ft = gy[i].split("=");
    if (ft[0] == ji) {
      return ft[1];
    }
  }
}

function HTMLEncode(wText){
  if(typeof(wText)!="string"){
    wText=wText.toString();
  };
  wText=wText.replace(/</g, "&lt;") ;
  wText=wText.replace(/>/g, "&gt;") ;

// emoticons
  wText=wText.replace(/:\)/g, '<img src="/public/happy.gif">') ;
  wText=wText.replace(/:-\)/g, '<img src="/public/happy.gif">') ;
  wText=wText.replace(/:\(/g, '<img src="/public/sad.gif">') ;
  wText=wText.replace(/:-\(/g, '<img src="/public/sad.gif">') ;
  wText=wText.replace(/:'\(/g, '<img src="/public/sad.gif">') ;
  wText=wText.replace(/:D/g, '<img src="/public/awesome.gif">') ;
  wText=wText.replace(/:P/g, '<img src="/public/tongue.gif">') ;
  wText=wText.replace(/:p/g, '<img src="/public/tongue.gif">') ;
  wText=wText.replace(/;\)/g, '<img src="/public/wink.gif">') ;
  wText=wText.replace(/;-\)/g, '<img src="/public/wink.gif">') ;
  wText=wText.replace(/;\//g, '<img src="/public/wink.gif">') ;
	

  return wText;
};

function blurredHandler(r) {
  if ($('#' + r).val().replace(/ /g, '') == '') {
  	$('#' + r).val("Type a message here");
  }
}
function focussedHandler(r) {
  if ($('#' + r).val() == "Type a message here") {
  	$('#' + r).val("");
  }
}

function displayRoom(r) {
  r = r.split("_")[1];  
  room = r;
  $(".room").css("display", "none");
  $("#rooms ul li").removeClass("active");
  $('#r_' + r).addClass("active");
  if(rooms[r]["type"] == "pm") {
	var fname = rooms[r]["to"].split("~")[0];
   	$('#r_' + r).html("@" + fname);
  } else {
	if(room.length != 16 && !IsNumeric(room)){
     console.log(r);
   		$('#r_' + r).html(r.split('-')[0]);
	}
  }  
  $('#n_' + r).html("");
  
  socket.send("/list " + r);
  $('#room_' + r).css("display", "block");
  cleanRoom(r);
  rooms[r]["nb"] = 0;
  scrollChat();
}

function refreshList(r) {
  socket.send("/list " + r);
}

function addNewRoom(r) {
  $('body').append("<div class='room' id='room_" + r + "'></div>");
  $('#room_' + r).append("<div class='chat' id='chat_" + r + "'></div>");
  $('#room_' + r).append('<form id="f_'+ r +'" action="send" method="post" onsubmit="send($(\'#t_' + r + '\').val()); return false;"></form>');
  $('#room_' + r).append("<div class='nicks' id='n_"+ r +"'></div>");
if ($('#t_' + r).length == 0) {
  $('#f_' + r).append('<input type="text" id="t_' + r + '" name="t" value="" width="50"  autocomplete="off"/><script>t_' + r + '.focus();</script>');
}
  $('.room').css("display","none");
  $('#r_' + r).click(function() { displayRoom(this.id) });        
  $('#t_' + r).focus(function() { focussedHandler(this.id) });
  $('#t_' + r).blur(function() { blurredHandler(this.id) });
  $("#rooms ul li").removeClass("active");
  $('#r_' + r).addClass("active");
  $('#room_' + r).css("display", "block");
}

socket.on('reconnect', function(){ 
	rooms[room] = undefined;
    $('#r_' + room).detach();
    $('#n_' + room).detach();
    $("#chat_" + room).detach();
    for(var r in rooms) {
      if(rooms[r] != undefined) {
        room = r;
        displayRoom("r_" + room);
      }
      break;
    }
    
	socket.send("/whoami");
	// socket.send("/nick " + nick); 
});

// socket.on('reconnecting', function( nextRetry ){ message({ message: ['System', 'Attempting to re-connect to the server, next attempt in ' + nextRetry + 'ms']})});
// socket.on('reconnect_failed', function(){ message({ message: ['System', 'Reconnected to server FAILED.']})});

function IsNumeric(input)
{
   return (input - 0) == input && input.length > 0;
}

function cleanRoom(roomId) {
  numUnread -= rooms[roomId]["nb"];
  updateTitle("");
}
function addUnread() {
  numUnread++;
  updateTitle("");
}

function updateTitle(leading) {
  var read = "";
  if (numUnread>0) {
  	read = "(" + numUnread + ") ";
  }
  document.title = leading + read + "CHATS.IO";
}