summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorKyle K <kylek389@gmail.com>2012-07-03 01:45:17 -0500
committerKyle Kaminski <kyle@kkaminsk.com>2012-07-03 01:45:17 -0500
commit214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65 (patch)
treed3e090812da449b6a8d1b2019dc26d2cc5a1ee71
parent3e48e4f16526698d22e70bc140a4244cf8d10041 (diff)
downloadfubar-214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65.tar.gz
fubar-214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65.tar.bz2
fubar-214c9b65377d9c1a847e0cd9a2d1ea7fb3cbff65.zip
attempt to track connected clients
-rw-r--r--protoype/app.js24
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);
});