vendor/ibexa/scheduler/src/lib/Event/Subscriber/QuickReviewEventSubscriber.php line 56

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. declare(strict_types=1);
  9. namespace Ibexa\Scheduler\Event\Subscriber;
  11. use Ibexa\Contracts\Core\Repository\NotificationService;
  12. use Ibexa\Contracts\Scheduler\Repository\DateBasedPublishServiceInterface;
  13. use Ibexa\Scheduler\ValueObject\NotificationFactory;
  14. use JMS\TranslationBundle\Annotation\Desc;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Workflow\Event\CompletedEvent;
  17. use Symfony\Contracts\Translation\TranslatorInterface;
  19. class QuickReviewEventSubscriber implements EventSubscriberInterface
  20. {
  21.     /** @var \Ibexa\Contracts\Scheduler\Repository\DateBasedPublishServiceInterface */
  22.     private $dateBasedPublisherService;
  24.     /** @var \Ibexa\Contracts\Core\Repository\NotificationService */
  25.     private $notificationService;
  27.     /** @var \Ibexa\Scheduler\ValueObject\NotificationFactory */
  28.     private $notificationFactory;
  30.     /** @var \Symfony\Contracts\Translation\TranslatorInterface */
  31.     private $translator;
  33.     public function __construct(
  34.         DateBasedPublishServiceInterface $dateBasedPublisherService,
  35.         NotificationService $notificationService,
  36.         NotificationFactory $notificationFactory,
  37.         TranslatorInterface $translator
  38.     ) {
  39.         $this->dateBasedPublisherService = $dateBasedPublisherService;
  40.         $this->notificationService = $notificationService;
  41.         $this->notificationFactory = $notificationFactory;
  42.         $this->translator = $translator;
  43.     }
  45.     public static function getSubscribedEvents(): array
  46.     {
  47.         return [
  48.             'workflow.quick_review.completed' => ['onQuickReview', 0],
  49.         ];
  50.     }
  52.     /**
  53.      * @throws \Ibexa\Contracts\Core\Repository\Exceptions\InvalidArgumentException
  54.      * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
  55.      */
  56.     public function onQuickReview(CompletedEvent $event)
  57.     {
  58.         /** @var \Ibexa\Contracts\Core\Repository\Values\Content\Content $content */
  59.         $content = $event->getSubject();
  61.         $scheduledVersions = $this->dateBasedPublisherService->getVersionsEntriesForContent($content->id);
  63.         /** @var \Ibexa\Contracts\Scheduler\ValueObject\ScheduledEntry $scheduledVersion */
  64.         foreach ($scheduledVersions as $scheduledVersion) {
  65.             $this->dateBasedPublisherService->unschedulePublish(
  66.                 $scheduledVersion->versionInfo->id
  67.             );
  69.             $createStruct = $this->notificationFactory->getNotificationCreateStruct($scheduledVersion, NotificationFactory::TYPE_UNSCHEDULED);
  70.             $createStruct->data['message'] = $this->translator->trans(/** @Desc("Content sent to review") */
  71.                 'content.in_review',
  72.                 [],
  73.                 'ibexa_scheduler'
  74.             );
  76.             $this->notificationService->createNotification($createStruct);
  77.         }
  78.     }
  79. }
  81. class_alias(QuickReviewEventSubscriber::class, 'EzSystems\DateBasedPublisher\Core\Event\Subscriber\QuickReviewEventSubscriber');