redis proviver and examples

Author: goenning

README.md

@@ -12,7 +12,10 @@ Currently requires express and connect to run, because it uses `res.on('header',
 
 Clone this repo into your project's node_modules directory. You can also install from npm, but the package may be outdated: https://www.npmjs.org/package/miniprofiler.
 
-Then see [examples/express/server.js](/blob/master/examples/express/server.js) for example use.
+Then see [examples/express/server.js](/examples/express/server.js) for example use.
+
+![](/examples/example1.png)
+![](/examples/example2.png)
 
 # Want to help?
 
@@ -27,3 +30,4 @@ Things to do:
 - add more providers (mongodb, mysql, redis)
 - remove old ids from global storage (when?)
 - add eslint to travis
+- better eslint (https://github.com/NodeRedis/node_redis/blob/master/.eslintrc)

examples/example1.png

@@ -1,12 +1,15 @@
 var miniprofiler = require('../../lib/miniprofiler.js');
 var pg = require('pg');
+var redis = require('redis');
+var redisClient = redis.createClient();
 
 var express = require('express');
 var connString = 'postgres://postgres:postgres@localhost/miniprofiler';
 
 var app = express();
 app.use(miniprofiler.profile());
 app.use(miniprofiler.for.pg(pg));
+app.use(miniprofiler.for.redis(redis));
 
 app.set('view engine', 'pug');
 app.set('views', './examples/views');
@@ -15,24 +18,43 @@ app.get('/', function(req, res) {
 	res.render('home');
 });
 
-app.get('/sleep', function(req, res) {
-	pg.connect(connString, function(err, client, done) {
-		client.query('SELECT pg_sleep(1)', [], function(err, result) {
+app.get('/redis-set-get', function(req, res) {
+  redisClient.set('customer', '[email protected]', function() {
+    redisClient.get('key', function(err, reply) {
+      res.render('home');
+    });
+  });
+});
+
+app.get('/pg-sleep', function(req, res) {
+	pg.connect(connString, function(err, pgClient, done) {
+		pgClient.query('SELECT pg_sleep(1)', [], function(err, result) {
       done();
       res.render('home');
 		});
 	});
 });
 
-app.get('/multi-query', function(req, res) {
-	pg.connect(connString, function(err, client, done) {
-		client.query('SELECT pg_sleep(1)', [], function(err, result) {
-			client.query('SELECT $1::int AS number', ['2'], function(err, result) {
-				done();
-        res.render('home');
-			});
-		});
-	});
+app.get('/all', function(req, res) {
+  req.miniprofiler.step('Waiting 1 second', function() {
+
+    pg.connect(connString, function(err, pgClient, done) {
+      pgClient.query('SELECT pg_sleep(1)', [ ], function(err, result) {
+
+        req.miniprofiler.step('Get from cache', function() {
+
+          redisClient.set('customer', '[email protected]', function() {
+            redisClient.get('key', function(err, reply) {
+              res.render('home');
+            });
+          });
+
+        });
+
+      });
+    });
+
+  });
 });
 
 app.listen(8080);

examples/example2.png

@@ -25,7 +25,8 @@ _.templateSettings = {
 exports.configure = configure;
 exports.profile = middleware;
 exports.for = {
-	pg: require('./providers/miniprofiler.pg.js')
+	pg: require('./providers/miniprofiler.pg.js'),
+	redis: require('./providers/miniprofiler.redis.js')
 };
 
 // GLOBALS
@@ -345,6 +346,8 @@ function step(name, request, call) {
  *  to have ended the query.
  */
 function timeQuery(extension, type, query, executeFunction) {
+  debug(`timeQuery "${type}" with command "${query}"`);
+
 	var time = process.hrtime();
 	var startDate = Date.now();
 

examples/express/server.js

@@ -0,0 +1,14 @@
+var redisSendCommand;
+
+module.exports = function(redis) {
+	return function(req, res, next) {
+    redisSendCommand = redisSendCommand || redis.RedisClient.prototype.internal_send_command;
+    if (req.miniprofiler.enabled) {
+      redis.RedisClient.prototype.internal_send_command = function(command, args, callback) {
+        var query = `${command} ${args}`;
+				req.miniprofiler.timeQuery('redis', query, redisSendCommand.bind(this), command, args, callback);
+			};
+		}
+		next();
+	};
+};