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');