Merge pull request #42 from CodelyTV/part-two

Part two

Author: rsaladocid

.github/workflows/nodejs.yml

@@ -4,23 +4,27 @@ on: [push]
 
 jobs:
   build:
-
     runs-on: ubuntu-latest
 
     strategy:
       matrix:
         node-version: [8.x, 10.x, 12.x]
+        mongodb-version: [4.0, 4.2]
 
     steps:
-    - uses: actions/checkout@v1
-    - name: Use Node.js ${{ matrix.node-version }}
-      uses: actions/setup-node@v1
-      with:
-        node-version: ${{ matrix.node-version }}
-    - name: npm install, build, and test
-      run: |
-        npm install
-        npm run build --if-present
-        npm test
-      env:
-        CI: true
+      - uses: actions/checkout@v1
+      - name: Use Node.js ${{ matrix.node-version }}
+        uses: actions/setup-node@v1
+        with:
+          node-version: ${{ matrix.node-version }}
+      - name: Launch MongoDB
+        uses: wbari/start-mongoDB@v0.2
+        with:
+          mongoDBVersion: ${{ matrix.mongodb-version }}
+      - name: npm install, build, and test
+        run: |
+          npm install
+          npm run build --if-present
+          npm test
+        env:
+          CI: true

.gitignore

@@ -2,4 +2,4 @@ node_modules/
 dist/
 .tmp
 logs/
-src/Contexts/Mooc/Courses/infrastructure/courses.*
+src/Contexts/Mooc/Courses/infrastructure/persistence/courses.*

package-lock.json

@@ -25,8 +25,10 @@
     "@types/express": "^4.17.2",
     "@types/glob": "^7.1.1",
     "@types/helmet": "0.0.44",
+    "@types/mongodb": "^3.3.15",
     "@types/node": "~13.1.1",
     "@types/uuid": "^3.4.6",
+    "@types/uuid-validate": "0.0.1",
     "body-parser": "^1.19.0",
     "bson": "^4.0.2",
     "compression": "^1.7.4",
@@ -38,10 +40,12 @@
     "helmet": "^3.21.2",
     "http-status": "^1.4.2",
     "mandrill-api": "^1.0.45",
+    "mongodb": "^3.5.2",
     "node-dependency-injection": "^2.4.2",
     "ts-node": "^8.3.0",
-    "typescript": "^3.4.5",
+    "typescript": "^3.7.2",
     "uuid": "^3.3.3",
+    "uuid-validate": "0.0.3",
     "winston": "^3.2.1"
   },
   "devDependencies": {

package.json

@@ -1,16 +1,29 @@
-import CourseRepository from '../domain/CourseRepository';
-import Course from '../domain/Course';
+import { CourseRepository } from '../domain/CourseRepository';
+import { Course } from '../domain/Course';
+import { CreateCourseRequest } from './CreateCourseRequest';
+import { CourseId } from '../../Shared/domain/Courses/CourseId';
+import { CourseName } from '../domain/CourseName';
+import { CourseDuration } from '../domain/CourseDuration';
+import { EventBus } from '../../../Shared/domain/EventBus';
 
-export default class CourseCreator {
+export class CourseCreator {
   private repository: CourseRepository;
+  private eventBus: EventBus;
 
-  constructor(repository: CourseRepository) {
+  constructor(repository: CourseRepository, eventBus: EventBus) {
     this.repository = repository;
+    this.eventBus = eventBus;
   }
 
-  async run(id: string, name: string, duration: string): Promise<void> {
-    const course = new Course(id, name, duration);
+  async run(request: CreateCourseRequest): Promise<void> {
+    const course = new Course(
+      new CourseId(request.id),
+      new CourseName(request.name),
+      new CourseDuration(request.duration)
+    );
 
-    return this.repository.save(course);
+    await this.repository.save(course);
+
+    this.eventBus.publish(course.pullDomainEvents());
   }
 }

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

@@ -0,0 +1,5 @@
+export type CreateCourseRequest = {
+  id: string;
+  name: string;
+  duration: string;
+};

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

@@ -0,0 +1,19 @@
+import { DomainEvent } from '../../../Shared/domain/DomainEvent';
+
+export abstract class AggregateRoot {
+  private domainEvents: Array<DomainEvent>;
+
+  constructor() {
+    this.domainEvents = [];
+  }
+
+  pullDomainEvents(): Array<DomainEvent> {
+    return this.domainEvents;
+  }
+
+  record(event: DomainEvent): void {
+    this.domainEvents.push(event);
+  }
+
+  abstract toPrimitives(): any;
+}

src/Contexts/Mooc/Courses/domain/AggregateRoot.ts

@@ -1,11 +1,48 @@
-export default class Course {
-  readonly id: string;
-  readonly name: string;
-  readonly duration: string;
+import { AggregateRoot } from './AggregateRoot';
+import { CourseCreatedDomainEvent } from './CourseCreatedDomainEvent';
+import { CourseName } from './CourseName';
+import { CourseDuration } from './CourseDuration';
+import { CourseId } from '../../Shared/domain/Courses/CourseId';
 
-  constructor(id: string, name: string, duration: string) {
+export class Course extends AggregateRoot {
+  readonly id: CourseId;
+  readonly name: CourseName;
+  readonly duration: CourseDuration;
+
+  constructor(id: CourseId, name: CourseName, duration: CourseDuration) {
+    super();
     this.id = id;
     this.name = name;
     this.duration = duration;
   }
+
+  static create(id: CourseId, name: CourseName, duration: CourseDuration): Course {
+    const course = new Course(id, name, duration);
+
+    course.record(
+      new CourseCreatedDomainEvent({
+        id: course.id.value,
+        duration: course.duration.value,
+        name: course.name.value
+      })
+    );
+
+    return course;
+  }
+
+  static fromPrimitives(plainData: any): Course {
+    return new Course(
+      new CourseId(plainData.id),
+      new CourseName(plainData.name),
+      new CourseDuration(plainData.duration)
+    );
+  }
+
+  toPrimitives(): any {
+    return {
+      id: this.id.value,
+      name: this.name.value,
+      duration: this.duration.value
+    };
+  }
 }

src/Contexts/Mooc/Courses/domain/Course.ts

@@ -1,5 +1,5 @@
-export default class CourseAlreadyExists extends Error {
-  constructor(courseId: string) {
-    super(`Course ${courseId} already exists`);
+export class CourseAlreadyExists extends Error {
+  constructor(id: string) {
+    super(`Course ${id} already exists`);
   }
 }