PR – Happy Thoughts API - Juan Z.

.gitignore

@@ -5,4 +5,5 @@ node_modules
 .env.development.local
 .env.test.local
 .env.production.local
-package-lock.json
+package-lock.json
+todo.md

controllers/deleteThought.js

@@ -0,0 +1,44 @@
+import { Thought } from "../models/thought.js"
+
+export const deleteThought = async (req, res) => {
+  const { id } = req.params
+  const userId = req.user._id
+
+  try {
+
+    const thought = await Thought.findById(id)
+
+    if (!thought) {
+      return res.status(404).json({
+        success: false,
+        response: [],
+        message: "Failed to delete thought: no thought found for the given id."
+      })
+    }
+
+    if (thought.userId.toString() !== userId.toString()) {
+      return res.status(403).json({
+        success: false,
+        response: [],
+        message: "Failed to delete thought: you are not authorized to delete this thought."
+      })
+    }
+
+    await Thought.findByIdAndDelete(id)
+
+    res.status(200).json({
+      success: true,
+      response: [],
+      message: "Thought deleted successfully."
+    })
+
+  } catch (error) {
+
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to delete thought. Please try again later."
+    })
+
+  }
+}

controllers/getThought.js

@@ -0,0 +1,31 @@
+import { Thought } from "../models/thought.js"
+
+export const getThought = async (req, res) => {
+  const { id } = req.params
+
+  try {
+    const thought = await Thought.findById(id)
+
+    if (!thought) {
+      return res.status(404).json({
+        success: false,
+        response: [],
+        message: "No thought found for the given id. Please try again with a different id."
+      })
+    }
+
+    res.status(200).json({
+      success: true,
+      response: thought,
+      message: "Success."
+    })
+  }
+
+  catch (error) {
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to fetch thought. Please try again later."
+    })
+  }
+}

controllers/getThoughts.js

@@ -0,0 +1,34 @@
+import { Thought } from "../models/thought.js"
+
+export const getThoughts = async (req, res) => {
+  const { hearts } = req.query;
+  const query = {}
+
+  if (hearts) {
+    query.hearts = hearts
+  }
+
+  try {
+    const filteredThoughts = await Thought.find(query)
+
+    if (filteredThoughts.length === 0) {
+      return res.status(404).json({
+        success: false,
+        response: [],
+        message: "No thoughts found for given query. Please try again with a different query"
+      })
+    }
+    res.status(200).json({
+      success: true,
+      response: filteredThoughts,
+      message: "Success"
+    })
+
+  } catch (error) {
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Failed to fetch thoughts"
+    })
+  }
+}

controllers/getUserData.js

@@ -0,0 +1,31 @@
+import { User } from "../models/user.js"
+
+export const getUserData = async (req, res) => {
+  try {
+
+    const user = req.user
+
+    if (!user) {
+      return res.status(404).json({
+        success: false,
+        response: [],
+        message: "Failed to get user data: no user found for the given id."
+      })
+    }
+
+    res.status(200).json({
+      success: true,
+      response: { name: user.name },
+      message: "Success"
+    })
+
+  } catch (error) {
+
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to get user data. Please try again later."
+    })
+
+  }
+}

controllers/loginUser.js

@@ -0,0 +1,44 @@
+import bcrypt from "bcrypt"
+import jwt from "jsonwebtoken"
+import { User } from "../models/user.js"
+
+export const loginUser = async (req, res) => {
+  const { email, password } = req.body
+
+  try {
+    const user = await User.findOne({ email })
+
+    if (!user || !bcrypt.compareSync(password, user.password)) {
+      return res.status(401).json({
+        success: false,
+        response: [],
+        message: "Failed to log in: invalid email or password."
+      })
+    }
+
+    const accessToken = jwt.sign(
+      { userId: user._id },
+      process.env.JWT_SECRET,
+      { expiresIn: process.env.JWT_EXPIRES_IN}
+    )
+
+    res.status(200).json({
+      success: true,
+      response: {
+        accessToken,
+        name: user.name,
+        userId: user._id
+      },
+      message: "Log in successful."
+    })
+
+} catch (error) {
+
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to log in. Please try again later."
+    })
+
+  }
+}

