add socket monit back

Author: anandkumarpatel

app.js

@@ -11,6 +11,7 @@ var Boom = require('dat-middleware').Boom;
 var activeApi = require('models/redis/active-api');
 var mongooseControl = require('models/mongo/mongoose-control');
 var envIs = require('101/env-is');
+var dogstatsd = require('models/datadog');
 
 if (process.env.NEWRELIC_KEY) {
   require('newrelic');
@@ -22,6 +23,9 @@ Api.prototype.start = function (cb) {
   debug('start');
   // start github ssh key generator
   keyGen.start();
+  // start sending socket count
+  dogstatsd.captureSocketCount();
+
   var count = createCount(callback);
   // connect to mongoose
   mongooseControl.start(count.inc.next);

lib/express-app.js

@@ -7,7 +7,6 @@ var envIs = require('101/env-is');
 var passport = require('middlewares/passport');
 var compression = require('compression');
 var pkg = require('../package.json');
-var dogstatsd = require('models/datadog');
 var app = module.exports = express();
 
 if (envIs('production')) {
@@ -17,8 +16,6 @@ if (envIs('production')) {
     'method':true,
     'tags': ['name:api', 'logType:express', 'env:'+process.env.NODE_ENV]
   }));
-
-  // app.use(dogstatsd.captureSocketCount);
 }
 
 if (envIs('development', 'local', 'stage')) {

lib/models/datadog/index.js

@@ -20,26 +20,26 @@ function captureSteamData (streamName, stream) {
   });
 }
 
-
-function captureSocketCount (req, res, next) {
+function captureSocketCount () {
   var sockets = require('http').globalAgent.sockets;
   var request = require('http').globalAgent.requests;
   var key;
 
   for (key in sockets) {
-    client.gauge('api.sockets_open', sockets[key].length, 1, ['target:'+key]);
+    client.gauge('api.sockets_open', sockets[key].length, 1,
+      ['target:'+key, 'pid:'+process.pid]);
   }
 
   for (key in request) {
-    client.gauge('api.sockets_pending', request[key].length, 1, ['target:'+key]);
+    client.gauge('api.sockets_pending', request[key].length, 1,
+      ['target:'+key, 'pid:'+process.pid]);
   }
 
   exec('lsof -p ' + process.pid + ' | wc -l', function (err, stdout) {
     if (err) { return; }
     client.gauge('api.openFiles', parseInt(stdout), 1, ['pid:'+process.pid]);
   });
-
-  next();
+  setTimeout(captureSocketCount, 60000);
 }
 
 module.exports.captureSteamData = captureSteamData;