Feat/fecth posts for specific thread (#184)

* Added PostController

* Added post module

* added list posts by thread query

* fixed lint errors

* resolved PR comments

Author: gnoulelem

src/api/rest/posts/v1/controller/index.ts

@@ -0,0 +1 @@
+export * from './post.controller';

src/api/rest/posts/v1/controller/post.controller.ts

@@ -0,0 +1,17 @@
+import { Controller, Get, Param, Query } from '@nestjs/common';
+import { ApiTags } from '@nestjs/swagger';
+import { ICQRSHandler } from '@common/cqrs';
+import { PaginationDto } from '@infrastructure/pagination';
+import { ListPostsByThreadQuery } from '@modules/post/cqrs/query/list-posts-by-thread.query';
+
+@Controller('v1/posts')
+@ApiTags('Posts')
+export class PostController {
+    constructor(private readonly cqrsHandler: ICQRSHandler) {}
+
+    @Get(':threadId')
+    async getPostsByThread(@Param('threadId') threadId: string, @Query() { page, pageSize }: PaginationDto) {
+        const foundPosts = await this.cqrsHandler.fetch(ListPostsByThreadQuery, { page, pageSize, filter: { threadId } });
+        return { pageInfo: foundPosts.pageInfo, items: foundPosts.items };
+    }
+}

src/api/rest/rest.module.ts

@@ -12,6 +12,7 @@ import { AuthenticationController } from './auth';
 import { ContactController } from './contact';
 import { ThreadController } from './threads';
 import { ForumController } from './forum/v1/controller';
+import { PostController } from './posts/v1/controller';
 
 @Module({
     imports: [InfrastructureModule, CQRSModule],
@@ -24,6 +25,7 @@ import { ForumController } from './forum/v1/controller';
         ThreadController,
         ContactController,
         ForumController,
+        PostController,
     ],
     providers: [CrowdActionService, ProfileService, AuthService],
     exports: [CrowdActionService, ProfileService, AuthService],

src/domain/post/entity/post.entity.ts

@@ -13,4 +13,20 @@ export class Post implements IPost {
     readonly subject: string;
     readonly message: string;
     readonly visible: boolean;
+
+    constructor(entityLike: IPost) {
+        this.id = entityLike.id;
+        this.threadId = entityLike.threadId;
+        this.forumId = entityLike.forumId;
+        this.author = entityLike.author;
+        this.createdAt = entityLike.createdAt;
+        this.updatedAt = entityLike.updatedAt;
+        this.subject = entityLike.subject;
+        this.message = entityLike.message;
+        this.visible = entityLike.visible;
+    }
+
+    static create(entityLike: Post): Post {
+        return new Post(entityLike);
+    }
 }

src/domain/post/entity/reported-post.entity.ts

@@ -15,4 +15,8 @@ export class ReportedPost implements IPost {
     readonly reason: string;
     readonly handledById?: string;
     readonly status: ReportStatusEnum;
+
+    readonly subject: string;
+    readonly message: string;
+    readonly visible: boolean;
 }

src/domain/post/interface/index.ts

@@ -1 +1,2 @@
 export * from './post.interface';
+export * from './post-repository.interface';

src/domain/post/interface/post-repository.interface.ts

@@ -0,0 +1,15 @@
+import { FindCriteria, IRepository } from '@core/repository.interface';
+import { Post } from '../entity';
+import { IPost } from './post.interface';
+
+export type CreatePost = Omit<IPost, 'id' | 'createdAt' | 'updatedAt'>;
+export type PatchPost = Partial<IPost>;
+export type QueryPost = Partial<Pick<IPost, 'id' | 'threadId'>>;
+
+export abstract class IPostRepository implements IRepository<Post, CreatePost, PatchPost, QueryPost> {
+    abstract findAll(query: FindCriteria<QueryPost>): Promise<Post[]>;
+    abstract create(entityLike: CreatePost): Promise<Post>;
+    abstract patch(id: string, entityLike: PatchPost): Promise<void>;
+    abstract delete(id: string): Promise<void>;
+    abstract findOne(query: FindCriteria<QueryPost>): Promise<Post>;
+}

src/domain/post/interface/post.interface.ts

@@ -7,4 +7,8 @@ export interface IPost {
     readonly author: IUserInfo;
     readonly createdAt: Date;
     readonly updatedAt: Date;
+
+    readonly subject: string;
+    readonly message: string;
+    readonly visible: boolean;
 }

src/infrastructure/mongo/mongo.module.ts

@@ -25,6 +25,7 @@ import {
     ThreadRepository,
     ForumPermissionRepository,
     ForumRepository,
+    PostRepsotory,
 } from '@infrastructure/mongo/repository';
 import { ICrowdActionRepository } from '@domain/crowdaction';
 import { IProfileRepository } from '@domain/profile';
@@ -33,7 +34,9 @@ import { IContactRepository } from '@domain/contact';
 import { ICommitmentRepository } from '@domain/commitment';
 import { IForumPermissionRepository, IForumRepository } from '@domain/forum';
 import { IThreadRepository } from '@domain/thread';
+import { IPostRepository } from '@domain/post';
 import { ContactPersistence, ContactSchema } from './persistence/contact.persistence';
+import { PostPersistence, PostSchema } from './persistence/post.persistence';
 
 @Module({
     imports: [
@@ -46,6 +49,7 @@ import { ContactPersistence, ContactSchema } from './persistence/contact.persist
             { name: ForumPersistence.name, schema: ForumSchema },
             { name: ThreadPersistence.name, schema: ThreadSchema },
             { name: ForumPermissionPersistence.name, schema: ForumPermissionSchema },
+            { name: PostPersistence.name, schema: PostSchema },
         ]),
     ],
     providers: [
@@ -81,6 +85,10 @@ import { ContactPersistence, ContactSchema } from './persistence/contact.persist
             provide: IForumPermissionRepository,
             useClass: ForumPermissionRepository,
         },
+        {
+            provide: IPostRepository,
+            useClass: PostRepsotory,
+        },
     ],
     exports: [
         ICrowdActionRepository,
@@ -91,6 +99,7 @@ import { ContactPersistence, ContactSchema } from './persistence/contact.persist
         IForumRepository,
         IThreadRepository,
         IForumPermissionRepository,
+        IPostRepository,
     ],
 })
 export class MongoModule {}

src/infrastructure/mongo/persistence/reported-post.persistence.ts

@@ -28,5 +28,14 @@ export class ReportedPostPersistence implements Omit<IPost, 'id' | 'createdAt' |
 
     @Prop({ enum: ReportStatusEnum, required: true })
     readonly status: ReportStatusEnum;
+
+    @Prop({ required: false })
+    readonly subject: string;
+
+    @Prop({ required: false })
+    readonly message: string;
+
+    @Prop({ required: false })
+    readonly visible: boolean;
 }
 export const ReportedPostSchema = SchemaFactory.createForClass(ReportedPostPersistence);