first commit

Author: rauchg

.gitignore

@@ -0,0 +1 @@
+node_modules

Readme.md

@@ -0,0 +1,26 @@
+
+# weplay-presence
+
+Small script that aggregates the count of connected clients from
+each weplay server and broadcasts it.
+
+## How to install
+
+```js
+$ npm install
+```
+
+And run it with the following ENV vars:
+
+- `WEPLAY_REDIS` - redis uri (`localhost:6379`)
+- `WEPLAY_INTERVAL` - how often we update clients on the total
+  number of connected peers. We use an interval to avoid client slowdowns
+  when too many clients connect at once (`5000`)
+
+```
+$ node index
+```
+
+## License
+
+MIT

index.js

@@ -0,0 +1,14 @@
+
+var redis = require('./redis');
+var io = require('socket.io-emitter')(redis);
+var interval = process.env.WEPLAY_INTERVAL || 5000;
+
+setInterval(function(){
+  redis.hgetall('weplay:connections', function(err, counts){
+    if (!counts) return;
+    var count = 0;
+    for (var i in counts) count += Number(counts[i]);
+    redis.set('weplay:connections-total', count);
+    io.emit('connections', count);
+  });
+}, interval);

package.json

@@ -0,0 +1,12 @@
+{
+  "name": "weplay-presence",
+  "version": "0.0.1",
+  "description": "",
+  "dependencies": {
+    "debug": "0.7.4",
+    "socket.io-emittter": "0.1.0"
+  },
+  "scripts": {
+    "start": "node index.js"
+  }
+}

redis.js

@@ -0,0 +1,8 @@
+
+var redis = require('redis');
+var uri = process.env.WEPLAY_REDIS_URI || 'localhost:6379';
+var pieces = uri.split(':');
+
+module.exports = function(){
+  return redis.createClient(pieces[1], pieces[0], { return_buffers: true });
+};