src/Cms/CoreBundle/EventSubscriber/OneRoster/OneRosterTidySubscriber.php line 80

Open in your IDE?
  1. <?php
  3. namespace Cms\CoreBundle\EventSubscriber\OneRoster;
  5. use App\Model\Query\ConditionQuery\ConditionConfig;
  6. use Cms\CoreBundle\Entity\OneRosterJob;
  7. use Cms\CoreBundle\Events\OneRosterEvents;
  8. use Cms\CoreBundle\Service\OneRosterService;
  9. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  10. use Exception;
  11. use Platform\QueueBundle\Event\AsyncEvent;
  12. use Platform\QueueBundle\Service\AsyncQueueService;
  13. use Products\NotificationsBundle\Service\Builder\ConditionDictionaryBuilder;
  14. use Products\NotificationsBundle\Service\Notifications\NotificationsConfigService;
  15. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  16. use Symfony\Contracts\Translation\TranslatorInterface;
  18. /**
  19.  * Class OneRosterTidySubscriber
  20.  * @package Cms\CoreBundle\EventSubscriber\OneRoster
  21.  */
  22. final class OneRosterTidySubscriber extends AbstractOneRosterSubscriber
  23. {
  24.     /**
  25.      * @var NotificationsConfigService
  26.      */
  27.     private NotificationsConfigService $notificationsConfigService;
  29.     /**
  30.      * @var ConditionDictionaryBuilder
  31.      */
  32.     private ConditionDictionaryBuilder $conditionDictionaryBuilder;
  34.     /**
  35.      * @param EntityManager $em
  36.      * @param AsyncQueueService $async
  37.      * @param OneRosterService $oneroster
  38.      * @param EventDispatcherInterface $dispatcher
  39.      * @param NotificationsConfigService $notificationsConfigService
  40.      * @param ConditionDictionaryBuilder $conditionDictionaryBuilder
  41.      */
  42.     public function __construct(
  43.         EntityManager $em,
  44.         AsyncQueueService $async,
  45.         OneRosterService $oneroster,
  46.         EventDispatcherInterface $dispatcher,
  47.         NotificationsConfigService $notificationsConfigService,
  48.         ConditionDictionaryBuilder $conditionDictionaryBuilder
  50.     ) {
  51.         parent::__construct($em, $async, $oneroster, $dispatcher);
  53.         $this->notificationsConfigService = $notificationsConfigService;
  54.         $this->conditionDictionaryBuilder = $conditionDictionaryBuilder;
  55.     }
  57.     /**
  58.      * {@inheritDoc}
  59.      */
  60.     public static function getSubscribedEvents(): array
  61.     {
  62.         return [
  63.             OneRosterEvents::EVENT__TIDY => [
  64.                 ['discardableDisable', self::PRIORITY__FIRST],
  65.                 ['phaseStart', self::PRIORITY__FIRST],
  66.                 //['ssoGroupsCleanup', 0],
  67.                 ['phaseFin', self::PRIORITY__LAST],
  68.                 ['phaseTrigger', self::PRIORITY__LAST],
  69.                 ['discardableEnable', self::PRIORITY__LAST],
  70.                 ['syncNotificationDictionaries', 0],
  71.             ],
  72.         ];
  73.     }
  75.     /**
  76.      * @param AsyncEvent $event
  77.      * @return void
  78.      * @throws Exception
  79.      */
  80.     public function syncNotificationDictionaries(AsyncEvent $event): void
  81.     {
  82.         $job = $this->loadJob($event);
  84.         $event->getOutput()->writeln(
  85.             sprintf(
  86.                 'Notification dictionaries sync #%s loaded',
  87.                 $job->getIdentifier()
  88.             )
  89.         );
  91.         $tenant = $job->getTenant();
  92.         $this->notificationsConfigService->saveNotificationsBaseConfig(
  93.             $tenant,
  94.             new ConditionConfig([], $this->conditionDictionaryBuilder->build($tenant)),
  95.         );
  96.     }
  98.     /**
  99.      * {@inheritDoc}
  100.      */
  101.     public function phase(): int
  102.     {
  103.         return OneRosterJob::PHASES__TIDY;
  104.     }
  106.     /**
  107.      * {@inheritDoc}
  108.      */
  109.     public function next(): ?int
  110.     {
  111.         return null;
  112.     }
  113. }