Send response times to influxdb

stats.js

var InfluxDB = require('influx');

module.exports.register = function (plugin, options, ready) {

    var influx = new InfluxDB(options.host, options.port, options.username, options.password, options.database);
    
    plugin.expose('client', influx);

    plugin.ext('onRequest', function (req, next) {

        req.plugins.stats = {startTime: process.hrtime()};

        next();
    });

    plugin.ext('onPreResponse', function (req, next) {

        var diff = process.hrtime(req.plugins.stats.startTime);

        var responseTime = (diff[0] * 1e9 + diff[1]) / 1e6;

        influx.writePoint('response_times', {path: req.path, value: responseTime, method: req.method, user: req.user && req.user._id}, function () {});

        next();
    });

    ready();
};