src/TeclaConnector/EventSubscriber/SynchronizeUpdatedContactSubscriber.php line 50

  1. <?php
  3. declare(strict_types=1);
  4. /**
  5.  * Copyright (c) 2020 TECLA Consulting Group oü.
  6.  * All rights reserved.
  7.  *
  8.  * This unpublished material is proprietary to TECLA Consulting Group oü.
  9.  * All rights reserved. The methods and
  10.  * techniques described herein are considered trade secrets
  11.  * and/or confidential. Reproduction or distribution, in whole
  12.  * or in part, is forbidden except by express written permission
  13.  * of TECLA Consulting Group oü.
  14.  *
  15.  * @author    Matúš Sýkorjak <matus@tecla.no>
  16.  * @copyright 2020 TECLA Consulting Group oü
  17.  */
  19. namespace App\TeclaConnector\EventSubscriber;
  21. use App\Contact\Event\ContactUpdatedEvent;
  22. use App\TeclaConnector\Exception\Synchronizer\LegacySynchronizerFailedExceptionInterface;
  23. use App\TeclaConnector\Service\FailedLegacySynchronizerServiceInterface;
  24. use App\TeclaConnector\Synchronizer\Contact\LegacyUpdateSynchronizerInterface;
  25. use JetBrains\PhpStorm\ArrayShape;
  26. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  28. final class SynchronizeUpdatedContactSubscriber implements EventSubscriberInterface
  29. {
  30.     private LegacyUpdateSynchronizerInterface $updatedContactSynchronizer;
  32.     private FailedLegacySynchronizerServiceInterface $failedSynchronizerService;
  34.     public function __construct(
  35.         LegacyUpdateSynchronizerInterface $updatedContactSynchronizer,
  36.         FailedLegacySynchronizerServiceInterface $failedSynchronizerService
  37.     ) {
  38.         $this->updatedContactSynchronizer = $updatedContactSynchronizer;
  39.         $this->failedSynchronizerService = $failedSynchronizerService;
  40.     }
  42.     #[ArrayShape([ContactUpdatedEvent::class => 'string'])]
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             ContactUpdatedEvent::class => 'onContactUpdated',
  47.         ];
  48.     }
  50.     public function onContactUpdated(ContactUpdatedEvent $event): void
  51.     {
  52.         if (false === $event->getSynchronize()) {
  53.             return;
  54.         }
  56.         $contact = $event->getContact();
  58.         try {
  59.             $this->updatedContactSynchronizer->synchronize($contact);
  60.         } catch (LegacySynchronizerFailedExceptionInterface $e) {
  61.             $this->failedSynchronizerService->create($e->getSynchronizerRequest());
  62.         }
  63.     }
  64. }