Merge pull request #105 from Mouwf/feature/add-reply-function

リプライ機能を追加した
Mouwf · Mar 11, 2024 · 4170dd5 · 4170dd5
2 parents aa442f0 + 658846c
commit 4170dd5
Show file tree

Hide file tree

Showing 82 changed files with 3,897 additions and 298 deletions.
diff --git a/app/actions/post/reply-message-action.ts b/app/actions/post/reply-message-action.ts
@@ -0,0 +1,27 @@
+import PostInteractor from "../../libraries/post/post-interactor";
+
+/**
+ * リプライを行うアクション。
+ */
+export default class ReplyMessageAction {
+    /**
+     * リプライを行うアクションを生成する。
+     * @param postInteractor 投稿に関する処理を行うクラス。
+     */
+    constructor(
+        private readonly postInteractor: PostInteractor,
+    ) {
+    }
+
+    /**
+     * リプライを行う。
+     * @param replierId リプライ者ID。
+     * @param originalPostId リプライ先投稿ID。
+     * @param originalReplyId リプライ先リプライID。
+     * @param content リプライ内容。
+     */
+    public async reply(replierId: number, originalPostId: number, originalReplyId: number | null, content: string): Promise<number> {
+        const replyId = await this.postInteractor.reply(replierId, originalPostId, originalReplyId, content);
+        return replyId;
+    }
+}
diff --git a/app/dependency-injector/production-app-load-context.ts b/app/dependency-injector/production-app-load-context.ts
@@ -9,14 +9,22 @@ import UserProfileManager from "../libraries/user/user-profile-manager";
 import PostgresClientProvider from "../repositories/common/postgres-client-provider";
 import PostgresUserRepository from "../repositories/user/postgres-user-repository";
 import LatestPostsLoader from "../loaders/post/latest-posts-loader";
+import PostLoader from "../loaders/post/post-loader";
+import RepliesLoader from "../loaders/post/replies-loader";
+import ReplyLoader from "../loaders/post/reply-loader";
 import FirebaseClient from "../libraries/authentication/firebase-client";
 import ReleaseInformationGetter from "../libraries/post/release-information-getter";
 import ReleaseInformationLoader from "../loaders/post/release-information-loader";
 import PostgresReleaseInformationRepository from "../repositories/post/postgres-release-information-repository";
 import PostgresPostContentRepository from "../repositories/post/postgres-post-content-repository";
+import PostgresReplyContentRepository from "../repositories/post/postgres-reply-content-repository";
 import PostInteractor from "../libraries/post/post-interactor";
 import PostMessageAction from "../actions/post/post-message-action";
+import ReplyMessageAction from "../actions/post/reply-message-action";
 import PostsFetcher from "../libraries/post/posts-fetcher";
+import PostFetcher from "../libraries/post/post-fetcher";
+import RepliesFetcher from "../libraries/post/replies-fetcher";
+import ReplyFetcher from "../libraries/post/reply-fetcher";
 import UserSettingAction from "../actions/user/user-setting-action";
 import UserSettingLoader from "../loaders/user/user-setting-loader";
 
@@ -44,12 +52,20 @@ const userSettingLoader = new UserSettingLoader(userProfileManager);
 
 // メッセージを投稿するためのクラスを生成する。
 const postContentRepository = new PostgresPostContentRepository(postgresClientProvider);
-const postInteractor = new PostInteractor(postContentRepository);
+const replyContentRepository = new PostgresReplyContentRepository(postgresClientProvider);
+const postInteractor = new PostInteractor(postContentRepository, replyContentRepository);
 const postMessageAction = new PostMessageAction(postInteractor);
+const replyMessageAction = new ReplyMessageAction(postInteractor);
 
 // 最新の投稿を取得するためのクラスを生成する。
 const postsFetcher = new PostsFetcher(postContentRepository);
 const latestPostsLoader = new LatestPostsLoader(postsFetcher);
