Raise event on Student registered

Author: OctaviPascual

src/mooc/main/tv/codely/mooc/students/application/register/StudentRegistrar.java

@@ -2,13 +2,16 @@
 
 import tv.codely.mooc.students.domain.*;
 import tv.codely.shared.domain.Service;
+import tv.codely.shared.domain.bus.event.EventBus;
 
 @Service
 public class StudentRegistrar {
     private final StudentRepository repository;
+    private final EventBus          eventBus;
 
-    public StudentRegistrar(StudentRepository repository) {
+    public StudentRegistrar(StudentRepository repository, EventBus eventBus) {
         this.repository = repository;
+        this.eventBus   = eventBus;
     }
 
     public void register(RegisterStudentRequest request) {
@@ -19,5 +22,6 @@ public void register(RegisterStudentRequest request) {
             new StudentEmail(request.email())
         );
         repository.register(student);
+        eventBus.publish(student.pullDomainEvents());
     }
 }

src/mooc/main/tv/codely/mooc/students/domain/Student.java

@@ -1,8 +1,11 @@
 package tv.codely.mooc.students.domain;
 
+import tv.codely.shared.domain.AggregateRoot;
+import tv.codely.shared.domain.student.StudentRegisteredDomainEvent;
+
 import java.util.Objects;
 
-public final class Student {
+public final class Student extends AggregateRoot {
     private final StudentId      id;
     private final StudentName    name;
     private final StudentSurname surname;
@@ -23,7 +26,11 @@ private Student() {
     }
 
     public static Student create(StudentId id, StudentName name, StudentSurname surname, StudentEmail email) {
-        return new Student(id, name, surname, email);
+        Student student = new Student(id, name, surname, email);
+
+        student.record(new StudentRegisteredDomainEvent(id.value(), name.value(), surname.value(), email.value()));
+
+        return student;
     }
 
     public StudentId id() {

src/mooc/test/tv/codely/mooc/students/application/register/StudentRegistrarTestShould.java

@@ -5,6 +5,8 @@
 import tv.codely.mooc.students.StudentsModuleUnitTestCase;
 import tv.codely.mooc.students.domain.Student;
 import tv.codely.mooc.students.domain.StudentMother;
+import tv.codely.mooc.students.domain.StudentRegisteredDomainEventMother;
+import tv.codely.shared.domain.student.StudentRegisteredDomainEvent;
 
 final class StudentRegistrarTestShould extends StudentsModuleUnitTestCase {
     StudentRegistrar registrar;
@@ -13,16 +15,18 @@ final class StudentRegistrarTestShould extends StudentsModuleUnitTestCase {
     protected void setUp() {
         super.setUp();
 
-        registrar = new StudentRegistrar(repository);
+        registrar = new StudentRegistrar(repository, eventBus);
     }
 
     @Test
     void register_a_valid_student() {
-        RegisterStudentRequest request = RegisterStudentRequestMother.random();
-        Student                student = StudentMother.fromRequest(request);
+        RegisterStudentRequest       request     = RegisterStudentRequestMother.random();
+        Student                      student     = StudentMother.fromRequest(request);
+        StudentRegisteredDomainEvent domainEvent = StudentRegisteredDomainEventMother.fromStudent(student);
 
         registrar.register(request);
 
         shouldHaveSaved(student);
+        shouldHavePublished(domainEvent);
     }
 }

src/mooc/test/tv/codely/mooc/students/domain/StudentRegisteredDomainEventMother.java

@@ -0,0 +1,24 @@
+package tv.codely.mooc.students.domain;
+
+import tv.codely.shared.domain.student.StudentRegisteredDomainEvent;
+
+public final class StudentRegisteredDomainEventMother {
+    public static StudentRegisteredDomainEvent create(
+        StudentId id, StudentName name, StudentSurname surname, StudentEmail email
+    ) {
+        return new StudentRegisteredDomainEvent(id.value(), name.value(), surname.value(), email.value());
+    }
+
+    public static StudentRegisteredDomainEvent fromStudent(Student student) {
+        return create(student.id(), student.name(), student.surname(), student.email());
+    }
+
+    public static StudentRegisteredDomainEvent random() {
+        return create(
+            StudentIdMother.random(),
+            StudentNameMother.random(),
+            StudentSurnameMother.random(),
+            StudentEmailMother.random()
+        );
+    }
+}

src/shared/main/tv/codely/shared/domain/student/StudentRegisteredDomainEvent.java

@@ -0,0 +1,106 @@
+package tv.codely.shared.domain.student;
+
+import tv.codely.shared.domain.bus.event.DomainEvent;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Objects;
+
+public final class StudentRegisteredDomainEvent extends DomainEvent {
+    private final String name;
+    private final String surname;
+    private final String email;
+
+    public StudentRegisteredDomainEvent() {
+        super(null);
+
+        this.name    = null;
+        this.surname = null;
+        this.email   = null;
+    }
+
+    public StudentRegisteredDomainEvent(String aggregateId, String name, String surname, String email) {
+        super(aggregateId);
+
+        this.name    = name;
+        this.surname = surname;
+        this.email   = email;
+    }
+
+    public StudentRegisteredDomainEvent(
+        String aggregateId,
+        String eventId,
+        String occurredOn,
+        String name,
+        String surname,
+        String email
+    ) {
+        super(aggregateId, eventId, occurredOn);
+
+        this.name    = name;
+        this.surname = surname;
+        this.email   = email;
+    }
+
+    @Override
+    public String eventName() {
+        return "course.created";
+    }
+
+    @Override
+    public HashMap<String, Serializable> toPrimitives() {
+        return new HashMap<String, Serializable>() {{
+            put("name", name);
+            put("surname", surname);
+            put("email", email);
+        }};
+    }
+
+    @Override
+    public StudentRegisteredDomainEvent fromPrimitives(
+        String aggregateId,
+        HashMap<String, Serializable> body,
+        String eventId,
+        String occurredOn
+    ) {
+        return new StudentRegisteredDomainEvent(
+            aggregateId,
+            eventId,
+            occurredOn,
+            (String) body.get("name"),
+            (String) body.get("surname"),
+            (String) body.get("email")
+        );
+    }
+
+    public String name() {
+        return name;
+    }
+
+    public String surname() {
+        return surname;
+    }
+
+    public String email() {
+        return email;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) {
+            return true;
+        }
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
+        StudentRegisteredDomainEvent that = (StudentRegisteredDomainEvent) o;
+        return name.equals(that.name) &&
+            surname.equals(that.surname) &&
+            email.equals(that.email);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(name, surname, email);
+    }
+}