From f607dac15deb8b9faeb060661ccf8edd2b9564fc Mon Sep 17 00:00:00 2001
From: okalintu <ilkka.oksanen@aalto.fi>
Date: Wed, 4 Mar 2015 02:45:33 +0200
Subject: implemented feature to allow ppl to remove themselves from que

---
 index.js | 31 +++++++++++++++++++++++++++----
 1 file changed, 27 insertions(+), 4 deletions(-)

(limited to 'index.js')

diff --git a/index.js b/index.js
index b4d50e1..bc02e82 100644
--- a/index.js
+++ b/index.js
@@ -2,7 +2,8 @@ var app = require('express')();
 var http = require('http').Server(app);
 var io = require('socket.io')(http);
 
-var que = []
+var que = [];
+var pws = {};
 
 app.get('/', function(req, res){
   res.sendFile(__dirname + '/f/templates/index.html');
@@ -18,10 +19,19 @@ app.get('/f/*', function(req, res){
 
 
 io.on('connection', function(socket){
+  var uid = Date.now();
+  var pw =  Math.random()*10000000 + Math.random()*10000000 -1;
+  pws[uid] = pw;
+
+
+  socket.emit("userinfo",{"uid":uid,"pw":pw});
   socket.emit("quedata",que);
+  
    
   socket.on("queadd",function(data){
-		console.log("adding new que entry");
+		console.log("adding new que entry with user :" );
+    data.qid= Date.now();
+
   	que.push(data);
 		io.emit("quedata",que);
   });
@@ -29,9 +39,22 @@ io.on('connection', function(socket){
 		console.log("deleting first from que");
   	que.shift();
 		io.emit("quedata",que);
-  });
-
 
+  });
+  socket.on("quedelete",function(data){
+    for (var i=0;i<que.length;i++){
+      if (que[i].qid == data.qid){
+        if (data.pw != pws[que[i].uid]){
+          socket.emit("err",{"msg":"you're not allowed to remove this entry"});
+          break;
+        }
+        console.log("deleting: "+ que[i].name);
+        que.splice(i,1);
+        io.emit("quedata",que);
+        break;
+      }
+    }
+  });
 
 });
 
-- 
cgit v1.3