Process of a teacher email students

Lecture

<?php

class Lecture extends EventSourcedAggregateRoot
{
  public function __construct(LectureId $id, StartTime $startTime) {
  }
  
  public function remindStudents()
  {
    $this->guardNotLAstDay();
    $this->apply(TeacherRequestedReminderForLecture($lectureId, $teacherId, $studentIds))
  }
}

LectureCommandHandler

<?php

class TeacherRequestsReminderForLecture {
  public function __construct(TeacherId $teacherId, LectureId $lectureId) {}
}

class LectureCommandHandler {
  function handleTeacherRequestsReminderForLecture(TeacherRequestsReminderForLecture $cmd) 
  {
    $lecture = $this->repo->find($cmd->lectureId);
    $lecture->remindStudents();
  }
}

LectureProcessor

<?php

class LectureProcessor
{
  public function whenTeacherRequestedReminderForLecture(TeacherRequestedReminderForLecture $event)
  {
    foreach($event->studentIds as $studentId) {
      $this->emailer->remindStudent($studentId, $lectureId);
      
      $this->commandBus->dispatch(RemindStudentOfLecture($studentId, $lectureId));
    }
  }
}

StudentCommandHandler

class StudentCommandHandler
{
  public function handleRemindStudentOfLecture(RemindStudentOfLecture $cmd)
  {
    student = $this->repo->find($cmd->studentId);
    student->remind($lectureId);
  }
}

class Student{
  public function remind($lectureId) {
    apply(StudentRemindedOfLecture($studentId, $lectureId));
  }
}

StudentReminderProjector

class StudentReminderProjector {
  public function whenStudentRemindedOfLecture() {
    // update view model
  }
}

TeacherRequestsReminderForLecture

// command
class TeacherRequestsReminderForLecture {
  public function __construct(LectureId $lectureId, TeacherId $teacherId) {}
}