Added socket.io

app.js

@@ -64,6 +64,15 @@ app.use((error, req, res, next) => {
 mongoose
 	.connect(process.env.FEED_DB_CONNECTION_STRING)
 	.then(() => {
-		app.listen(8080);
+		const server = app.listen(8080);
+		const io = require('./socket').init(server, {
+			cors: {
+				origin: 'http://localhost:3000',
+				methods: ['GET', 'POST'],
+			},
+		});
+		io.on('connection', (socket) => {
+			console.log('client connected');
+		});
 	})
 	.catch((err) => console.log(err));

controllers/feed.js

@@ -1,4 +1,5 @@
 const { validationResult } = require('express-validator');
+const io = require('../socket');
 const Post = require('../models/post');
 const User = require('../models/user');
 const removeFile = require('../utils/removeFile');
@@ -11,6 +12,7 @@ exports.getPosts = async (req, res, next) => {
 		const totalItems = await Post.find().countDocuments();
 		const posts = await Post.find()
 			.populate('creator')
+			.sort({ createdAt: -1 })
 			.skip((currentPage - 1) * perPage)
 			.limit(perPage);
 
@@ -62,6 +64,11 @@ exports.createPost = async (req, res, next) => {
 		user.posts.push(post);
 		await user.save();
 
+		io.getIO().emit('posts', {
+			action: 'create',
+			post: { ...post.doc, creator: { _id: req.userId, name: user.name } },
+		});
+
 		res.status(201).json({
 			message: 'Post created successfully!',
 			post: post,
@@ -113,15 +120,15 @@ exports.updatePost = async (req, res, next) => {
 	const newContent = req.body.content;
 
 	try {
-		let post = await Post.findById(postId);
+		let post = await Post.findById(postId).populate('creator');
 
 		if (!post) {
 			const error = new Error('No post foound with the id: ' + postId);
 			error.statusCode = 404;
 			throw error;
 		}
 
-		if (post.creator.toString() !== req.userId) {
+		if (post.creator._id.toString() !== req.userId) {
 			const error = new Error('Not Authorized!');
 			error.statusCode = 403;
 			throw error;
@@ -136,6 +143,12 @@ exports.updatePost = async (req, res, next) => {
 		post.imageUrl = newImageUrl;
 
 		const updatedPost = await post.save();
+
+		io.getIO().emit('posts', {
+			action: 'update',
+			post: updatedPost,
+		});
+
 		res.status(200).json({ message: 'Post is updated', post: updatedPost });
 	} catch (err) {
 		if (!err.statusCode) {
@@ -179,6 +192,11 @@ exports.deletePost = async (req, res, next) => {
 
 		await user.save();
 
+		io.getIO().emit('posts', {
+			action: 'delete',
+			post: postId,
+		});
+
 		res.status(200).json({ message: 'Post is removed!' });
 	} catch (err) {
 		if (!err.statusCode) {