Making cache layer toggable.

Author: rcreasey

config/settings.js

@@ -30,6 +30,8 @@ module.exports = function () {
 		eventTtl: 900000,
 		scanTtl: 900000,
 
+		enableCache: false,
+
 		minPollInterval: 1,
 		cleanInterval: 60000,
 

lib/storage/storageManager.js

@@ -1,9 +1,10 @@
-module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, logger) {
+module.exports = function (memoryClient, mongoDbClient, mongooseClient, cacheLayer, settings, logger) {
 
 	var pub = {},
 		clients = {
 			'memory': memoryClient,
 			'mongoDb': mongoDbClient,
+			'mongoose': mongooseClient,
 		};
 
 	var getStore = function () {
@@ -13,42 +14,51 @@ module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, lo
 	pub.getByKey = function (type, key, callback) {
 		// logger.log('Getting ' + type + ' ' + key + '...', 1);
 
-		var cacheResult = cacheLayer.getByKey(type, key);
-		if (cacheResult) return callback(null, cacheResult);
+		if (settings.enableCache) {
+			var cacheResult = cacheLayer.getByKey(type, key);
+			if (cacheResult) return callback(null, cacheResult);
+		}
 
 		// logger.log(type + ' ' + key + ' not found in cache, getting from store...', 1);
 
 		getStore().getByKey(type, key, function (error, storeResult) {
 			if (error)  return callback(error);
 
-			if (storeResult) cacheLayer.upsertItem(type, storeResult);
+			if (settings.enableCache && storeResult) cacheLayer.upsertItem(type, storeResult);
 			callback(null, storeResult);
 		});
 	};
 
 	pub.getById = function (type, id, callback) {
-		var cacheResult = cacheLayer.getById(type, id);
-		if (cacheResult.length) return callback(null, cacheResult);
+
+		if (settings.enableCache) {
+			var cacheResult = cacheLayer.getById(type, id);
+			if (cacheResult.length) return callback(null, cacheResult);
+		}
 
 		getStore().getById(type, id, function (error, storeResult) {
 			if (error) return callback(error);
 
-			cacheLayer.upsertItem(type, storeResult);
+			if (settings.enableCache) cacheLayer.upsertItem(type, storeResult);
 			callback(null, storeResult);
 		});
 	};
 
 	pub.getByArmadaKey = function (type, armadaKey, callback) {
 		// logger.log('Getting all ' + type + 's from armada ' + armadaKey + '...', 1);
 
-		var cacheResult = cacheLayer.getByArmadaKey(type, armadaKey);
-		if (cacheResult.length) return callback(null, cacheResult);
+		if (settings.enableCache) {
+			var cacheResult = cacheLayer.getByArmadaKey(type, armadaKey);
+			if (cacheResult.length) return callback(null, cacheResult);
+		}
 
 		getStore().getByArmadaKey(type, armadaKey, function (error, storeResult) {
 			if (error) return callback(error);
 
-			for (var i in storeResult) {
-				cacheLayer.upsertItem(type, storeResult[i]);
+			if (settings.enableCache) {
+				for (var i in storeResult) {
+					cacheLayer.upsertItem(type, storeResult[i]);
+				}
 			}
 
 			callback(null, storeResult);
@@ -61,7 +71,7 @@ module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, lo
 		getStore().addItem(type, item, function (error) {
 			if (error) callback(error);
 
-			cacheLayer.upsertItem(type, item);
+			if (settings.enableCache) cacheLayer.upsertItem(type, item);
 			callback(null, true);
 		});
 	};
@@ -72,7 +82,7 @@ module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, lo
 		getStore().removeByKey(type, key, function (error) {
 			if (error) callback(error);
 
-			cacheLayer.removeByKey(type, key);
+			if (settings.enableCache) cacheLayer.removeByKey(type, key);
 			callback(null, true);
 		});
 	};
@@ -83,7 +93,7 @@ module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, lo
 		getStore().removeByArmadaKey(type, armadaKey, function (error) {
 			if (error) callback(error);
 
-			cacheLayer.removeByArmadaKey(type, armadaKey);
+			if (settings.enableCache) cacheLayer.removeByArmadaKey(type, armadaKey);
 			callback(null, true);
 		});
 	};
@@ -94,7 +104,7 @@ module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, lo
 		getStore().removeBySystemId(type, systemId, function (error) {
 			if (error) callback(error);
 
-			cacheLayer.removeBySystemId(type, systemId);
+			if (settings.enableCache) cacheLayer.removeBySystemId(type, systemId);
 			callback(null, true);
 		});
 	};
@@ -105,8 +115,10 @@ module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, lo
 		getStore().getAll(type, function (error, items) {
 			if (error) callback(error);
 
-			for (var i in items) {
-				if (items[i].key) cacheLayer.upsertItem(type, items[i]);
+			if (settings.enableCache) {
+				for (var i in items) {
+					if (items[i].key) cacheLayer.upsertItem(type, items[i]);
+				}
 			}
 
 			callback(null, items);
@@ -119,7 +131,7 @@ module.exports = function (memoryClient, mongoDbClient, cacheLayer, settings, lo
 		getStore().updateItem(type, key, item, function (error) {
 			if (error) return callback(error);
 
-			cacheLayer.upsertItem(type, item);
+			if (settings.enableCache) cacheLayer.upsertItem(type, item);
 			callback(null, true);
 		});
 	};