diff options
author | Kyle K <kylek389@gmail.com> | 2012-07-03 01:45:17 -0500 |
---|---|---|
committer | Kyle Kaminski <kyle@kkaminsk.com> | 2012-07-03 01:45:17 -0500 |
commit | 214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65 (patch) | |
tree | d3e090812da449b6a8d1b2019dc26d2cc5a1ee71 /protoype | |
parent | 3e48e4f16526698d22e70bc140a4244cf8d10041 (diff) | |
download | fubar-214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65.tar.gz fubar-214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65.tar.bz2 fubar-214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65.zip |
attempt to track connected clients
Diffstat (limited to 'protoype')
-rw-r--r-- | protoype/app.js | 24 |
1 files changed, 22 insertions, 2 deletions
diff --git a/protoype/app.js b/protoype/app.js index 15556eb..2d55388 100644 --- a/protoype/app.js +++ b/protoype/app.js @@ -11,8 +11,10 @@ var dburl = 'localhost/nodejs1'; var collections = ['users']; var db = require('mongojs').connect(dburl, collections); var util = require('util'); +var crypto = require('crypto') var driver = require('./router/driver.js'); /* var activeusers = require('./activeusers'); */ +var connected_clients = {}; var app = express.createServer(); @@ -59,6 +61,8 @@ app.post('/login', function(req, res) { if (err || !updated) util.log('[login] failed to set status to online'); }); + /* real deal? */ + connected_clients[thing[0].tag] = {ip: res.connection.myip, port: res.connection.myport}; res.send('successfully logged in\n', 200); } else { @@ -139,9 +143,25 @@ app.get('/', function(req, res) { app.get('/newuser', driver.newuser); app.listen(8081, function() { - console.log("listening on port %d in %s mode", this.address().port, this.settings.env); + util.log(util.format('[server] listening on port %d in %s mode', this.address().port, this.settings.env)); }) .on('error', function(e) { - console.log('failed creating server, errno: ' + e.errno); + util.log('[server] failed creating server, errno: ' + e.errno); +}) +.on('connection', function(socket) { + /* socket.myid = crypto.createHash('md5').update(socket.remoteAddress + ':' + socket.remotePort).digest('hex'); */ + socket.myip = socket.remoteAddress; + socket.myport = socket.remotePort; + util.log('[server] new connection from ' + socket.remoteAddress + ':' + socket.remotePort); + socket.on('close', function() { + /* delete connected_clients */ + console.log('[server] client ' + this.myip + ':' + this.myport + ' closed connection\n'); + }); +}) +.on('close', function() { + util.log('[server] server shutdown'); +}) +.on('clientError', function(exception) { + util.log('[server] ' + exception); }); |