var express = require('express'); var app = express(); var http = require('http'), mysql = require("mysql"); var server = http.createServer(app); var io = require('socket.io').listen(server); 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 SiteRooms = {}; var parseCookie = require('connect').utils.parseCookie; io.sockets.on('connection', function (socket) { io.set('authorization', function (data, accept) { if (data.headers.cookie) { data.cookie = parseCookie(data.headers.cookie); data.sessionID = data.cookie['express.sid']; } else { return accept('No cookie transmitted.', false); } accept(null, true); }); socket.on("private", function(data) { if(data.agentName.length <= 0) { data.agentName = 'Besökare'; } io.sockets.in('Room_' + data.user_id).emit('updatechat', data.agentName, data.msg); console.log('A socket with sessionID ' + data.handshake.sessionID + ' connected!'); }); });