Merge pull request #10 from Sewvandiii/main

Post Endpoint Done

Author: chamodshehanka

src/api/index.ts

@@ -1,6 +1,7 @@
 import { Router } from "express";
 import user from "./user/user.route";
 import category from "./category/category.route";
+import post from "./post/post.route"
 
 const router = Router();
 
@@ -10,5 +11,6 @@ router.get("/", (req, res) => {
 
 router.use("/user", user);
 router.use("/category", category);
+router.use("/post", post);
 
 export default router;

src/api/post/post.class.ts

@@ -0,0 +1,13 @@
+import * as mongoose from "mongoose";
+import { IPost } from "./post.interface";
+
+export const PostSchema = new mongoose.Schema({
+    description: { type: String, required: true },
+    imageURL: { type: String, required: true },
+    createdDate: { type: String, required: true },
+    userId: { type: String, required: true },
+    categoryName: { type: String, required: true },
+});
+
+const Post = mongoose.model<IPost>("Post", PostSchema);
+export default Post;

src/api/post/post.controller.ts

@@ -0,0 +1,115 @@
+import { Request, Response } from "express";
+import * as mongodb from "mongodb";
+import { MongoHelper } from "../../config/mongodb.config";
+import Post from "./post.class";
+import Config from "../../config/config";
+import ErrorCodes from "../../config/error.codes";
+import SuccessCodes from "../../config/success.codes";
+import * as httpStatus from "http-status";
+import * as responses from "../../helpers/responses.handler";
+import { ObjectId } from "mongodb";
+
+const getCollection = () => {
+    return MongoHelper.client
+        .db(Config.DB_NAME)
+        .collection(Config.POST_COLLECTION_NAME);
+};
+
+export default class PostController {
+    public addPost = async (req: Request, res: Response): Promise<any> => {
+        const requestData = req.body;
+        const collection = getCollection();
+        const post = new Post(requestData);
+        try {
+            await collection.insertOne(post);
+
+            res
+                .status(httpStatus.CREATED)
+                .send(responses.success(SuccessCodes.SUCCESSFULLY_DATA_ADDED));
+            res.end();
+        } catch (e) {
+            console.error(e.message);
+            res.send(
+                responses.failed(ErrorCodes.INTERNAL_ERROR, httpStatus.BAD_REQUEST)
+            );
+        }
+    };
+
+    public getPost = async (req: Request, res: Response): Promise<any> => {
+        const collection = getCollection();
+        const id = req.params.id;
+        try {
+            const post = await collection.findOne({
+                _id: new ObjectId(id),
+            });
+
+            res.send(
+                responses.successWithPayload(
+                    SuccessCodes.SUCCESSFULLY_DATA_RETRIVED,
+                    post
+                )
+            );
+        } catch (e) {
+            console.error(e.message);
+            res.send(
+                responses.failed(ErrorCodes.INTERNAL_ERROR, httpStatus.BAD_REQUEST)
+            );
+        }
+    };
+
+    public getAllPost = async (req: Request, res: Response): Promise<any> => {
+        const collection: any = getCollection();
+
+        try {
+            const data = await collection.find().toArray();
+
+            res.send(
+                responses.successWithPayload(
+                    SuccessCodes.SUCCESSFULLY_DATA_RETRIVED,
+                    data
+                )
+            );
+        } catch (e) {
+            console.error(e.message);
+            res.send(
+                responses.failed(ErrorCodes.INTERNAL_ERROR, httpStatus.BAD_REQUEST)
+            );
+        }
+    };
+
+    public updatePost = async (req: Request, res: Response): Promise<any> => {
+        const { _id, userId, description, imageURL, createdDate, categoryName } =
+            req.body;
+
+        const collection: any = getCollection();
+
+        try {
+            await collection.findOneAndUpdate(
+                { _id: new mongodb.ObjectId(_id) },
+                { $set: { userId, description, imageURL, createdDate, categoryName } }
+            );
+
+            res.send(responses.success(SuccessCodes.SUCCESSFULLY_DATA_UPDATED));
+        } catch (e) {
+            console.error(e.message);
+            res.send(
+                responses.failed(ErrorCodes.INTERNAL_ERROR, httpStatus.BAD_REQUEST)
+            );
+        }
+    };
+
+    public deletePost = async (req: Request, res: Response): Promise<any> => {
+        const id = req.params.id;
+        const collection: any = getCollection();
+
+        try {
+            await collection.deleteOne({ _id: new mongodb.ObjectId(id) });
+            res.send(responses.success(SuccessCodes.SUCCESSFULLY_DATA_DELETED));
+        } catch (e) {
+            console.error(e.message);
+            res.send(
+                responses.failed(ErrorCodes.INTERNAL_ERROR, httpStatus.BAD_REQUEST)
+            );
+        }
+    };
+}

src/api/post/post.interface.ts

@@ -0,0 +1,9 @@
+import * as mongoose from "mongoose";
+
+export interface IPost extends mongoose.Document {
+  description: string;
+  imageURL: string;
+  createdDate: string;
+  userId: string;
+  categoryName: string;
+}

src/api/post/post.route.ts

@@ -0,0 +1,13 @@
+import { Router } from "express";
+import Controller from "./post.controller";
+
+const post: Router = Router();
+const controller = new Controller();
+
+post.post("/", controller.addPost);
+post.get("/:id", controller.getPost);
+post.get("/", controller.getAllPost);
+post.put("/", controller.updatePost);
+post.delete("/:id", controller.deletePost);
+
+export default post;

src/config/config.ts

@@ -11,4 +11,5 @@ export default {
   DB_NAME: "CodeKitty",
   USER_COLLECTION_NAME: "user",
   CATEGORY_COLLECTION_NAME: "category",
+  POST_COLLECTION_NAME: "post"
 };