src/Products/NotificationsBundle/Subscriber/OneRoster/OneRosterUserTweakSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. namespace Products\NotificationsBundle\Subscriber\OneRoster;
  5. use Cms\CoreBundle\Entity\OneRoster\OneRosterUser;
  6. use Cms\CoreBundle\Entity\OneRosterSync;
  7. use Cms\CoreBundle\Events\OneRosterTweakEvent;
  8. use Doctrine\Common\Util\ClassUtils;
  9. use Products\NotificationsBundle\Entity\Profile;
  10. use Products\NotificationsBundle\Entity\Student;
  11. use Products\NotificationsBundle\Util\Reachability;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15.  * Class OneRosterUserTweakSubscriber
  16.  * @package Products\NotificationsBundle\Subscriber\OneRoster
  17.  */
  18. final class OneRosterUserTweakSubscriber extends AbstractNotificationsOneRosterSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * {@inheritdoc}
  22.      */
  23.     static public function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             OneRosterTweakEvent::EVENT__USER => [
  27.                 //['discardableEnable', 0],
  28.                 ['calculateStudentReachability', 0],
  29.                 //['discardableDisable', 0],
  30.             ],
  31.         ];
  32.     }
  34.     /**
  35.      * @param OneRosterTweakEvent $event
  36.      */
  37.     public function calculateStudentReachability(OneRosterTweakEvent $event): void
  38.     {
  39.         // ensure we are meant to process this
  40.         if ( ! $this->checkTypes($event->getJob(), [
  41.             OneRosterSync::STRATEGIES__NOTIFICATIONS__FAMILY,
  42.             OneRosterSync::STRATEGIES__NOTIFICATIONS__STUDENTS,
  43.         ])) {
  44.             return;
  45.         }
  47.         // get the user
  48.         $user = $event->getEntity();
  49.         if ( ! $user instanceof OneRosterUser) {
  50.             throw new \Exception(sprintf(
  51.                 'User is not of proper type, got "%s".',
  52.                 ClassUtils::getClass($user)
  53.             ));
  54.         }
  56.         // branch on the role type
  57.         switch (true) {
  58.             case $this->checkTypes($event->getJob(), [OneRosterSync::STRATEGIES__NOTIFICATIONS__FAMILY]) && $user->isRoleStudent():
  59.             case $this->checkTypes($event->getJob(), [OneRosterSync::STRATEGIES__NOTIFICATIONS__STUDENTS]) && $user->isRoleStudent():
  60.                 // noop, code will continue after the switch statement
  61.                 break;
  62.             default:
  64.                 // DEBUGGING
  65.                 $event->getOutput()->writeln(sprintf(
  66.                     'User role for #%s is "%s", skipping...',
  67.                     $user->getSourcedId(),
  68.                     $user->getRole()
  69.                 ));
  71.                 // quit early
  72.                 return;
  74.         }
  76.         // load up the student, this must match something, and it should at this point...
  77.         $student = $this->em->getRepository(Student::class)->findOneBy([
  78.             'onerosterId' => $user->getSourcedId(),
  79.         ]);
  81.         // if we don't have a profile we have a problem
  82.         if ( ! $student) {
  83.             throw new \Exception(sprintf(
  84.                 'Could not load student "%s".',
  85.                 $user->getSourcedId()
  86.             ));
  87.         }
  89.         // get all the profiles for this student, should be attached now
  90.         /** @var array|Profile[] $profiles */
  91.         $profiles = $this->em->getRepository(Profile::class)->createQueryBuilder('profiles')
  92.             ->leftJoin('profiles.relationships', 'relationships')
  93.             ->andWhere('relationships.student = :student')
  94.             ->setParameter('student', $student)
  95.             ->getQuery()
  96.             ->getResult();
  98.         // reset the students standing
  99.         $student->setStanding(Reachability::STANDINGS__NONE);
  101.         // loop over all the profiles
  102.         foreach ($profiles as $profile) {
  104.             // merge the standing into the student
  105.             $student->mergeStanding($profile->getStanding());
  107.         }
  109.         // save the student
  110.         $this->em->save(
  111.             $student
  112.         );
  113.     }
  114. }