basic routing

2 files changed, 41 insertions, 2 deletions

diff --git a/server/index.js b/server/index.js
index d375351..657cdc8 100644
--- a/server/index.js
+++ b/server/index.js
@@ -9,7 +9,8 @@ var http = require('http'),
   express = require('express'),
 	bodyParser = require('body-parser'),
 	multer = require('multer'),
-	path = require('path');
+	path = require('path'),
+	ws = require("./ws");
 
 var app = express()
 var server
@@ -31,7 +32,7 @@ app.use(express.query())
 // }
 
 app.get("/", function(req,res){
-  res.render("pages/index", {})
+  res.render("pages/lobby", {})
 })
 app.get("/v/:room", function(req,res){
   res.render("pages/room")
@@ -42,3 +43,4 @@ server.listen(app.get('port'), function () {
   console.log('asdf-yt server listening on port ' + app.get('port'));
 })
 
+ws.listen(server)
\ No newline at end of file
diff --git a/server/ws.js b/server/ws.js
new file mode 100644
index 0000000..4715d34
--- /dev/null
+++ b/server/ws.js
@@ -0,0 +1,37 @@
+
+var server = require('socket.io')
+
+var ws = module.exports = {}
+
+ws.listen = function(app){
+  ws.io = server(app)
+}
+ws.add = function(name){
+  var room = {}
+  room.users = {}
+  
+  var ns = base.io.of('/' + name)
+  
+  ns.on('connection', function(socket){
+    
+    var username
+  
+    socket.on('join', function(data){
+      username = data.username
+      if (room.users[username]) {
+        // already connected?
+        room.users[username].disconnect()
+        room.users[username] = socket
+      }
+    })
+    
+    socket.on('message', function(data){
+      ns.emit('message', data)
+    })
+    
+    socket.on('disconnect', function(){
+      delete room.users[username]
+    })
+
+  })
+}