Initial commit for posts route

routes/post.js

@@ -0,0 +1,87 @@
+let express = require('express')
+let router = express.Router()
+
+const Errors = require('../lib/errors')
+let { User, Thread, Post } = require('../models')
+
+router.post('/', async (req, res) => {
+	let validationErrors = []
+	let thread, replyingToPost, post
+
+	try {
+		if(req.body.content === undefined) {
+			validationErrors.push(Errors.missingParameter('content'))
+		} else if(typeof req.body.content !== 'string') {
+			validationErrors.push(Errors.invalidParamterType('content', 'string'))
+		} if (req.body.threadId === undefined) {
+			validationErrors.push(Errors.missingParameter('threadId'))
+		} else if(!Object.isInteger(req.body.threadId)) {
+			validationErrors.push(Errors.invalidParamterType('threadId', 'integer'))
+		} if(req.body.replyingToId !== undefined && !Object.isInteger(req.body.replyingToId)) {
+			validationErrors.push(Errors.invalidParamterType('replyingToId', 'integer'))
+		}
+
+		if(validationErrors) throw Errors.VALIDATION_ERROR
+
+		post = await Post.create({
+			content: req.body.content
+		})
+
+		thread = await Thread.findOne({ where: {
+			id: req.body.threadId
+		}})
+		user = await User.findOne({ where: {
+			username: req.session.username
+		}})
+
+		if(!thread) throw Errors.invalidParamter('threadId', 'thread does not exist')
+
+		await post.setUser(user)
+		await post.setThread(thread)
+		await thread.addPost(post)
+
+		if(req.body.replyingToId) {
+			replyingToPost = await Post.findOne({ where: {
+				id: req.body.replyingToId
+			}, include: [Thread] })
+
+			if(!replyingToPost) {
+				throw Errors.invalidParamter('replyingToId', 'post does not exist')
+			} else if(replyingToPost.Thread.id !== thread.id) {
+				throw Errors.invalidParamter('replyingToId', 'replies must be in same thread')
+			} else {
+				await post.setReplyingTo(replyingToPost)
+				await replyingToPost.addReplies(post)
+			}
+		}
+
+		res.json(await post.reload({
+			include: [
+				{ model: User, attributes: ['username', 'createdAt', 'updatedAt', 'id'] }, 
+				Thread,
+				{ model: Post, as: 'ReplyingTo', include:
+					[{ model: User, attributes: ['username', 'createdAt', 'updatedAt', 'id'] }]
+				}
+			]
+		}))
+	} catch (e) {
+		if(e === Errors.VALIDATION_ERROR) {
+			res.status(400)
+			res.json({
+				errors: validationErrors
+			})
+		} else if(e.name === 'invalidParamter') {
+			res.status(400)
+			res.json({
+				errors: [e]
+			})
+		} else {
+			res.status(500)
+			res.json({
+				errors: [Errors.unknown]
+			})
+		}
+	}
+})
+
+module.exports  router