src/Platform/SecurityBundle/Listeners/OneRoster/OneRosterProcessOrgSubscriber.php line 50

Open in your IDE?
  1. <?php
  3. namespace Platform\SecurityBundle\Listeners\OneRoster;
  5. use Cms\CoreBundle\Entity\AbstractOneRosterEntity;
  6. use Cms\CoreBundle\Entity\OneRoster\OneRosterOrg;
  7. use Cms\CoreBundle\Entity\OneRosterSync;
  8. use Cms\CoreBundle\Events\OneRosterProcessEvent;
  9. use Cms\CoreBundle\Model\Interfaces\OneRosterable\AbstractOneRosterableSubscriber;
  10. use Doctrine\Common\Util\ClassUtils;
  11. use Platform\SecurityBundle\Entity\Identity\Group;
  13. /**
  14.  * Class OneRosterProcessUserSubscriber
  15.  * @package Platform\SecurityBundle\Listeners\OneRoster
  16.  */
  17. final class OneRosterProcessOrgSubscriber extends AbstractOneRosterableSubscriber
  18. {
  19.     // NEW
  20.     const ALIASES = [
  21.         'oneroster.school.all' => [
  22.             AbstractOneRosterEntity::ENUMS__ROLE_TYPE__ADMINISTRATOR,
  23.             AbstractOneRosterEntity::ENUMS__ROLE_TYPE__AIDE,
  24.             AbstractOneRosterEntity::ENUMS__ROLE_TYPE__PROCTOR,
  25.             AbstractOneRosterEntity::ENUMS__ROLE_TYPE__TEACHER,
  26.             AbstractOneRosterEntity::ENUMS__ROLE_TYPE__STAFF,
  27.         ],
  28.         'oneroster.school.'.AbstractOneRosterEntity::ENUMS__ROLE_TYPE__ADMINISTRATOR => [AbstractOneRosterEntity::ENUMS__ROLE_TYPE__ADMINISTRATOR],
  29.         'oneroster.school.'.AbstractOneRosterEntity::ENUMS__ROLE_TYPE__AIDE => [AbstractOneRosterEntity::ENUMS__ROLE_TYPE__AIDE],
  30.         'oneroster.school.'.AbstractOneRosterEntity::ENUMS__ROLE_TYPE__PROCTOR => [AbstractOneRosterEntity::ENUMS__ROLE_TYPE__PROCTOR],
  31.         'oneroster.school.'.AbstractOneRosterEntity::ENUMS__ROLE_TYPE__TEACHER => [AbstractOneRosterEntity::ENUMS__ROLE_TYPE__TEACHER],
  32.         'oneroster.school.'.AbstractOneRosterEntity::ENUMS__ROLE_TYPE__STAFF => [AbstractOneRosterEntity::ENUMS__ROLE_TYPE__STAFF],
  33.     ];
  35.     /**
  36.      * {@inheritdoc}
  37.      */
  38.     static public function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             OneRosterProcessEvent::EVENT__ORG => [
  42.                 ['groupsSync', 1],
  43.             ],
  44.         ];
  45.     }
  47.     /**
  48.      * @param OneRosterProcessEvent $event
  49.      */
  50.     public function groupsSync(OneRosterProcessEvent $event): void
  51.     {
  52.         // ensure we are meant to process this
  53.         if ( ! $this->checkTypes($event->getSync(), [
  54.             OneRosterSync::STRATEGIES__SSO,
  55.         ])) {
  56.             return;
  57.         }
  59.         // get the org
  60.         $org = $event->getEntity();
  61.         if ( ! $org instanceof OneRosterOrg) {
  62.             throw new \Exception(sprintf(
  63.                 'SSO: Org is not of proper type, got "%s".',
  64.                 ClassUtils::getClass($org)
  65.             ));
  66.         }
  68.         // holder for groups to make
  69.         $groups = [];
  71.         // NEW: loop over all the groups we need to make
  72.         foreach (array_keys(self::ALIASES) as $base) {
  74.             // generate the exact alias
  75.             $alias = sprintf(
  76.                 '%s.%s',
  77.                 $base,
  78.                 $org->getSourcedId()
  79.             );
  81.             // attempt to load the group by alias
  82.             $group = $this->em->getRepository(Group::class)->findOneBy([
  83.                 'alias' => $alias,
  84.             ]);
  86.             // now if null, we need to make a new one
  87.             if (empty($group)) {
  88.                 $group = new Group();
  89.             }
  91.             // update fields on the account
  92.             $group
  93.                 ->setName($this->translator->trans(
  94.                     sprintf(
  95.                         'campussuite.platform.security.groups.aliases.%s',
  96.                         $base
  97.                     ),
  98.                     [
  99.                         '%org%' => $org->getName(),
  100.                     ]
  101.                 ))
  102.                 ->setAlias($alias)
  103.                 ->setFixed(true)
  104.                 ->setOneRosterId($org->getSourcedId())
  105.             ;
  107.             // attach to array of things to save
  108.             $groups[] = $group;
  110.         }
  112.         // cache the output
  113.         $output = array_map(
  114.             function (Group $grp) {
  115.                 return sprintf(
  116.                     '    %s    %s    (%s | %s | %s)',
  117.                     ((empty($grp->getId())) ? 'Generating' : 'Updating'),
  118.                     ClassUtils::getClass($grp),
  119.                     $grp->getName(),
  120.                     $grp->getOneRosterId(),
  121.                     $grp->getId() ?: '-'
  122.                 );
  123.             },
  124.             $groups
  125.         );
  127.         // let's save the groups
  128.         $this->em->saveAll($groups);
  130.         // DEBUGGING
  131.         $event->getOutput()->writeln($output);
  132.     }
  133. }