Minte.upload file

starter-project-backend-g32/package.json

@@ -13,14 +13,16 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
+    "cloudinary": "^1.30.1",
     "@types/bcrypt": "^5.0.0",
     "@types/jsonwebtoken": "^8.5.8",
     "bcrypt": "^5.0.1",
     "dotenv": "^10.0.0",
     "express": "^4.17.1",
     "jsonwebtoken": "^8.5.1",
     "mongodb-memory-server": "^7.6.3",
-    "mongoose": "^5.13.4"
+    "mongoose": "^5.13.4",
+    "multer": "^1.4.5-lts.1"
   },
   "devDependencies": {
     "@types/dotenv": "^8.2.0",

starter-project-backend-g32/src/app.ts

@@ -1,21 +1,20 @@
 import express, {Application, Request, Response, NextFunction, json} from 'express';
 import dotenv from 'dotenv';
-
-dotenv.config();
-
 import articleRoutes from './routes/article'
 import userRoutes from './routes/user'
-import commentRouter from './routes/comment';
-dotenv.config();
+import commentRoutes from './routes/comment'
+import uploadRoutes  from './routes/upload'
 
 
+dotenv.config();
 const app: Application = express();
 app.use(express.urlencoded({ extended: true }));
 app.use(express.json());
 app.use("/" , json({}));
 
-app.use("/api/v1/comment", commentRouter);
-app.use('/api/v1/articles', articleRoutes);
+app.use('/api/v1/articles', articleRoutes)
+app.use('/api/v1/comments', commentRoutes)
+app.use('/api/v1/upload', uploadRoutes)
 app.use('/api/v1/userProfile', userRoutes);
 
 export default app;

starter-project-backend-g32/src/controllers/comment.ts

@@ -0,0 +1,103 @@
+import {Request , Response } from "express";
+import Comment from "../models/comment";
+import Article from "../models/article";
+
+
+export const createComment = async (req:Request, res:Response ) => {
+    const comment = new Comment(req.body);
+    await comment.save().then(() => {
+        res.status(201).json({
+            message: "Comment added successfully",
+            comment: comment
+        });
+    }).catch((error: Error) => {
+        res.status(400).json({
+            error: error
+        });
+    }   );
+
+}
+
+export const getComment = async (req:Request, res:Response ) => {
+
+    try{
+        const article = await Article.findById({ _id: req.params.articleID })
+        if (article){
+            await Comment.findById(req.params.commentID).then((comment : typeof Comment) => {
+                res.status(200).json(comment);
+            }).catch((error: Error) => {
+                res.status(404).json({
+                    error: error
+                });
+            }   );
+        }else{
+            res.status(404).json({msg: "article not found"})
+        }
+    }catch(err){
+        res.status(500).json({msg: err})
+    }
+
+}
+
+export const getComments = async (req:Request, res:Response ) => {
+    await Comment.find().then((comments: any) => {
+        res.status(200).json(comments);
+    }).catch((error: Error) => {
+        res.status(400).json({
+            error: error
+        });
+    }   );
+}
+
+export const deleteComment = async (req:Request, res:Response ) => {
+    try{
+        const article = await Article.findById({ _id: req.params.articleID })
+        if (article){
+            await Comment.findByIdAndRemove(req.params.commentID).then(() => {
+                res.status(200).json({
+                    message: "Comment deleted successfully"
+                });
+            }).catch((error: Error) => {
+                res.status(404).json({
+                    error: error
+                });
+            }   );
+        }else{
+            res.status(404).json({msg: "article not found"})
+        }
+    }catch(err){
+        res.status(500).json(err)
+    }
+
+}
+
+export const updateComment = async (req:Request, res:Response ) => {
+    try{
+        const article = await Article.findById({ _id: req.params.articleID })
+        if (article){
+            if(!req.body.content) {
+                res.status(400).json({
+                    error: "Content is required"
+                });
+            }else{
+            const {content , createdAt} = req.body;
+            const updatedComment = {"content" : content , "createdAt": createdAt ? createdAt : new Date()};
+
+            await Comment.findByIdAndUpdate(req.params.commentID, updatedComment).then(() => {
+                res.status(200).json({
+                    message: "Comment updated successfully"
+                });
+            }).catch((error: Error) => {
+                res.status(404).json({
+                    error: error
+                });
+            }   );
+            }  
+        }else{
+            res.status(404).json({msg: "article not found"})
+        }
+    }catch(err){
+        res.status(500).json(err)
+    }
+
+}

starter-project-backend-g32/src/controllers/upload.ts

@@ -0,0 +1,82 @@
+import { Request, Response } from 'express'
+import cloudinary from '../utils/cloudinary'
+import User from '../models/user.models'
+import Article from '../models/article'
+
+export const deleteUserProfile = async (req: Request, res: Response) => {
+      try {
+          let user = await User.findById(req.params.id)
+          const cloudinaryId = user?.profilePic.split(/.jpg|.jpeg|.png/,2)[1]
+          cloudinaryId && (await cloudinary.uploader.destroy(cloudinaryId))
+          const data = {
+            profilePic: "",
+          }
+          user = await User.findByIdAndUpdate(req.params.id, data, { new: true })
+          res.status(200).json(user)
+      } catch (err) {
+          res.status(404).json(err)
+      }
+}
+
+
+export const updateUserProfile = async (req: Request, res: Response) => {
+      try {
+          let user = await User.findById(req.params.id)
+          const cloudinaryId = user?.profilePic.split(/.jpg|.jpeg|.png/,2)[1]
+          cloudinaryId && (await cloudinary.uploader.destroy(cloudinaryId))
+          let result = {secure_url:"",public_id:""};
+          if (req.file) {
+            result = await cloudinary.uploader.upload(req.file.path)
+          }else{
+            return res.status(400).end()
+          }
+          const profileData = user?.profilePic || result.secure_url + result.public_id
+
+          const data = {
+            profilePic: profileData
+          };
+          user = await User.findByIdAndUpdate(req.params.id, data, { new: true })
+          res.status(200).json(user)
+      } catch (err) {
+          res.status(404).json(err)
+      }
+    }
+
+export const deleteArticleMedia = async (req: Request, res: Response) => {
+        try {
+            let article = await Article.findById({_id:req.params.id})
+            const cloudinaryId = article?.media.split(/.jpg|.jpeg|.png/,2)[1]
+            cloudinaryId && (await cloudinary.uploader.destroy(cloudinaryId))
+            const data = {
+                media: '',
+            }
+            article = await Article.findByIdAndUpdate(req.params.id, data, { new: true })
+            res.status(200).json(article)
+        } catch (err) {
+            res.status(404).json(err)
+        }
+}
+
+
+export const updateArticleMedia = async (req: Request, res: Response) => {
+      try {
+          let article = await Article.findById(req.params.id)
+          const cloudinaryId = article?.media.split(/.jpg|.jpeg|.png/,2)[1]
+          cloudinaryId && (await cloudinary.uploader.destroy(cloudinaryId))
+          let result = {secure_url:"",public_id:""};
+          if (req.file) {
+            result = await cloudinary.uploader.upload(req.file.path);
+          }else{
+            return res.status(400).end()
+          }
+          const profileData = article?.media || result.secure_url + result.public_id
+
+          const data = {
+              media: profileData,
+          }
+          article = await Article.findByIdAndUpdate(req.params.id, data, { new: true })
+          res.status(200).json(article)
+        } catch (err) {
+          res.status(404).json(err)
+        }
+    }

starter-project-backend-g32/src/models/article.ts

@@ -8,6 +8,7 @@ export interface IArticle extends Document {
 }
 
 const articleSchema: Schema<IArticle> = new mongoose.Schema({
+
     author: {
       type: String,
       required: true

starter-project-backend-g32/src/models/comment.ts

@@ -1,25 +1,23 @@
 const mongoose = require('mongoose');
-
-const commentSchema = new mongoose.Schema({    
-        articleId: {
-            type: mongoose.Schema.Types.ObjectId,
-            ref:"Article",
-            required: true
-        },
-
-        content: {
-            type: String,
-            required: true
-        },
-     },
-    {
-        timestamps: {
-          createdAt: 'created_at',
-          updatedAt: 'updated_at'
-        }
-    }
-
-)
-
+const commentSchema = new mongoose.Schema({
+  articleId: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "Article",
+      required: true,
+    },
+  userId: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "User",
+      required: true,
+    },
+  content: {
+        type: String, 
+        required: true
+    },
+  createdAt: {
+      type: Date, 
+      default: Date.now
+    },
+  })
 const Comment = mongoose.model('Comment', commentSchema);
 export default Comment;

starter-project-backend-g32/src/models/user.models.ts

@@ -31,6 +31,7 @@ const userSchema = new Schema<IUser>({
     max: [20, "password can not be more than 20 characters"],
   },
   profilePic: String,
+
 });
 
 

starter-project-backend-g32/src/routes/article.ts

@@ -19,4 +19,4 @@ router.route("/:articleID").get(getSpecificArticle).put(updateArticle).delete(de
 router.route("/:articleID/rating").post(createRating)
 router.route("/:articleID/rating/:ratingId").get(getSpecificRating).put(updateRating)
 
-export default router
+export default router

starter-project-backend-g32/src/routes/comment.ts

@@ -8,7 +8,6 @@ commentRouter.get("/:id",getComment) // get comment by id
 commentRouter.get('/:articleid', getCommentsByArticleId) // get comments by article id
 commentRouter.post('/' , createComment); // create comment
 commentRouter.put('/:id' , updateComment); // update comment
-commentRouter.patch('/:id' , patchComment); // patch comment
 commentRouter.delete('/:id' , deleteComment); // delete comment
 
 export default commentRouter; 

starter-project-backend-g32/src/routes/upload.ts

@@ -0,0 +1,16 @@
+import { Router } from 'express'
+import upload from "../utils/multer"
+
+import {
+    deleteUserProfile, 
+    updateUserProfile, 
+    deleteArticleMedia, 
+    updateArticleMedia
+} from '../controllers/upload'
+
+const router = Router()
+
+router.route('/userProfile/:id').put(upload.single('image'),updateUserProfile).delete(deleteUserProfile)
+router.route('/articleMedia/:id').put(upload.single('image'),updateArticleMedia).delete(deleteArticleMedia)
+
+export default router

starter-project-backend-g32/src/server.ts

@@ -1,17 +1,16 @@
 import app from "./app"
 import mongoose from 'mongoose';
 
-const PORT = process.env.PORT || 8000
+const PORT = process.env.PORT || 3000
 const DB_URI = process.env.MONGO_URI || "mongodb://localhost:27017/usersdb";
+
 mongoose.connect(DB_URI, {
     useNewUrlParser: true,
     useUnifiedTopology: true,
     useCreateIndex: true,
     useFindAndModify: false,
 })
-
 .then(() => {
     app.listen(PORT, () => console.log(`Server running... ${PORT}`));
 })
-.catch((err: any) => console.log('Error occurred while connecting', err));
-
+.catch((err: any) => console.log('Error occurred while connecting', err));