+const postFetcher = new PostFetcher(postContentRepository);
+const postLoader = new PostLoader(postFetcher);
+const repliesFetcher = new RepliesFetcher(replyContentRepository);
+const repliesLoader = new RepliesLoader(repliesFetcher);
+const replyFetcher = new ReplyFetcher(replyContentRepository);
+const replyLoader = new ReplyLoader(replyFetcher);
 
 // リリース情報を取得するためのクラスを生成する。
 const releaseInformationRepository = new PostgresReleaseInformationRepository(postgresClientProvider);
@@ -64,6 +80,10 @@ export const productionAppLoadContext: AppLoadContext = {
     authenticatedUserLoader,
     userSettingLoader,
     latestPostsLoader,
+    postLoader,
+    repliesLoader,
+    replyLoader,
     releaseInformationLoader,
     postMessageAction,
+    replyMessageAction,
 };
diff --git a/app/libraries/post/post-fetcher.ts b/app/libraries/post/post-fetcher.ts
@@ -0,0 +1,33 @@
+import systemMessages from "../../messages/system-messages";
+import PostContent from '../../models/post/post-content';
+import IPostContentRepository from '../../repositories/post/i-post-content-repository';
+
+/**
+ * 投稿を取得するクラス。
+ */
+export default class PostFetcher {
+    /**
+     * 投稿を取得するクラスを生成する。
+     * @param postContentRepository 投稿を取得するリポジトリ。
+     */
+    constructor(
+        private readonly postContentRepository: IPostContentRepository,
+    ) {
+    }
+
+    /**
+     * 指定された投稿を取得する。
+     * @param postId 投稿ID。
+     * @returns 取得した投稿。
+     */
+    public async fetchPostById(postId: number): Promise<PostContent> {
+        try {
+            const post = await this.postContentRepository.getById(postId);
+            return post;
+        } catch (error) {
+            console.error(error);
+            if (error instanceof TypeError) throw new Error(systemMessages.error.networkError);
+            throw new Error(systemMessages.error.postRetrievalFailed);
+        }
+    }
+}
diff --git a/app/libraries/post/post-interactor.ts b/app/libraries/post/post-interactor.ts
@@ -1,5 +1,6 @@
 import systemMessages from "../../messages/system-messages";
-import IPostContentRepository from '../../repositories/post/i-post-content-repository';
+import IPostContentRepository from "../../repositories/post/i-post-content-repository";
+import IReplyContentRepository from "../../repositories/post/i-reply-content-repository";
 
 /**
  * 投稿に関する処理を行うクラス。
@@ -8,9 +9,11 @@ export default class PostInteractor {
     /**
      * 投稿に関する処理を行うクラスを生成する。
      * @param postContentRepository 投稿内容リポジトリ。
+     * @param replyContentRepository リプライ内容リポジトリ。
      */
     constructor(
         private readonly postContentRepository: IPostContentRepository,
+        private readonly replyContentRepository: IReplyContentRepository,
     ) {
     }
 
@@ -31,4 +34,22 @@ export default class PostInteractor {
             throw new Error(systemMessages.error.postFailed);
         }
     }
+
+    /**
+     * リプライを行う。
+     * @param replierId リプライ者ID。
+     * @param originalPostId リプライ先投稿ID。
+     * @param originalReplyId リプライ先リプライID。
+     * @param content リプライ内容。
+     */
+    public async reply(replierId: number, originalPostId: number, originalReplyId: number | null, content: string): Promise<number> {
+        try {
+            const replyId = await this.replyContentRepository.create(replierId, originalPostId, originalReplyId, content);
+            return replyId;
+        } catch (error) {
+            console.error(error);
+            if (error instanceof TypeError) throw new Error(systemMessages.error.networkError);
+            throw new Error(systemMessages.error.replyFailed);
+        }
+    }
 }
