Names reimplemented, just a little better

server/handlers/chat.js

@@ -46,34 +46,49 @@ function all_chat(msg, guid, offline, socket) {
     }
 }
 
-function namechange(data, guid, coll) {
+function namechange(data, guid, socket) {
-    if(typeof(data) !== "string" || coll == undefined) return;
+    if(!data.hasOwnProperty("name") || data.name.length > 10 || !data.hasOwnProperty("channel")) return;
-    data = encodeURIComponent(data).replace(/\W/g, '').replace(/[^\x00-\x7F]/g, "");
+    var pw = "";
-    db.collection("user_names").find({"guid": guid}, function(err, docs) {
+    var new_password;
-        if(docs.length == 1) {
+    if(data.hasOwnProperty("password")) {
-            if(docs[0].name == data) return;
+        pw = data.password;
-            var change_name = function(new_name, guid, old_name) {
+        new_password = false;
-                if(new_name.length > 9) {
+    } else if(data.hasOwnProperty("new_password") && data.hasOwnProperty("old_password")) {
+        pw = data.old_password;
+        new_password = Functions.decrypt_string(socket.zoff_id, data.new_password);
+    }
+    var password = Functions.decrypt_string(socket.zoff_id, pw);
+    var name = data.name;
+    db.collection("registered_users").find({"_id": name}, function(err, docs) {
+        var accepted_password = false;
+        if(docs.length == 0) {
+            if(new_password) {
                 return;
-                } else {
+            }
-                    db.collection("user_names").update({"_id": "all_names"}, {$addToSet: {names: new_name}}, function(err, updated) {
+            accepted_password = true;
-                        if(updated.nModified == 1) {
+            db.collection("registered_users").update({"_id": name}, {$set: {password: Functions.hash_pass(password)}}, {upsert: true}, function() {});
-                            db.collection("user_names").update({"guid": guid}, {$set: {name: new_name}}, function(err, updated) {
+        } else if(docs[0].password == Functions.hash_pass(password)) {
-                                db.collection("user_names").update({"_id": "all_names"}, {$pull: {names: old_name}}, function(err, updated) {});
+            accepted_password = true;
-                                name = new_name;
+            if(new_password) {
-                                io.to(coll).emit('chat', {from: old_name, msg: " changed name to " + name});
+                db.collection("registered_users").update({"_id": name, password: Functions.hash_pass(password)}, {$set: {password: Functions.hash_pass(new_password)}}, function() {});
-                                io.sockets.emit('chat.all', {from: old_name , msg: " changed name to " + name, channel: coll});
+            }
-                            });
+        }
-                        } else {
+        if(accepted_password) {
-                            change_name(new_name + "_", guid, old_name);
+            db.collection("user_names").find({"guid": guid}, function(err, names) {
+                var old_name = names[0].name;
+                db.collection("user_names").update({"_id": "all_names"}, {$pull: {names: old_name}}, function() {});
+                db.collection("user_names").update({"guid": guid}, {$set: {name: name}}, function(err, docs) {
+                    db.collection("user_names").update({"_id": "all_names"}, {$addToSet: {names: name}}, function(err, docs) {
+                        socket.emit('name', {type: "name", accepted: true});
+                        if(old_name != name) {
+                            io.to(data.channel).emit('chat', {from: old_name, msg: " changed name to " + name});
+                            io.sockets.emit('chat.all', {from: old_name , msg: " changed name to " + name, channel: data.channel});
                         }
                     });
-                }
+                });
-            }
+            });
-
+        } else {
-            var old_name = docs[0].name;
+            socket.emit('name', {type: "name", accepted: false});
-            change_name(data, guid, old_name);
-
         }
     });
 }

server/handlers/io.js

@@ -79,6 +79,18 @@ module.exports = function() {
             Suggestions.description(msg, coll, guid, offline, socket);
         });
 
+        socket.on("namechange", function(msg) {
+            Chat.namechange(msg, guid, socket);
+        });
+
+        socket.on("removename", function(msg) {
+            if(typeof(msg) != "object" || !msg.hasOwnProperty("channel")) {
+                socket.emit("update_required");
+                return;
+            }
+            Chat.removename(guid, msg.channel);
+        });
+
         socket.on("offline", function(msg){
             if(!msg.hasOwnProperty('status') && !msg.hasOwnProperty('channel')) {
                 socket.emit("update_required");

server/public/assets/js/chat.js

@@ -2,25 +2,44 @@ var Chat = {
 
     channel_received: 0,
     all_received: 0,
-    chat_help: [/*"/name <new name> to change name", "/removename to remove name"*/ "There are no commands.. As of now!"],
+    chat_help: ["/name <new name> <password> to register and save a password for a nickname", "/name <new name> <new_password> <old_password> to change the password on a nickname", "/removename to logout"],//, "There are no commands.. As of now!"],
 
-    namechange: function(newName) {
+    namechange: function(data) {
-        socket.emit("namechange", {name: newName, channel: chan.toLowerCase()});
+        var input = data.split(" ");
-        Crypt.set_name(newName);
+        if(input.length == 2) {
+            var name = input[0];
+            var password = input[1];
+            temp_name = name;
+            temp_pass = password;
+            password = Crypt.crypt_pass(password);
+            socket.emit("namechange", {name: name, channel: chan.toLowerCase(), password: password});
+        } else if(input.length == 3) {
+            var name = input[0];
+            var new_password = input[1];
+            var old_password = input[2];
+
+            temp_name = name;
+            temp_pass = password;
+
+            new_password = Crypt.crypt_pass(new_password);
+            old_password = Crypt.crypt_pass(old_password);
+
+            socket.emit("namechange", {name: name, channel: chan.toLowerCase(), new_password: new_password, old_password: old_password});
+        } else {
+
+        }
     },
 
     removename: function() {
-        socket.emit("removename");
+        socket.emit("removename", {channel: chan.toLowerCase()});
         Crypt.remove_name();
     },
 
     chat: function(data) {
-        if(data.value.length > 150)
+        if(data.value.length > 150) return;
-        return;
+        if(data.value.startsWith("/name ")){
-        /*if(data.value.startsWith("/name ")){
             Chat.namechange(data.value.substring(6));
-    } else */
+        } else if(data.value.startsWith("/help")) {
-    if(data.value.startsWith("/help")) {
             if($(".chat-tab-li a.active").attr("href") == "#all_chat"){
                 if($("#chatall").children().length > 100) {
                     $("#chatall").children()[0].remove()

server/public/assets/js/crypt.js

@@ -29,7 +29,11 @@ var Crypt = {
 
             Hostcontroller.change_enabled(conf_arr.remote);
             if(conf_arr.width != 100) Player.set_width(conf_arr.width);
-            //if(conf_arr.name !== undefined && conf_arr.name !== "") Chat.namechange(conf_arr.name);
+            if(conf_arr.name !== undefined && conf_arr.name !== "" && conf_arr.chat_pass !== undefined && conf_arr.chat_pass !== ""){
+                setTimeout(function() {
+                    Chat.namechange(conf_arr.name + " " + conf_arr.chat_pass);
+                }, 100); //to take height for delay on establishing connection
+            }
         }
     },
 
@@ -158,8 +162,9 @@ var Crypt = {
         Crypt.encrypt(Crypt.conf_pass, chan.toLowerCase());
     },
 
-    set_name:function(name) {
+    set_name:function(name, pass) {
         conf_arr.name = encodeURIComponent(name).replace(/\W/g, '');
+        conf_arr.chat_pass = pass;
         Crypt.encrypt(conf_arr, "_opt");
     },
 
@@ -170,6 +175,7 @@ var Crypt = {
 
     remove_name:function() {
         conf_arr.name = "";
+        conf_arr.chat_pass = "";
         Crypt.encrypt(conf_arr, "_opt");
     },
 

server/public/assets/js/embed.js

@@ -41,7 +41,6 @@ var Crypt = {
 
 function receiveMessage(event) {
     if(event.data == "parent") {
-        //console.log(event);
         window.parentWindow = event.source;
         window.parentOrigin = event.origin;
     }

server/public/assets/js/listeners.js

@@ -15,6 +15,8 @@ var frontpage 		   	  		= 1;
 var adminpass 		   	  		= "";
 var showDiscovery						= false;
 var filesadded		   	  		= "";
+var temp_name = "";
+var temp_pass = "";
 var chromecast_icon_color = "";
 var player_ready 	   	  		= false;
 var viewers 			  		= 1;
@@ -150,16 +152,28 @@ $().ready(function(){
                 if(offline) {
                     socket.emit("offline", {status: true, channel: chan != undefined ? chan.toLowerCase() : ""});
                 }
-                if((Crypt.get_pass(chan.toLowerCase()) !== undefined && Crypt.get_pass(chan.toLowerCase()) !== "")){
+                if(chan != undefined && (Crypt.get_pass(chan.toLowerCase()) !== undefined && Crypt.get_pass(chan.toLowerCase()) !== "")){
                     socket.emit("password", {password: Crypt.crypt_pass(Crypt.get_pass(chan.toLowerCase())), channel: chan.toLowerCase()});
                 }
+                if(chan != undefined && conf_arr.name !== undefined && conf_arr.name !== "" && conf_arr.chat_pass !== undefined && conf_arr.chat_pass !== ""){
+                    setTimeout(function() {
+                        Chat.namechange(conf_arr.name + " " + conf_arr.chat_pass);
+                    }, 100); //to take height for delay on establishing connection
+                }
             });
         }
-        /*if(conf_arr != undefined && conf_arr.name !== undefined && conf_arr.name !== "") {
+
-        setTimeout(function(){
+});
-        Chat.namechange(conf_arr.name);
+
-    }, 1000);
+socket.on("name", function(data) {
-}*/
+    if(data.type == "name" && data.accepted) {
+        Crypt.set_name(temp_name, temp_pass);
+        temp_name = "";
+        temp_pass = "";
+    } else {
+        temp_name = "";
+        temp_pass = "";
+    }
 });
 
 socket.on("self_ping", function() {