add like service & model

Author: icebob

blog/models/like.model.js

@@ -0,0 +1,24 @@
+"use strict";
+
+let mongoose = require("mongoose");
+let Schema = mongoose.Schema;
+
+let LikeSchema = new Schema({
+	user: {
+		type: Schema.Types.ObjectId,
+		ref: "User",
+		required: "Please fill in a user ID",
+	},
+	post: {
+		type: Schema.Types.ObjectId,
+		ref: "Post",
+		required: "Please fill in a post ID",
+	}
+}, {
+	timestamps: true
+});
+
+// Add index
+LikeSchema.index({user: 1, post: 1}, {unique: true});
+
+module.exports = mongoose.model("Like", LikeSchema);

blog/models/post.model.js

@@ -16,10 +16,6 @@ let PostSchema = new Schema({
 	coverPhoto: {
 		type: String
 	},
-	likes: {
-		type: Number,
-		default: 0
-	},
 	author: {
 		type: Schema.Types.ObjectId,
 		ref: "User",

blog/package.json

@@ -20,7 +20,7 @@
     "ioredis": "3.1.1",
     "lodash": "4.17.4",
     "moleculer": "0.8.2",
-    "moleculer-db": "0.4.1",
+    "moleculer-db": "0.4.5",
     "moleculer-db-adapter-mongoose": "0.3.1",
     "moleculer-fake": "1.0.4",
     "moleculer-repl": "0.1.3",

blog/services/likes.service.js

@@ -0,0 +1,79 @@
+"use strict";
+
+const _ = require("lodash");
+const DbService = require("moleculer-db");
+const MongooseAdapter = require("moleculer-db-adapter-mongoose");
+const Like = require("../models/like.model");
+const Fakerator = require("fakerator");
+const fake = new Fakerator();
+
+module.exports = {
+	name: "likes",
+	mixins: DbService,
+	adapter: new MongooseAdapter(process.env.MONGO_URI || "mongodb://localhost/moleculer-blog"),
+	model: Like,
+
+	settings: {
+		fields: ["user", "post"],
+		populates: {
+			"user": {
+				action: "users.get",
+				params: {
+					fields: ["_id", "username", "fullName", "avatar"]
+				}
+			}
+		}
+	},
+
+	methods: {
+		seedDB() {
+			this.logger.info("Seed Likes DB...");
+
+			return this.Promise.all([
+				this.broker.call("users.find"),
+				this.broker.call("posts.find")
+			]).then(([users, posts]) => {
+				if (users.length == 0 || posts.length == 0) {
+					this.logger.info("Waiting for `users` & 'posts' seed...");
+					setTimeout(this.seedDB, 1000);
+					return;
+				}
+
+				let promises = [];
+
+				users.forEach(user => {
+					_.times(fake.random.number(8, 15), () => {
+						let p = this.adapter.insert({
+							user: user._id,
+							post: fake.random.arrayElement(posts)._id
+						}).catch(err => {
+							// Skip unique index error
+						});
+						promises.push(p);
+					});
+				});
+
+				return this.Promise.all(promises)
+					.then(() => this.count())
+					.then(count => console.log(`Generated ${count} likes!`));
+
+			}).catch(err => {
+				if (err.name == "ServiceNotFoundError") {
+					this.logger.info("Waiting for `users` & `posts` service...");
+					setTimeout(this.seedDB, 1000);
+					return;
+				} else
+					return Promise.reject(err);
+			});
+		}
+	},
+
+	afterConnected() {
+		return this.count().then(count => {
+			if (count == 0) {
+				this.seedDB();
+			}
+		});
+	}
+
+};

blog/services/posts.service.js

@@ -14,19 +14,38 @@ module.exports = {
 	model: Post,
 
 	settings: {
-		fields: ["_id", "title", "content", "author", "likes", "category", "coverPhoto", "createdAt"],
+		fields: ["_id", "title", "content", "author", "likes", "likers", "category", "coverPhoto", "createdAt"],
 		populates: {
 			"author": {
 				action: "users.get",
 				params: {
 					fields: ["_id", "username", "fullName", "avatar"]
 				}
+			},
+			likes(ids, docs, rule, ctx) {
+				return this.Promise.all(docs.map(doc => ctx.call("likes.count", { query: { post: doc._id } }).then(count => doc.likes = count)));
+			},
+			"likers": {
+				action: "likes.findByPost",
+				params: {
+					populate: ["user"],
+					limit: 5
+				}
 			}
 		},
 		pageSize: 5
 	},
 
 	actions: {
+
+		like(ctx) {
+
+		},
+
+		unlike(ctx) {
+
+		}
+
 	},
 
 	methods: {
@@ -49,7 +68,6 @@ module.exports = {
 						content: fake.times(fake.lorem.paragraph, 10).join("\r\n"),
 						category: fake.random.arrayElement(["General", "Tech", "Social", "News"]),
 						author: fake.random.arrayElement(authors)._id,
-						likes: fake.random.number(100),
 						coverPhoto: fake.random.number(1, 20) + ".jpg",
 						createdAt: fakePost.created
 					});

blog/services/www.service.js

@@ -41,7 +41,7 @@ module.exports = {
 
 			return Promise.resolve({ page })
 				.then(data => {
-					return this.broker.call("posts.list", { page, pageSize, populate: ["author"] }).then(res => {
+					return this.broker.call("posts.list", { page, pageSize, populate: ["author", "likes"] }).then(res => {
 						data.posts = res.rows;
 						data.totalPages = res.totalPages;
 						return data;
@@ -60,7 +60,7 @@ module.exports = {
 
 			return Promise.resolve({ page })
 				.then(data => {
-					return this.broker.call("posts.list", { query: { category }, page, pageSize, populate: ["author"] }).then(res => {
+					return this.broker.call("posts.list", { query: { category }, page, pageSize, populate: ["author", "likes"] }).then(res => {
 						data.posts = res.rows;
 						data.totalPages = res.totalPages;
 						return data;
@@ -81,7 +81,7 @@ module.exports = {
 
 			return Promise.resolve({ page })
 				.then(data => {
-					return this.broker.call("posts.list", { query: { author }, page, pageSize, populate: ["author"] }).then(res => {
+					return this.broker.call("posts.list", { query: { author }, page, pageSize, populate: ["author", "likes"] }).then(res => {
 						data.posts = res.rows;
 						data.totalPages = res.totalPages;
 						return data;
@@ -102,7 +102,7 @@ module.exports = {
 
 			return Promise.resolve({ page })
 				.then(data => {
-					return this.broker.call("posts.list", { search, page, pageSize, populate: ["author"] }).then(res => {
+					return this.broker.call("posts.list", { search, page, pageSize, populate: ["author", "likes"] }).then(res => {
 						data.query = search;
 						data.posts = res.rows;
 						data.totalPages = res.totalPages;
@@ -121,7 +121,7 @@ module.exports = {
 				return this.handleErr(res)(this.Promise.reject(new MoleculerError("Invalid POST ID", 404, "INVALID_POST_ID", { id: req.params.id })));
 
 			return Promise.resolve({ })
-				.then(data => this.broker.call("posts.get", { id, populate: ["author"] }).then(post => {
+				.then(data => this.broker.call("posts.get", { id, populate: ["author", "likes"] }).then(post => {
 					if (!post)
 						return this.Promise.reject(new MoleculerError("Post not found", 404, "NOT_FOUND_POST", { id: req.params.id }));
 
@@ -136,7 +136,7 @@ module.exports = {
 		},
 
 		appendAdditionalData(data) {
-			return this.broker.call("posts.find", { limit: 5, sort: "-likes" }).then(posts => {
+			return this.broker.call("posts.find", { limit: 5, sort: "-createdAt" }).then(posts => {
 				data.bestOfPosts = posts;
 				return data;
 			});