diff --git a/app/libraries/post/posts-fetcher.ts b/app/libraries/post/posts-fetcher.ts
@@ -3,11 +3,11 @@ import PostContent from '../../models/post/post-content';
 import IPostContentRepository from '../../repositories/post/i-post-content-repository';
 
 /**
- * 投稿を取得するクラス。
+ * 複数の投稿を取得するクラス。
  */
 export default class PostsFetcher {
     /**
-     * 投稿を取得するクラスを生成する。
+     * 複数の投稿を取得するクラスを生成する。
      * @param postContentRepository 投稿を取得するリポジトリ。
      */
     constructor(

diff --git a/app/libraries/post/replies-fetcher.ts b/app/libraries/post/replies-fetcher.ts
@@ -0,0 +1,34 @@
+import systemMessages from "../../messages/system-messages";
+import ReplyContent from "../../models/post/reply-content";
+import IReplyContentRepository from "../../repositories/post/i-reply-content-repository";
+
+
+/**
+ * 複数のリプライを取得するクラス。
+ */
+export default class RepliesFetcher {
+    /**
+     * 複数のリプライを取得するクラスを生成する。
+     * @param replyContentRepository リプライ内容リポジトリ。
+     */
+    constructor(
+        private readonly replyContentRepository: IReplyContentRepository,
+    ) {
+    }
+
+    /**
+     * 指定された投稿の全てのリプライを取得する。
+     * @param postId 投稿ID。
+     * @returns 指定された投稿の全てのリプライ。
+     */
+    public async fetchAllByPostId(postId: number): Promise<ReplyContent[]> {
+        try {
+            const replies = await this.replyContentRepository.getAllByPostId(postId);
+            return replies;
+        } catch (error) {
+            console.error(error);
+            if (error instanceof TypeError) throw new Error(systemMessages.error.networkError);
+            throw new Error(systemMessages.error.replyRetrievalFailed);
+        }
+    }
+}
diff --git a/app/libraries/post/reply-fetcher.ts b/app/libraries/post/reply-fetcher.ts
@@ -0,0 +1,33 @@
+import systemMessages from "../../messages/system-messages";
+import ReplyContent from "../../models/post/reply-content";
+import IReplyContentRepository from "../../repositories/post/i-reply-content-repository";
+
+/**
+ * リプライを取得するクラス。
+ */
+export default class ReplyFetcher {
+    /**
+     * リプライを取得するクラスを生成する。
+     * @param replyContentRepository リプライ内容リポジトリ。
+     */
+    constructor(
+        private readonly replyContentRepository: IReplyContentRepository,
+    ) {
+    }
+
+    /**
+     * 指定されたリプライを取得する。
+     * @param replyId リプライID。
+     * @returns 取得したリプライ。
+     */
+    public async fetchReplyById(replyId: number): Promise<ReplyContent> {
+        try {
+            const reply = await this.replyContentRepository.getById(replyId);
+            return reply;
+        } catch (error) {
+            console.error(error);
+            if (error instanceof TypeError) throw new Error(systemMessages.error.networkError);
+            throw new Error(systemMessages.error.replyRetrievalFailed);
+        }
+    }
+}
diff --git a/app/loaders/post/latest-posts-loader.ts b/app/loaders/post/latest-posts-loader.ts
@@ -8,7 +8,7 @@ import PostContent from "../../models/post/post-content";
 export default class LatestPostsLoader extends PostFetchLimit {
     /**
      * 最新の投稿を取得するローダーを生成する。
-     * @param postsFetcher 投稿を取得するクラス。
+     * @param postsFetcher 複数の投稿を取得するクラス。
      */
     constructor(
         private readonly postsFetcher: PostsFetcher,

diff --git a/app/loaders/post/post-loader.ts b/app/loaders/post/post-loader.ts
@@ -0,0 +1,26 @@
+import PostFetcher from "../../libraries/post/post-fetcher";
+import PostContent from "../../models/post/post-content";
+
+/**
+ * 投稿を取得するローダー。
+ */
+export default class PostLoader {
+    /**
+     * 投稿を取得するローダーを生成する。
+     * @param postFetcher 投稿を取得するクラス。
+     */
+    constructor(
+        private readonly postFetcher: PostFetcher,
+    ) {
+    }
+
+    /**
+     * 指定された投稿を取得する。
+     * @param postId 投稿ID。
+     * @returns 取得した投稿。
+     */
+    public async getPostById(postId: number): Promise<PostContent> {
+        const post = await this.postFetcher.fetchPostById(postId);
+        return post;
+    }
+}
diff --git a/app/loaders/post/replies-loader.ts b/app/loaders/post/replies-loader.ts
@@ -0,0 +1,26 @@
+import RepliesFetcher from "../../libraries/post/replies-fetcher";
+import ReplyContent from "../../models/post/reply-content";
+
+/**
+ * 指定された投稿の全てのリプライを取得するローダー。
+ */
+export default class RepliesLoader {
+    /**
+     * 指定された投稿の全てのリプライを取得するローダーを生成する。
+     * @param repliesFetcher 複数のリプライを取得するクラス。
+     */
+    constructor(
+        private readonly repliesFetcher: RepliesFetcher,
+    ) {
+    }
+
+    /**
+     * 指定された投稿の全てのリプライを取得する。
+     * @param postId 投稿ID。
+     * @returns 指定された投稿の全てのリプライ。
+     */
+    public async getAllRepliesByPostId(postId: number): Promise<ReplyContent[]> {
+        const replies = await this.repliesFetcher.fetchAllByPostId(postId);
+        return replies;
+    }
+}
diff --git a/app/loaders/post/reply-loader.ts b/app/loaders/post/reply-loader.ts
@@ -0,0 +1,26 @@
+import ReplyFetcher from "../../libraries/post/reply-fetcher";
+import ReplyContent from "../../models/post/reply-content";
+
+/**
+ * リプライを取得するローダー。
+ */
+export default class ReplyLoader {
+    /**
+     * リプライを取得するローダーを生成する。
+     * @param replyFetcher リプライを取得するクラス。
+     */
+    constructor(
+        private readonly replyFetcher: ReplyFetcher,
+    ) {
+    }
+
+    /**
+     * 指定されたリプライを取得する。
+     * @param replyId リプライID。
+     * @returns 取得したリプライ。
+     */
+    public async getReplyById(replyId: number): Promise<ReplyContent> {
+        const reply = await this.replyFetcher.fetchReplyById(replyId);
+        return reply;
+    }
+}
diff --git a/app/messages/system-messages.ts b/app/messages/system-messages.ts
@@ -36,13 +36,20 @@ const systemMessages: Messages = {
         userSettingRetrievalFailed: "ユーザー設定の取得に失敗しました。",
         postContentNotInputted: "投稿内容が入力されていません。",
         postFailed: "投稿に失敗しました。",
+        postNotExists: "投稿が存在しません。",
         postRetrievalFailed: "投稿の取得に失敗しました。",
         postDeletionFailed: "投稿の削除に失敗しました。",
         releaseInformationRetrievalFailed: "リリース情報の取得に失敗しました。",
         releaseInformationNotExists: "リリース情報が存在しません。",
+        replyContentNotInputted: "リプライ内容が入力されていません。",
+        replyFailed: "リプライに失敗しました。",
+        replyNotExists: "リプライが存在しません。",
+        replyRetrievalFailed: "リプライの取得に失敗しました。",
+        replyDeletionFailed: "リプライの削除に失敗しました。",
     },
     success: {
         userSettingSaved: "ユーザー設定を保存しました。",
+        replyMessagePosted: "返信しました。",
     },
 }
 export default systemMessages;
diff --git a/app/models/post/post-content.ts b/app/models/post/post-content.ts
@@ -29,6 +29,11 @@ export default interface PostContent extends Entity {
      */
     readonly releaseName: string;
 
+    /**
+     * リプライ数。
+     */
+    readonly replyCount: number;
+
     /**
      * 投稿内容。
      */