feat: createComment/getComments method implemented

Author: hyeon-z

src/index.js

@@ -1,15 +1,27 @@
-const { ApolloServer } = require("apollo-server");
-const queries = require("./typedefs-resolvers/_queries");
-const dotenv = require("dotenv");
-const { posts, users } = require("./typedefs-resolvers");
-const connectDB = require("./loaders/db");
+const { ApolloServer } = require('apollo-server');
+const queries = require('./typedefs-resolvers/_queries');
+const mutations = require('./typedefs-resolvers/_mutations');
+const dotenv = require('dotenv');
+const { posts, users, comments } = require('./typedefs-resolvers');
+const connectDB = require('./loaders/db');
 
 dotenv.config();
 connectDB();
 
-const typeDefs = [queries, posts.typeDefs, users.typeDefs];
-const resolvers = [posts.resolvers, users.resolvers];
-const server = new ApolloServer({ typeDefs, resolvers, introspection: true, playground: true });
+const typeDefs = [
+  queries,
+  mutations,
+  users.typeDefs,
+  posts.typeDefs,
+  comments.typeDefs,
+];
+const resolvers = [users.resolvers, posts.resolvers, comments.resolvers];
+const server = new ApolloServer({
+  typeDefs,
+  resolvers,
+  introspection: true,
+  playground: true,
+});
 
 server.listen().then(({ url }) => {
   console.log(`server ready at ${url}`);

src/models/Comment.js

@@ -1,17 +1,27 @@
-const mongoose = require("mongoose");
+const mongoose = require('mongoose');
 
 const CommentSchema = new mongoose.Schema(
-    {
-        content: {
-            type: String,
-            required: true
-        },
-        parent: {
-            type: mongoose.Types.ObjectId,
-            ref: "Comment"
-        }
+  {
+    content: {
+      type: String,
+      required: true,
     },
-    { timestamps: true }
+    parent: {
+      type: mongoose.Types.ObjectId,
+      ref: 'Comment',
+    },
+    post: {
+      type: mongoose.Types.ObjectId,
+      required: true,
+      ref: 'Post',
+    },
+    writer: {
+      type: mongoose.Types.ObjectId,
+      required: true,
+      ref: 'User',
+    },
+  },
+  { timestamps: true }
 );
 
-module.exports = mongoose.model("Comment", CommentSchema);
+module.exports = mongoose.model('Comment', CommentSchema);

src/services/commentService.js

@@ -0,0 +1,53 @@
+const Comment = require('../models/Comment');
+const dayjs = require('dayjs');
+
+const createComment = async (args) => {
+  try {
+    const { content, post, parent, writer } = args.comment;
+    const comment = new Comment({
+      content: content,
+      post: post,
+      parent: parent,
+      writer: writer,
+    });
+
+    await comment.save();
+
+    return comment;
+  } catch (error) {
+    console.log(error);
+    throw error;
+  }
+};
+
+const getComments = async (postId) => {
+  try {
+    const comments = await Comment.find({
+      post: postId,
+      // parent: null,
+    })
+      .populate('post')
+      .populate('writer')
+      .sort({ createdAt: -1 });
+
+    const data = await Promise.all(
+      comments.map((comment) => {
+        const result = {
+          _id: comment._id,
+          writer: comment.writer.name,
+          writerProfile: comment.writer.intro,
+          content: comment.content,
+          date: `${dayjs(new Date()).diff(comment.createdAt, 'hour')}`,
+        };
+        return result;
+      })
+    );
+
+    return data;
+  } catch (error) {
+    console.log(error);
+    throw error;
+  }
+};
+
+module.exports = { createComment, getComments };

src/services/index.js

@@ -1,3 +1,4 @@
-const postService = require("./postService")
-const userService = require("./userService")
-module.exports = { postService, userService }
+const postService = require('./postService');
+const userService = require('./userService');
+const commentService = require('./commentService');
+module.exports = { postService, userService, commentService };

src/typedefs-resolvers/_mutations.js

@@ -0,0 +1,9 @@
+const { gql } = require('apollo-server');
+
+const typeDefs = gql`
+  type Mutation {
+    createComment(comment: CreateCommentInput!): Comment!
+  }
+`;
+
+module.exports = typeDefs;

src/typedefs-resolvers/_queries.js

@@ -1,10 +1,10 @@
-const { gql } = require("apollo-server");
+const { gql } = require('apollo-server');
 
 const typeDefs = gql`
   type Query {
     posts: Post
-
     users(_id: ID): [User]
+    comments(_id: ID): [ResponseComment!]
   }
 `;
 

src/typedefs-resolvers/comments.js

@@ -0,0 +1,44 @@
+const { gql } = require('apollo-server');
+const { commentService } = require('../services');
+
+const typeDefs = gql`
+  type Comment {
+    _id: ID!
+    content: String!
+    post: ID!
+    parent: ID
+    writer: ID!
+  }
+
+  type ResponseComment {
+    _id: ID!
+    writer: ID!
+    writerProfile: String!
+    content: String!
+    """
+    현재시간과 댓글을 올린 시간의 차이
+    """
+    date: String!
+  }
+
+  input CreateCommentInput {
+    content: String!
+    post: ID!
+    parent: ID
+    writer: ID!
+  }
+`;
+
+const resolvers = {
+  Query: {
+    comments: async (_, args) => await commentService.getComments(args._id),
+  },
+  Mutation: {
+    createComment: async (_, args) => await commentService.createComment(args),
+  },
+};
+
+module.exports = {
+  typeDefs: typeDefs,
+  resolvers: resolvers,
+};

src/typedefs-resolvers/index.js

@@ -1,3 +1,4 @@
-const posts = require("./posts");
-const users = require("./users");
-module.exports = { posts, users };
+const posts = require('./posts');
+const users = require('./users');
+const comments = require('./comments');
+module.exports = { posts, users, comments };

yarn.lock

@@ -269,6 +269,11 @@
   resolved "https://registry.npmjs.org/@types/node/-/node-10.17.60.tgz"
   integrity sha512-F0KIgDJfy2nA3zMLmWGKxcH2ZVEtCZXHHdOQs2gSaQ27+lNeEfGxzkIw90aXswATX7AZ33tahPbzy6KAfUreVw==
 
+"@types/node@^14.11.2":
+  version "14.18.21"
+  resolved "https://registry.yarnpkg.com/@types/node/-/node-14.18.21.tgz#0155ee46f6be28b2ff0342ca1a9b9fd4468bef41"
+  integrity sha512-x5W9s+8P4XteaxT/jKF0PSb7XEvo5VmqEWgsMlyeY4ZlLK8I6aH6g5TPPyDlLAep+GYf4kefb7HFyc7PAO3m+Q==
+
 "@types/qs@*":
   version "6.9.7"
   resolved "https://registry.npmjs.org/@types/qs/-/qs-6.9.7.tgz"