redis library and product list cache added

.docker/redis/redis.conf

@@ -0,0 +1 @@
+bind 0.0.0.0

docker-compose.yml

@@ -20,6 +20,9 @@ services:
         image: redis:alpine
         ports:
             - "6379:6379"
+        command: ["redis-server", "/etc/redis/redis.conf"]
+        volumes:
+            - "./.docker/redis/redis.conf:/etc/redis/redis.conf"
 
     logstash:
         build: ./.docker/logstash

libraries/redis-client.js

@@ -0,0 +1,39 @@
+var redis = require('redis');
+  client = redis.createClient({'host': 'redis'});
+
+var RedisClient = {
+  push: function(key, value, callback) {
+    client.lpush(key, value, function(err, result) {
+      callback(err, result);
+    });
+  },
+
+  pop: function() {
+    client.brpop(key, value, function(err, result) {
+      callback(err, result);
+    });
+  },
+
+  set: function(key, value, ttl) {
+    if (value) {
+      client.set(key, JSON.stringify(value), 'EX', ttl);
+    }
+  },
+
+  get: function(key, callback) {
+    client.get(key, function(err, result) {
+      if (result) {
+        callback(err, JSON.parse(result));
+        return;
+      }
+      callback(true, {});
+    });
+  },
+
+  delete: function() {
+    client.delete(key);
+  }
+}
+
+
+module.exports = RedisClient;

package.json

@@ -7,6 +7,7 @@
   },
   "dependencies": {
     "async": "^2.5.0",
+    "blueimp-md5": "^2.10.0",
     "body-parser": "~1.18.2",
     "cookie-parser": "~1.4.3",
     "debug": "~2.6.9",
@@ -18,6 +19,7 @@
     "mysql": "^2.14.1",
     "node-datetime": "^2.0.3",
     "nodemon": "^1.12.1",
+    "redis": "^2.8.0",
     "serve-favicon": "~2.4.5",
     "twig": "~0.10.3"
   }

routes/products.js

@@ -4,15 +4,33 @@ var productService = require('../services/productService');
 var categoryService = require('../services/categoryService');
 var waterfall = require('async/waterfall');
 var productSearchService = require('../services/productSearchService');
+var redisClient = require('../libraries/redis-client');
+var md5 = require('blueimp-md5');
 
 /* GET products listing. */
 router.get('/', function(req, res, next) {
-  var queryParams = req.query
-  productService.getRecords(queryParams, function(err, results) {
-    if(err) { res.send(500,"Server Error"); return; }
-    // Respond with results as JSON
-    res.render('products', {'title': 'Products', products: results, 'totalCount': results.length});
-  });
+  var queryParams = req.query;
+  waterfall([
+    function(waterfallCallback) {
+      redisClient.get(md5(queryParams), function(err, results) {
+        if (err) { console.log(err); waterfallCallback(); return; }
+        if (results) {
+          res.render('products', {'title': 'Products', products: results, 'totalCount': results.length, 'cache': true});
+          return;
+        }
+        waterfallCallback();
+      });
+    },
+    function(waterfallCallback) {
+      productService.getRecords(queryParams, function(err, results) {
+        if(err) { res.send(500,"Server Error"); return; }
+        redisClient.set(md5(queryParams), results, 100);
+        // Respond with results as JSON
+        res.render('products', {'title': 'Products', products: results, 'totalCount': results.length,  'cache': false});
+
+      });
+    }
+  ]);
 });
 
 /* GET products listing. */

views/products.twig

@@ -2,7 +2,7 @@
 
 {% block body %}
   <a href="/product/new" class="float-right">New Product</a>
-  <h1>{{title}} <sup><small>(Total : {{totalCount}})</small></sup></h1>
+  <h1>{{title}} <sup><small>(Total : {{totalCount}} | Cache: {% if cache %}true{% else %}false{% endif %})</small></sup></h1>
   <div>
     <ul>
       {% for product in products %}