Merge commit '6335583169ef685f9425ed8c95e07151e77a03c9' into 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/[email protected]
+        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,6 +25,7 @@
     "@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",
@@ -39,6 +40,7 @@
     "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.7.2",

package.json

@@ -14,4 +14,6 @@ export abstract class AggregateRoot {
   record(event: DomainEvent): void {
     this.domainEvents.push(event);
   }
+
+  abstract toPrimitives(): any;
 }

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

@@ -29,4 +29,20 @@ export class Course extends AggregateRoot {
 
     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,9 +1,9 @@
-import { CourseRepository } from '../domain/CourseRepository';
-import { Course } from '../domain/Course';
+import { CourseRepository } from '../../domain/CourseRepository';
+import { Course } from '../../domain/Course';
 import fs from 'fs';
 import BSON from 'bson';
-import { Nullable } from '../../../Shared/domain/Nullable';
-import { CourseId } from '../../Shared/domain/Courses/CourseId';
+import { Nullable } from '../../../../Shared/domain/Nullable';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
 
 export class FileCourseRepository implements CourseRepository {
   private FILE_PATH = `${__dirname}/courses`;

src/Contexts/Mooc/Courses/infrastructure/FileCourseRepository.ts renamed to src/Contexts/Mooc/Courses/infrastructure/persistence/FileCourseRepository.ts

@@ -0,0 +1,23 @@
+import { Nullable } from '../../../../Shared/domain/Nullable';
+import { MongoRepository } from '../../../../Shared/infrastructure/persistence/mongo/MongoRepository';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { Course } from '../../domain/Course';
+import { CourseRepository } from '../../domain/CourseRepository';
+
+export class MongoCourseRepository extends MongoRepository<Course> implements CourseRepository {
+  public save(course: Course): Promise<void> {
+    return this.persist(course.id.value, course);
+  }
+
+  public async search(id: CourseId): Promise<Nullable<Course>> {
+    const collection = await this.collection();
+
+    const document = await collection.findOne({ _id: id.value });
+
+    return document ? Course.fromPrimitives({ ...document, id: id.value }) : null;
+  }
+
+  protected moduleName(): string {
+    return 'courses';
+  }
+}

src/Contexts/Mooc/Courses/infrastructure/persistence/MongoCourseRepository.ts

@@ -0,0 +1,6 @@
+import { MongoDocument } from '../../../../../Shared/infrastructure/persistence/mongo/MongoDocument';
+
+export type CourseDocument = MongoDocument & {
+  name: string;
+  duration: string;
+};

src/Contexts/Mooc/Courses/infrastructure/persistence/mongo/CourseDocument.ts

@@ -0,0 +1,4 @@
+export interface ConnectionManager {
+  connect(): Promise<void>;
+  close(): Promise<void>;
+}