controllers/patchThought.js

@@ -0,0 +1,45 @@
+import { Thought } from "../models/thought.js"
+
+export const patchThought = async (req, res) => {
+  const { id } = req.params
+  const { updatedMessage } = req.body
+  const userId = req.user._id
+
+  try {
+    const thought = await Thought.findById(id)
+
+    if (!thought) {
+      return res.status(404).json({
+        success: false,
+        response: [],
+        message: "Failed to update thought: no thought found for given id."
+      })
+    }
+
+    if (thought.userId.toString() !== userId.toString()) {
+      return res.status(403).json({
+        success: false,
+        response: [],
+        message: "Failed to update thought: you are not authorized to update this thought."
+      })
+    }
+
+    thought.message = updatedMessage
+    await thought.save()
+
+    res.status(200).json({
+      success: true,
+      response: thought,
+      message: "Thought updated successfully."
+    })
+
+  } catch (error) {
+
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to update thought. Please try again later."
+    })
+
+  }
+}

controllers/patchThoughtLikes.js

@@ -0,0 +1,46 @@
+import { Thought } from "../models/thought.js"
+
+export const patchThoughtLikes = async (req, res) => {
+  const { id } = req.params
+  const userId = req.user._id
+
+  try {
+
+    const thought = await Thought.findById(id)
+
+    if (!thought) {
+      return res.status(404).json({
+        success: false,
+        response: [],
+        message: "No thought found for the given id. Please try again with a different id."
+      })
+    }
+
+    const hasLiked = thought.likes.includes(userId)
+
+    if (hasLiked) {
+      // remove like
+      thought.likes = thought.likes.filter(like => like.toString() !== userId.toString())
+    } else {
+      // add like
+      thought.likes.push(userId)
+    }
+
+    await thought.save()
+
+    res.status(200).json({
+      success: true,
+      response: thought,
+      message: "Likes updated successfully."
+    })
+
+  } catch (error) {
+
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to update likes. Please try again later."
+    })
+
+  }
+}

controllers/postThought.js

@@ -0,0 +1,33 @@
+import { Thought } from "../models/thought.js"
+
+export const postThought = async (req, res) => {
+  const { message } = req.body
+  const user = req.user
+
+  try {
+    const newThought = await new Thought({ message, userId: user._id }).save()
+
+    if (!newThought) {
+      return res.status(400).json({
+        success: false,
+        response: [],
+        message: "Failed to post thought."
+      })
+    }
+
+    res.status(201).json({
+      success: true,
+      response: newThought,
+      message: "Thought posted successfully."
+    })
+
+  } catch (error) {
+
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to post thought. Please try again later."
+    })
+
+  }
+}

controllers/postUser.js

@@ -0,0 +1,40 @@
+import bcrypt from "bcrypt"
+import jwt from "jsonwebtoken"
+import { User } from "../models/user.js"
+
+export const postUser = async (req, res) => {
+  try {
+
+    const { name, email, password } = req.body
+
+    const salt = bcrypt.genSaltSync()
+    const hashedPassword = bcrypt.hashSync(password, salt)
+
+    const newUser = await new User({ name, email, password: hashedPassword }).save()
+
+    const accessToken = jwt.sign(
+      { userId: newUser._id },
+      process.env.JWT_SECRET,
+      { expiresIn: process.env.JWT_EXPIRES_IN }
+    )
+
+    res.status(201).json({
+      success: true,
+      response: { 
+        userId: newUser._id, 
+        name: newUser.name,
+        accessToken
+      },
+      message: "User registered successfully."
+    })
+
+  } catch (error) {
+
+    res.status(500).json({
+      success: false,
+      response: error,
+      message: "Internal server error: failed to register user. Please try again later."
+    })
+
+  }
+}