fix(): create separate files for command and queries

Author: NarHakobyan

src/modules/post/commands/create-post.command.ts

@@ -1,56 +1,10 @@
-import type { ICommand, ICommandHandler } from '@nestjs/cqrs';
-import { CommandHandler } from '@nestjs/cqrs';
-import { InjectRepository } from '@nestjs/typeorm';
-import { Repository } from 'typeorm';
+import type { ICommand } from '@nestjs/cqrs';
 
 import type { CreatePostDto } from '../dtos/create-post.dto.ts';
-import { PostEntity } from '../post.entity.ts';
-import { PostTranslationEntity } from '../post-translation.entity.ts';
 
 export class CreatePostCommand implements ICommand {
   constructor(
     public readonly userId: Uuid,
     public readonly createPostDto: CreatePostDto,
   ) {}
 }
-
-@CommandHandler(CreatePostCommand)
-export class CreatePostHandler
-  implements ICommandHandler<CreatePostCommand, PostEntity>
-{
-  constructor(
-    @InjectRepository(PostEntity)
-    private postRepository: Repository<PostEntity>,
-    @InjectRepository(PostTranslationEntity)
-    private postTranslationRepository: Repository<PostTranslationEntity>,
-  ) {}
-
-  async execute(command: CreatePostCommand) {
-    const { userId, createPostDto } = command;
-    const postEntity = this.postRepository.create({ userId });
-    const translations: PostTranslationEntity[] = [];
-
-    await this.postRepository.save(postEntity);
-
-    // FIXME: Create generic function for translation creation
-    for (const createTranslationDto of createPostDto.title) {
-      const languageCode = createTranslationDto.languageCode;
-      const translationEntity = this.postTranslationRepository.create({
-        postId: postEntity.id,
-        languageCode,
-        title: createTranslationDto.text,
-        description: createPostDto.description.find(
-          (desc) => desc.languageCode === languageCode,
-        )!.text,
-      });
-
-      translations.push(translationEntity);
-    }
-
-    await this.postTranslationRepository.save(translations);
-
-    postEntity.translations = translations;
-
-    return postEntity;
-  }
-}

src/modules/post/commands/create-post.handler.ts

@@ -0,0 +1,49 @@
+import type { ICommandHandler } from '@nestjs/cqrs';
+import { CommandHandler } from '@nestjs/cqrs';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+
+import { PostEntity } from '../post.entity.ts';
+import { PostTranslationEntity } from '../post-translation.entity.ts';
+import { CreatePostCommand } from './create-post.command.ts';
+
+@CommandHandler(CreatePostCommand)
+export class CreatePostHandler
+  implements ICommandHandler<CreatePostCommand, PostEntity>
+{
+  constructor(
+    @InjectRepository(PostEntity)
+    private postRepository: Repository<PostEntity>,
+    @InjectRepository(PostTranslationEntity)
+    private postTranslationRepository: Repository<PostTranslationEntity>,
+  ) {}
+
+  async execute(command: CreatePostCommand) {
+    const { userId, createPostDto } = command;
+    const postEntity = this.postRepository.create({ userId });
+    const translations: PostTranslationEntity[] = [];
+
+    await this.postRepository.save(postEntity);
+
+    // FIXME: Create generic function for translation creation
+    for (const createTranslationDto of createPostDto.title) {
+      const languageCode = createTranslationDto.languageCode;
+      const translationEntity = this.postTranslationRepository.create({
+        postId: postEntity.id,
+        languageCode,
+        title: createTranslationDto.text,
+        description: createPostDto.description.find(
+          (desc) => desc.languageCode === languageCode,
+        )!.text,
+      });
+
+      translations.push(translationEntity);
+    }
+
+    await this.postTranslationRepository.save(translations);
+
+    postEntity.translations = translations;
+
+    return postEntity;
+  }
+}

src/modules/post/post.module.ts

@@ -1,12 +1,12 @@
 import { Module } from '@nestjs/common';
 import { TypeOrmModule } from '@nestjs/typeorm';
 
-import { CreatePostHandler } from './commands/create-post.command.ts';
+import { CreatePostHandler } from './commands/create-post.handler.ts';
 import { PostController } from './post.controller.ts';
 import { PostEntity } from './post.entity.ts';
 import { PostService } from './post.service.ts';
 import { PostTranslationEntity } from './post-translation.entity.ts';
-import { GetPostHandler } from './queries/get-post.query.ts';
+import { GetPostHandler } from './queries/get-post.handler.ts';
 
 const handlers = [CreatePostHandler, GetPostHandler];
 

src/modules/post/queries/get-post.handler.ts

@@ -0,0 +1,21 @@
+import type { IQueryHandler } from '@nestjs/cqrs';
+import { QueryHandler } from '@nestjs/cqrs';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+
+import { PostEntity } from '../post.entity.ts';
+import { GetPostQuery } from './get-post.query.ts';
+
+@QueryHandler(GetPostQuery)
+export class GetPostHandler implements IQueryHandler<GetPostQuery> {
+  constructor(
+    @InjectRepository(PostEntity)
+    private postRepository: Repository<PostEntity>,
+  ) {}
+
+  async execute(query: GetPostQuery) {
+    return this.postRepository.findBy({
+      userId: query.userId as never,
+    });
+  }
+}

src/modules/post/queries/get-post.query.ts

@@ -1,24 +1,5 @@
-import type { ICommand, IQueryHandler } from '@nestjs/cqrs';
-import { QueryHandler } from '@nestjs/cqrs';
-import { InjectRepository } from '@nestjs/typeorm';
-import { Repository } from 'typeorm';
-
-import { PostEntity } from '../post.entity.ts';
+import type { ICommand } from '@nestjs/cqrs';
 
 export class GetPostQuery implements ICommand {
   constructor(public readonly userId: Uuid) {}
 }
-
-@QueryHandler(GetPostQuery)
-export class GetPostHandler implements IQueryHandler<GetPostQuery> {
-  constructor(
-    @InjectRepository(PostEntity)
-    private postRepository: Repository<PostEntity>,
-  ) {}
-
-  async execute(query: GetPostQuery) {
-    return this.postRepository.findBy({
-      userId: query.userId as never,
-    });
-  }
-}