src/Component/ExternalIntegration/EventSubscriber/SendApplicationSubscriber.php line 91

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Component\ExternalIntegration\EventSubscriber;
  7. use App\Component\ExternalIntegration\AbstractExternalIntegration;
  8. use App\Component\ExternalIntegration\DependencyInjection\ExternalIntegrationCollection;
  9. use App\Component\ExternalIntegration\Event\PostApplicantFailEvent;
  10. use App\Component\ExternalIntegration\Event\PostApplicantSuccessEvent;
  11. use App\Component\ExternalIntegration\Message\Command\SendApplication;
  12. use App\Component\GDPR\Anonymize\AnonymizeApplicant;
  13. use App\Enum\DataTypeEnum;
  14. use App\Event\ApplicantEvent;
  15. use App\Mail\NotificationAddress;
  16. use App\Mail\RecipientsByImportance;
  17. use App\Notification\ExternalApplicantNotification;
  18. use App\Util\TypeUtil;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Symfony\Component\Messenger\MessageBusInterface;
  21. use Symfony\Component\Notifier\NotifierInterface;
  23. class SendApplicationSubscriber implements EventSubscriberInterface
  24. {
  25.     public function __construct(
  26.         private readonly ExternalIntegrationCollection $externalIntegrationCollection,
  27.         private readonly MessageBusInterface $messageBus,
  28.         private readonly AnonymizeApplicant $anonymizeApplicant,
  29.         private readonly NotifierInterface $notifier,
  30.         private readonly RecipientsByImportance $recipientsByImportance,
  31.         private readonly NotificationAddress $notificationAddress,
  32.     ) {
  33.     }
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             ApplicantEvent::EVENT_POST_PERSIST => 'onApplicantPostPersist',
  39.             PostApplicantSuccessEvent::class => 'onPostApplicantSuccess',
  40.             PostApplicantFailEvent::class => 'onPostApplicantFail',
  41.         ];
  42.     }
  44.     public function onApplicantPostPersist(ApplicantEvent $applicantEvent): void
  45.     {
  46.         $applicant = $applicantEvent->getApplicant();
  47.         $externalReference = $applicant->getExternalVacancyReference() ?? '';
  49.         if (!TypeUtil::checkTypeAndTruthy($externalReference, DataTypeEnum::STRING)
  50.             && $this->externalIntegrationCollection->hasActiveExternalIntegrations()
  51.         ) {
  52.             $activeExternalIntegrations = $this->externalIntegrationCollection->getActiveExternalIntegrations();
  53.             /** @var AbstractExternalIntegration $firstActiveIntegration */
  54.             $firstActiveIntegration = reset($activeExternalIntegrations);
  55.             $externalReference = $firstActiveIntegration::getReference();
  56.         }
  58.         // only accept vacancies with valid external reference
  59.         if (!TypeUtil::checkTypeAndTruthy($externalReference, DataTypeEnum::STRING)
  60.             || !\is_int($applicant->getId())
  61.         ) {
  62.             return;
  63.         }
  65.         $this->messageBus->dispatch(new SendApplication($applicant->getId(), $externalReference));
  66.     }
  68.     public function onPostApplicantSuccess(PostApplicantSuccessEvent $event): void
  69.     {
  70.         $from = $this->notificationAddress->getFrom();
  71.         $applicant = $event->getApplicant();
  73.         if (\is_string($applicant->getExternalId())
  74.             && \is_string($applicant->getExternalCandidateId())
  75.         ) {
  76.             $this->anonymizeApplicant->anonymize($applicant);
  77.         } elseif ('' !== $from) {
  78.             $notification = ExternalApplicantNotification::create(
  79.                 $from,
  80.                 $event->getAts(),
  81.                 $applicant,
  82.                 'An Applicant could not be anonymized.'
  83.             );
  84.             $this->notifier->send(
  85.                 $notification,
  86.                 ...$this->recipientsByImportance->get($notification->getImportance())
  87.             );
  88.         }
  89.     }
  91.     public function onPostApplicantFail(PostApplicantFailEvent $event): void
  92.     {
  93.         $from = $this->notificationAddress->getFrom();
  95.         if ('' !== $from) {
  96.             $notification = ExternalApplicantNotification::create(
  97.                 $from,
  98.                 $event->getAts(),
  99.                 $event->getApplicant(),
  101.                 'Applicant could not be sent.'
  102.                 .\PHP_EOL
  103.                 .($event->getThrowable()?->getMessage() ?? 'There was no error message.')
  104.             );
  105.             $this->notifier->send($notification, ...$this->recipientsByImportance->get($notification->getImportance()));
  106.         }
  107.     }
  108. }