Merge pull request #66 from CodelyTV/part_four_query_bus

Part four query bus

Author: ivanportillo

.github/workflows/nodejs.yml

@@ -25,6 +25,7 @@ jobs:
         run: |
           npm install
           npm run build --if-present
+          npm run lint
           npm test
         env:
           CI: true

package.json

@@ -16,6 +16,7 @@
     "test": "npm run test:unit && npm run test:features",
     "test:unit": "NODE_ENV=test jest",
     "test:features": "NODE_ENV=test cucumber-js -p default",
+    "lint": "tslint src/**/*.ts{,x}",
     "start": "NODE_ENV=production node dist/src/apps/mooc_backend/server",
     "start:backoffice:frontend": "NODE_ENV=production node dist/src/apps/backoffice/frontend/server",
     "build": "npm run build:clean && npm run build:tsc && npm run build:di",

src/Contexts/Mooc/Courses/application/CourseCreator.ts

@@ -6,6 +6,12 @@ import { CourseName } from '../domain/CourseName';
 import { CourseDuration } from '../domain/CourseDuration';
 import { EventBus } from '../../../Shared/domain/EventBus';
 
+type Params = {
+  courseId: CourseId;
+  courseName: CourseName;
+  courseDuration: CourseDuration;
+};
+
 export class CourseCreator {
   private repository: CourseRepository;
   private eventBus: EventBus;
@@ -15,11 +21,11 @@ export class CourseCreator {
     this.eventBus = eventBus;
   }
 
-  async run(request: CreateCourseRequest): Promise<void> {
+  async run({ courseId, courseName, courseDuration }: Params): Promise<void> {
     const course = Course.create(
-      new CourseId(request.id),
-      new CourseName(request.name),
-      new CourseDuration(request.duration)
+      courseId,
+      courseName,
+      courseDuration
     );
 
     await this.repository.save(course);

src/Contexts/Mooc/Courses/application/CreateCourseCommand.ts

@@ -0,0 +1,20 @@
+import { Command } from '../../../Shared/domain/Command';
+
+type Params = {
+    id: string;
+    name: string;
+    duration: string;
+};
+
+export class CreateCourseCommand extends Command {
+    id: string;
+    name: string;
+    duration: string;
+
+    constructor({ id, name, duration }: Params) {
+        super();
+        this.id = id;
+        this.name = name;
+        this.duration = duration;
+    }
+}

src/Contexts/Mooc/Courses/application/CreateCourseCommandHandler.ts

@@ -0,0 +1,22 @@
+import { CreateCourseCommand } from './CreateCourseCommand';
+import { CommandHandler } from '../../../Shared/domain/CommandHandler';
+import { CourseCreator } from './CourseCreator';
+import { Command } from '../../../Shared/domain/Command';
+import { CourseId } from '../../Shared/domain/Courses/CourseId';
+import { CourseName } from '../domain/CourseName';
+import { CourseDuration } from '../domain/CourseDuration';
+
+export class CreateCourseCommandHandler implements CommandHandler<CreateCourseCommand> {
+    constructor(private courseCreator: CourseCreator) {}
+
+    subscribedTo(): Command {
+        return CreateCourseCommand;
+    }
+
+    async handle(command: CreateCourseCommand): Promise<void> {
+        const courseId = new CourseId(command.id);
+        const courseName = new CourseName(command.name);
+        const courseDuration = new CourseDuration(command.duration);
+        await this.courseCreator.run({ courseId, courseName, courseDuration });
+    }
+}

src/Contexts/Mooc/CoursesCounter/application/Find/CoursesCounterFinder.ts

@@ -1,6 +1,6 @@
 import { CoursesCounterRepository } from '../../domain/CoursesCounterRepository';
 import { CoursesCounterNotExist } from '../../domain/CoursesCounterNotExist';
-import { CoursesCounterResponse } from './CoursesCounterResponse';
+import { FindCoursesCounterResponse } from './FindCoursesCounterResponse';
 
 export class CoursesCounterFinder {
   constructor(private repository: CoursesCounterRepository) {}
@@ -11,6 +11,6 @@ export class CoursesCounterFinder {
       throw new CoursesCounterNotExist();
     }
 
-    return new CoursesCounterResponse(counter.total.value);
+    return new FindCoursesCounterResponse(counter.total.value);
   }
 }

src/Contexts/Mooc/CoursesCounter/application/Find/FindCoursesCounterQuery.ts

@@ -0,0 +1,3 @@
+import { Query } from '../../../../Shared/domain/Query';
+
+export class FindCoursesCounterQuery implements Query {}

src/Contexts/Mooc/CoursesCounter/application/Find/FindCoursesCounterQueryHandler.ts

@@ -0,0 +1,17 @@
+import { QueryHandler } from '../../../../Shared/domain/QueryHandler';
+import { FindCoursesCounterQuery } from './FindCoursesCounterQuery';
+import { FindCoursesCounterResponse } from './FindCoursesCounterResponse';
+import { Query } from '../../../../Shared/domain/Query';
+import { CoursesCounterFinder } from './CoursesCounterFinder';
+
+export class FindCoursesCounterQueryHandler
+  implements QueryHandler<FindCoursesCounterQuery, FindCoursesCounterResponse> {
+  constructor(private finder: CoursesCounterFinder) {}
+
+  subscribedTo(): Query {
+    return FindCoursesCounterQuery;
+  }
+  handle(_query: FindCoursesCounterQuery): Promise<FindCoursesCounterResponse> {
+    return this.finder.run();
+  }
+}

src/Contexts/Mooc/CoursesCounter/application/Find/CoursesCounterResponse.ts renamed to src/Contexts/Mooc/CoursesCounter/application/Find/FindCoursesCounterResponse.ts

@@ -1,4 +1,4 @@
-export class CoursesCounterResponse {
+export class FindCoursesCounterResponse {
   readonly total: number;
 
   constructor(total: number) {

src/Contexts/Shared/domain/Command.ts

@@ -0,0 +1 @@
+export abstract class Command {}