Merge pull request #171 from velopert/refactor/create-post-history

refactor: postHistoryService and createPostHistory resolver

Author: winverse

src/graphql/post.ts

@@ -26,6 +26,7 @@ import { purgeRecentPosts, purgeUser, purgePost } from '../lib/graphcdn';
 import imageService from '../services/imageService';
 import externalInterationService from '../services/externalIntegrationService';
 import postService from '../services/postService';
+import postHistoryService, { CreatePostHistoryArgs } from '../services/postHistoryService';
 
 type ReadingListQueryParams = {
   type: 'LIKED' | 'READ';
@@ -166,17 +167,6 @@ type WritePostArgs = {
   token: string | null;
 };
 
-type CreatePostHistoryArgs = {
-  post_id: string;
-  title: string;
-  body: string;
-  is_markdown: boolean;
-};
-
-type EditPostArgs = WritePostArgs & {
-  id: string;
-};
-
 const slackUrl = `https://hooks.slack.com/services/${process.env.SLACK_TOKEN}`;
 
 export const resolvers: IResolvers<any, ApolloContext> = {
@@ -651,6 +641,9 @@ export const resolvers: IResolvers<any, ApolloContext> = {
     editPost: async (parent: any, args, ctx) => {
       return await postService.edit(args, ctx.cookies, ctx.ip);
     },
+    createPostHistory: async (parent: any, args, ctx) => {
+      return await postHistoryService.createPostHistory(args, ctx);
+    },
     removePost: async (parent: any, args, ctx) => {
       const { id } = args as { id: string };
       const postRepo = getRepository(Post);

src/services/postHistoryService.ts

@@ -0,0 +1,69 @@
+import { ApolloError, AuthenticationError } from 'apollo-server-koa';
+import { ApolloContext } from './../app';
+import { getRepository } from 'typeorm';
+import Post from '../entity/Post';
+import PostHistory from '../entity/PostHistory';
+import searchSync from '../search/searchSync';
+
+const postHistoryService = {
+  async createPostHistory(args: CreatePostHistoryArgs, ctx: ApolloContext) {
+    if (!ctx.user_id) {
+      throw new AuthenticationError('Not Logged In');
+    }
+
+    // check ownPost
+    const { post_id, title, body, is_markdown } = args;
+
+    const postRepo = getRepository(Post);
+    const post = await postRepo.findOne(post_id);
+
+    if (!post) {
+      throw new ApolloError('Post not found', 'NOT_FOUND');
+    }
+    if (post.fk_user_id !== ctx.user_id) {
+      throw new ApolloError('This post is not yours', 'NO_PERMISSION');
+    }
+
+    // create postHistory
+    const postHistoryRepo = getRepository(PostHistory);
+    const postHistory = new PostHistory();
+    Object.assign(postHistory, { title, body, is_markdown, fk_post_id: post_id });
+
+    await postHistoryRepo.save(postHistory);
+
+    const [data, count] = await postHistoryRepo.findAndCount({
+      where: {
+        fk_post_id: post_id,
+      },
+      order: {
+        created_at: 'DESC',
+      },
+    });
+
+    if (count > 10) {
+      await postHistoryRepo
+        .createQueryBuilder('post_history')
+        .delete()
+        .where('fk_post_id = :postId', {
+          postId: post_id,
+        })
+        .andWhere('created_at < :createdAt', { createdAt: data[9].created_at })
+        .execute();
+
+      setTimeout(() => {
+        searchSync.update(post.id).catch(console.error);
+      }, 0);
+    }
+
+    return postHistory;
+  },
+};
+
+export type CreatePostHistoryArgs = {
+  post_id: string;
+  title: string;
+  body: string;
+  is_markdown: boolean;
+};
+
+export default postHistoryService;