Send twit after a new course created

docker-compose.yml

@@ -17,7 +17,7 @@ services:
 
   mooc-backend:
     <<: *default-app
-    command: bash -c "npm run build && npm run start"
+    command: bash -c "npm run build && npm run dev"
     ports:
       - 3000:3000
 

src/Contexts/Mooc/Courses/application/ChangeDescriptionCourse/ChangeDescriptionCourseCommand.ts

@@ -0,0 +1,12 @@
+import { Command } from '../../../../Shared/domain/Command';
+
+export class ChangeDescriptionCourseCommand extends Command {
+    readonly id: string;
+    readonly description: string;
+
+    constructor(id: string, description: string) {
+        super();
+        this.id = id;
+        this.description = description;
+    }
+}

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

@@ -0,0 +1,36 @@
+import { CourseRepository } from '../../domain/CourseRepository';
+import { Course } from '../../domain/Course';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { CourseDuration } from '../../domain/CourseDuration';
+import { EventBus } from '../../../../Shared/domain/EventBus';
+import { CourseName } from '../../../Shared/domain/Courses/CourseName';
+import { CourseDescription } from '../../domain/CourseDescription';
+
+type Params = {
+  courseId: CourseId;
+  courseName: CourseName;
+  courseDuration: CourseDuration;
+  courseDescription: CourseDescription
+};
+
+export class CourseCreator {
+  private repository: CourseRepository;
+  private eventBus: EventBus;
+
+  constructor(repository: CourseRepository, eventBus: EventBus) {
+    this.repository = repository;
+    this.eventBus = eventBus;
+  }
+
+  async run({ courseId, courseName, courseDuration, courseDescription }: Params): Promise<void> {
+    const course = Course.create(
+      courseId,
+      courseName,
+      courseDuration,
+      courseDescription
+    );
+
+    await this.repository.save(course);
+    await this.eventBus.publish(course.pullDomainEvents());
+  }
+}

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

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

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

@@ -1,10 +1,11 @@
 import { CreateCourseCommand } from './CreateCourseCommand';
-import { CommandHandler } from '../../../Shared/domain/CommandHandler';
+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';
+import { Command } from '../../../../Shared/domain/Command';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { CourseDuration } from '../../domain/CourseDuration';
+import { CourseName } from '../../../Shared/domain/Courses/CourseName';
+import { CourseDescription } from '../../domain/CourseDescription';
 
 export class CreateCourseCommandHandler implements CommandHandler<CreateCourseCommand> {
     constructor(private courseCreator: CourseCreator) {}
@@ -17,6 +18,7 @@ export class CreateCourseCommandHandler implements CommandHandler<CreateCourseCo
         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 });
+        const courseDescription = new CourseDescription(command.description);
+        await this.courseCreator.run({ courseId, courseName, courseDuration, courseDescription });
     }
 }

src/Contexts/Mooc/Courses/application/GetCourse/CourseFinder.ts

@@ -0,0 +1,20 @@
+import { CourseFinder as DomainCourseFinder } from '../../domain/CourseFinder';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { CourseResponse } from '../../../Shared/domain/Courses/application/CourseResponse';
+
+export type Params = {
+  courseId: CourseId;
+};
+
+export class CourseFinder {
+  private courseFinder: DomainCourseFinder;
+
+  constructor(courseFinder: DomainCourseFinder) {
+    this.courseFinder = courseFinder;
+  }
+
+  async run({ courseId }: Params): Promise<CourseResponse> {
+    const course = await this.courseFinder.run(courseId);
+    return new CourseResponse(course);
+  }
+}

src/Contexts/Mooc/Courses/application/GetCourse/GetCourseQuery.ts

@@ -0,0 +1,11 @@
+import { GetCourseRequest } from './GetCourseRequest';
+import { Query } from '../../../../Shared/domain/Query';
+
+export class GetCourseQuery extends Query {
+    id: string;
+
+    constructor({ id }: GetCourseRequest) {
+        super();
+        this.id = id;
+    }
+}

src/Contexts/Mooc/Courses/application/GetCourse/GetCourseQueryHandler.ts

@@ -0,0 +1,19 @@
+import { GetCourseQuery } from './GetCourseQuery';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { CourseFinder } from './CourseFinder';
+import { CourseResponse } from '../../../Shared/domain/Courses/application/CourseResponse';
+import { QueryHandler } from '../../../../Shared/domain/QueryHandler';
+import { Query } from '../../../../Shared/domain/Query';
+
+export class GetCourseQueryHandler implements QueryHandler<GetCourseQuery, CourseResponse> {
+    constructor(private courseFinder: CourseFinder) {}
+
+    subscribedTo(): Query {
+        return GetCourseQuery;
+    }
+
+    async handle(query: GetCourseQuery): Promise<CourseResponse> {
+        const courseId = new CourseId(query.id);
+        return this.courseFinder.run({ courseId });
+    }
+}

src/Contexts/Mooc/Courses/application/GetCourse/GetCourseRequest.ts

@@ -0,0 +1,3 @@
+export type GetCourseRequest = {
+  id: string;
+};

src/Contexts/Mooc/Courses/application/GetCourses/CoursesResponse.ts

@@ -0,0 +1,16 @@
+import { Course } from '../../domain/Course';
+import { CourseResponse } from '../../../Shared/domain/Courses/application/CourseResponse';
+import { Nullable } from '../../../../Shared/domain/Nullable';
+export class CoursesResponse {
+    readonly data: CourseResponse[];
+
+    constructor(courses: Nullable<Course[]>) {
+        this.data = [];
+        if (courses !== null) {
+            courses.forEach(course => {
+                this.data.push(new CourseResponse(course))
+            }); 
+        }       
+    }
+}
+

