feat(api): basic post endpoints

api/src/controllers/post.ts

@@ -0,0 +1,50 @@
+import { Router } from 'express';
+import { auth } from 'src/middlewares/auth';
+import { createPost, getAllPosts, getPostsByUserId } from 'src/services/post';
+import { createError, formatResponse } from 'src/utils/helpers';
+
+const postRouter = Router();
+
+postRouter.use(auth);
+
+postRouter.get('/', async (req, res) => {
+  try {
+    const posts = await getAllPosts();
+    res.send(formatResponse(posts));
+  } catch (error) {
+    console.log(error);
+    res.status(500).send(createError('Internal server error.', error));
+  }
+});
+
+postRouter.get('/user/:id', async (req, res) => {
+  const {
+    params: { id },
+  } = req;
+
+  if (!id) return res.status(400).send(createError('User id not found'));
+
+  try {
+    const posts = await getPostsByUserId(id);
+    res.send(formatResponse(posts));
+  } catch (error) {
+    console.log(error);
+    res.status(500).send(createError('Internal server error.', error));
+  }
+});
+
+postRouter.post('/', async (req, res) => {
+  const { userId, body } = req;
+
+  if (!Object.keys(body.post).length) res.status(400).send(createError('Post not found'));
+
+  try {
+    const post = await createPost({ ...(body.post as any), user: userId });
+    res.send(formatResponse(post));
+  } catch (error) {
+    console.log(error);
+    res.status(500).send(createError('Internal server error.', error));
+  }
+});
+
+export { postRouter };

api/src/index.ts

@@ -12,6 +12,7 @@ import { authRouter } from 'src/controllers/auth';
 import { setupOauth } from './oauth';
 import { serve, setup } from 'swagger-ui-express';
 import specs from '../swagger-spec.json';
+import { postRouter } from './controllers/post';
 
 const PORT = parseEnv<number>('PORT') || 3000;
 
@@ -33,6 +34,7 @@ async function main() {
   setupOauth(app);
 
   app.use('/auth', authRouter);
+  app.use('/posts', postRouter);
   app.use('/api-docs', serve, setup(specs));
 
   try {

api/src/services/post.ts

@@ -0,0 +1,30 @@
+import { CreateQuery } from 'mongoose';
+import { Post, postModel } from 'src/entities/post';
+import { sanitizeResponse } from 'src/utils/helpers';
+
+export async function createPost(post: CreateQuery<Post>) {
+  try {
+    const newPost = await postModel.create({ ...post });
+    return { ...sanitizeResponse(newPost.toJSON()) };
+  } catch (error) {
+    throw error;
+  }
+}
+
+export async function getAllPosts() {
+  try {
+    const allPosts = await postModel.find();
+    return allPosts.map((post) => ({ ...sanitizeResponse(post.toJSON()) }));
+  } catch (error) {
+    throw error;
+  }
+}
+
+export async function getPostsByUserId(id: string) {
+  try {
+    const allPosts = await postModel.find({ user: id });
+    return allPosts.map((post) => ({ ...sanitizeResponse(post.toJSON()) }));
+  } catch (error) {
+    throw error;
+  }
+}

api/src/utils/helpers.ts

@@ -27,3 +27,9 @@ export function sanitizeResponse(
         {},
       );
 }
+
+export function formatResponse<T>(data: T) {
+  return {
+    data,
+  };
+}