Merge pull request #6 from CodelyTV/part-one-refactor

Part one refactor

Author: rsaladocid

.gitignore

@@ -1,3 +1,4 @@
 node_modules/
 dist/
 .tmp
+src/Contexts/Mooc/Courses/infrastructure/courses.*

package-lock.json

@@ -23,6 +23,7 @@
     "@types/convict": "^4.2.1",
     "@types/errorhandler": "0.0.32",
     "@types/express": "^4.17.1",
+    "@types/glob": "^7.1.1",
     "@types/helmet": "0.0.44",
     "@types/node": "~11.13.0",
     "@types/uuid": "^3.4.5",
@@ -33,6 +34,7 @@
     "copy": "^0.3.2",
     "errorhandler": "^1.5.1",
     "express": "^4.17.1",
+    "glob": "^7.1.6",
     "helmet": "^3.21.1",
     "http-status": "^1.3.2",
     "mandrill-api": "^1.0.45",

package.json

@@ -1,7 +1,7 @@
 import CourseRepository from '../domain/CourseRepository';
 import Course from '../domain/Course';
 
-export default class CreateCourse {
+export default class CourseCreator {
   private repository: CourseRepository;
 
   constructor(repository: CourseRepository) {
@@ -11,6 +11,6 @@ export default class CreateCourse {
   async run(id: string, name: string, duration: string): Promise<void> {
     const course = new Course(id, name, duration);
 
-    this.repository.save(course);
+    return this.repository.save(course);
   }
 }

src/Mooc/Courses/application/CreateCourse.ts renamed to src/Contexts/Mooc/Courses/application/CourseCreator.ts

@@ -0,0 +1,11 @@
+export default class Course {
+  readonly id: string;
+  readonly name: string;
+  readonly duration: string;
+
+  constructor(id: string, name: string, duration: string) {
+    this.id = id;
+    this.name = name;
+    this.duration = duration;
+  }
+}

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

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

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

@@ -0,0 +1,8 @@
+import Course from './Course';
+import { Nullable } from '../../../Shared/domain/Nullable';
+
+export default interface CourseRepository {
+  save(course: Course): Promise<void>;
+
+  search(id: string): Promise<Nullable<Course>>;
+}

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

@@ -0,0 +1,27 @@
+import CourseRepository from '../domain/CourseRepository';
+import Course from '../domain/Course';
+import fs from 'fs';
+import BSON from 'bson';
+import { Nullable } from '../../../Shared/domain/Nullable';
+
+export default class FileCourseRepository implements CourseRepository {
+  private FILE_PATH = `${__dirname}/courses`;
+
+  async save(course: Course): Promise<void> {
+    const filePath = this.filePath(course.id);
+    const data = BSON.serialize(course);
+
+   return fs.writeFileSync(filePath, data);
+  }
+
+  async search(id: string): Promise<Nullable<Course>> {
+    const filePath = this.filePath(id);
+    const exists = fs.existsSync(filePath);
+
+    return exists ? BSON.deserialize(fs.readFileSync(this.filePath(id))) : null;
+  }
+
+  private filePath(id: string): string {
+    return `${this.FILE_PATH}.${id}.repo`;
+  }
+}

src/Contexts/Mooc/Courses/infrastructure/FileCourseRepository.ts

@@ -0,0 +1 @@
+export type Nullable<T> = T | null;