src/Contexts/Mooc/Courses/application/GetCourses/CoursesSearcher.ts

@@ -0,0 +1,20 @@
+import { CourseFinder as DomainCourseFinder } from '../../domain/CourseFinder';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { CourseResponse } from '../../../Shared/domain/Courses/application/CourseResponse';
+import { CourseRepository } from '../../domain/CourseRepository';
+import { Course } from '../../domain/Course';
+import { CoursesResponse } from './CoursesResponse';
+import { Nullable } from '../../../../Shared/domain/Nullable';
+
+export class CoursesSearcher {
+  private repository: CourseRepository;
+
+  constructor(repository: CourseRepository) {
+    this.repository = repository;
+  }
+
+  async run(): Promise<CoursesResponse> {
+    const courses : Nullable<Course[]> = await this.repository.getAll();
+    return new CoursesResponse(courses);
+  }
+}

src/Contexts/Mooc/Courses/application/GetCourses/GetCoursesQuery.ts

@@ -0,0 +1,8 @@
+import { Query } from '../../../../Shared/domain/Query';
+
+export class GetCoursesQuery extends Query {
+
+    constructor() {
+        super();
+    }
+}

src/Contexts/Mooc/Courses/application/GetCourses/GetCoursesQueryHandler.ts

@@ -0,0 +1,17 @@
+import { QueryHandler } from '../../../../Shared/domain/QueryHandler';
+import { Query } from '../../../../Shared/domain/Query';
+import { CoursesResponse } from './CoursesResponse';
+import { GetCoursesQuery } from './GetCoursesQuery';
+import { CoursesSearcher } from './CoursesSearcher';
+
+export class GetCoursesQueryHandler implements QueryHandler<GetCoursesQuery, CoursesResponse> {
+    constructor(private coursesSearcher: CoursesSearcher) {}
+
+    subscribedTo(): Query {
+        return GetCoursesQuery;
+    }
+
+    async handle(query: GetCoursesQuery): Promise<CoursesResponse> {
+        return this.coursesSearcher.run();
+    }
+}

src/Contexts/Mooc/Courses/application/LikeCourse/CourseLiker.ts

@@ -0,0 +1,21 @@
+import { CourseId } from './../../../Shared/domain/Courses/CourseId';
+import { CourseFinder } from '../../domain/CourseFinder';
+import { UserId } from '../../domain/UserId';
+import { CourseRepository } from '../../domain/CourseRepository';
+
+type Params = {
+  courseId: CourseId;
+  userId: UserId;
+};
+
+export class CourseLiker {
+  constructor(private courseFinder: CourseFinder, private repository: CourseRepository) {}
+
+  async run({ courseId, userId }: Params): Promise<void> {
+    const course = await this.courseFinder.run(courseId);
+
+    course.like(userId);
+
+    await this.repository.save(course);
+  }
+}

src/Contexts/Mooc/Courses/application/LikeCourse/LikeCourseCommand.ts

@@ -0,0 +1,16 @@
+import { Command } from '../../../../Shared/domain/Command';
+
+type Params = {
+  id: string;
+  userId: string;
+};
+
+export class LikeCourseCommand implements Command {
+  readonly id: string;
+  readonly userId: string;
+
+  constructor({ id, userId }: Params) {
+    this.id = id;
+    this.userId = userId;
+  }
+}

src/Contexts/Mooc/Courses/application/LikeCourse/LikeCourseCommandHandler.ts

@@ -0,0 +1,19 @@
+import { Command } from '../../../../Shared/domain/Command';
+import { CommandHandler } from '../../../../Shared/domain/CommandHandler';
+import { LikeCourseCommand } from './LikeCourseCommand';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { CourseLiker } from './CourseLiker';
+import { UserId } from '../../domain/UserId';
+export class LikeCourseCommandHandler implements CommandHandler<LikeCourseCommand> {
+  constructor(private courseLiker: CourseLiker) {}
+
+  subscribedTo(): Command {
+    return LikeCourseCommand;
+  }
+
+  handle(command: LikeCourseCommand): Promise<void> {
+    const courseId = new CourseId(command.id);
+    const userId = new UserId(command.userId);
+    return this.courseLiker.run({ courseId, userId });
+  }
+}

src/Contexts/Mooc/Courses/application/RenameCourse/CourseRenamer.ts

@@ -0,0 +1,30 @@
+import { CourseRepository } from '../../domain/CourseRepository';
+import { CourseId } from '../../../Shared/domain/Courses/CourseId';
+import { EventBus } from '../../../../Shared/domain/EventBus';
+import { CourseName } from '../../../Shared/domain/Courses/CourseName';
+import { CourseFinder } from '../../domain/CourseFinder';
+
+type Params = {
+  courseId: CourseId;
+  courseName: CourseName;
+};
+
+export class CourseRenamer {
+  private courseFinder: CourseFinder;
+  private eventBus: EventBus;
+  private repository: CourseRepository;
+
+  constructor(courseFinder: CourseFinder, repository: CourseRepository, eventBus: EventBus) {
+    this.courseFinder = courseFinder;
+    this.eventBus = eventBus;
+    this.repository = repository;
+  }
+
+  async run({ courseId, courseName }: Params): Promise<void> {
+    const course = await this.courseFinder.run(courseId);
+    course.rename(courseName);
+
+    await this.repository.save(course);
+    await this.eventBus.publish(course.pullDomainEvents());
+  }
+}