blog: add cache cleaner mixin

Author: icebob

blog/mixins/cache.cleaner.mixin.js

@@ -0,0 +1,18 @@
+"use strict";
+
+module.exports = function(serviceNames) {
+	const events = {};
+
+	serviceNames.forEach(name => {
+		events[`cache.clean.${name}`] = function() {
+			if (this.broker.cacher) {
+				this.logger.debug(`Clear local '${this.name}' cache`);
+				this.broker.cacher.clean(`${this.name}.*`);
+			}
+		};
+	});
+
+	return {
+		events
+	};
+};

blog/moleculer.config.js

@@ -6,5 +6,5 @@ module.exports = {
 	// Append hostname to nodeID. It will be unique when scale up instances in Docker
 	nodeID: (process.env.NODEID ? process.env.NODEID + "-" : "") + os.hostname().toLowerCase(),
 	metrics: true,
-	cacher: process.env.NODE_ENV == "production"
+	cacher: true
 };

blog/services/likes.service.js

@@ -4,12 +4,13 @@ const _ = require("lodash");
 const DbService = require("moleculer-db");
 const MongooseAdapter = require("moleculer-db-adapter-mongoose");
 const Like = require("../models/like.model");
+const CacheCleaner = require("../mixins/cache.cleaner.mixin");
 const Fakerator = require("fakerator");
 const fake = new Fakerator();
 
 module.exports = {
 	name: "likes",
-	mixins: [DbService],
+	mixins: [DbService, CacheCleaner(["users", "posts"])],
 	adapter: new MongooseAdapter(process.env.MONGO_URI || "mongodb://localhost/moleculer-blog"),
 	model: Like,
 
@@ -56,7 +57,10 @@ module.exports = {
 
 					return this.Promise.all(promises)
 						.then(() => this.adapter.count())
-						.then(count => this.logger.info(`Generated ${count} likes!`));
+						.then(count => {
+							this.logger.info(`Generated ${count} likes!`);
+							this.clearCache();
+						});
 
 				})
 				.catch(err => {

blog/services/posts.service.js

@@ -4,12 +4,13 @@ const _ = require("lodash");
 const DbService = require("moleculer-db");
 const MongooseAdapter = require("moleculer-db-adapter-mongoose");
 const Post = require("../models/post.model");
+const CacheCleaner = require("../mixins/cache.cleaner.mixin");
 const Fakerator = require("fakerator");
 const fake = new Fakerator();
 
 module.exports = {
 	name: "posts",
-	mixins: [DbService],
+	mixins: [DbService, CacheCleaner(["users", "likes"])],
 	adapter: new MongooseAdapter(process.env.MONGO_URI || "mongodb://localhost/moleculer-blog"),
 	model: Post,
 
@@ -73,8 +74,10 @@ module.exports = {
 							coverPhoto: fake.random.number(1, 20) + ".jpg",
 							createdAt: fakePost.created
 						};
-					}))
-						.then(posts => this.logger.info(`Generated ${posts.length} posts!`));
+					})).then(posts => {
+						this.logger.info(`Generated ${posts.length} posts!`);
+						this.clearCache();
+					});
 
 				}).catch(err => {
 					if (err.name == "ServiceNotFoundError") {

blog/services/users.service.js

@@ -7,6 +7,7 @@ const { MoleculerError } = require("moleculer").Errors;
 const DbService = require("moleculer-db");
 const MongooseAdapter = require("moleculer-db-adapter-mongoose");
 const User = require("../models/user.model");
+const CacheCleaner = require("../mixins/cache.cleaner.mixin");
 const Fakerator = require("fakerator");
 const fake = new Fakerator();
 
@@ -30,7 +31,7 @@ function hashPassword(password) {
 
 module.exports = {
 	name: "users",
-	mixins: [DbService],
+	mixins: [DbService, CacheCleaner(["users"])],
 	adapter: new MongooseAdapter(process.env.MONGO_URI || "mongodb://localhost/moleculer-blog"),
 	model: User,
 
@@ -81,7 +82,10 @@ module.exports = {
 						author: false
 					};
 				})))
-				.then(users => this.logger.info(`Generated ${users.length} users!`));
+				.then(users => {
+					this.logger.info(`Generated ${users.length} users!`);
+					this.clearCache();
+				});
 		}
 	},