src/Component/CompanyMatch/EventSubscriber/CompanyMatchUserSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Component\CompanyMatch\EventSubscriber;
  7. use App\Component\CompanyMatch\ApproachStrategy;
  8. use App\Component\CompanyMatch\Calculator\ApproachCalculator;
  9. use App\Component\CompanyMatch\Event\CompanyMatchUserEvent;
  10. use App\Component\CompanyMatch\Message\InvalidateCompanyMatchUserCompanies;
  11. use App\Component\CompanyMatch\Message\MailCompaniesToApproach;
  12. use App\Component\CompanyMatch\Util\CompanyMatchUserHistorian;
  13. use App\Entity\Company;
  14. use App\Entity\CompanyMatchUser;
  15. use App\Entity\SiteUserData;
  16. use Doctrine\Common\Collections\ArrayCollection;
  17. use Doctrine\Common\Collections\Collection;
  18. use Doctrine\ORM\EntityManagerInterface;
  19. use Doctrine\ORM\PersistentCollection;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\Messenger\MessageBusInterface;
  23. class CompanyMatchUserSubscriber implements EventSubscriberInterface
  24. {
  25.     public function __construct(
  26.         protected readonly ApproachCalculator $approachCalculator,
  27.         protected readonly MessageBusInterface $messageBus,
  28.         protected readonly CompanyMatchUserHistorian $companyMatchUserHistorian,
  29.         protected readonly EntityManagerInterface $entityManager,
  30.     ) {
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             CompanyMatchUserEvent::class => 'preUpdate',
  37.         ];
  38.     }
  40.     public function preUpdate(CompanyMatchUserEvent $event): void
  41.     {
  42.         $this->checkCompanies($event);
  43.     }
  45.     private function checkCompanies(CompanyMatchUserEvent $event): void
  46.     {
  47.         $siteUserData = $event->getUser();
  48.         if (!\is_int($siteUserData->getId())) {
  49.             return;
  50.         }
  52.         $companyCollection = $this->approachCalculator->calculateApproachableCompaniesCollection($siteUserData);
  53.         $this->messageBus->dispatch(new MailCompaniesToApproach($companyCollection, $siteUserData->getId()));
  55.         $removableCompanies = $this->calculateRemoveableCompanies($siteUserData);
  56.         if (0 !== \count($removableCompanies)) {
  57.             $this->messageBus->dispatch(new InvalidateCompanyMatchUserCompanies($removableCompanies, $siteUserData->getId()));
  58.         }
  60.         $this->entityManager->persist($siteUserData);
  61.         $this->entityManager->flush();
  62.     }
  64.     /**
  65.      * @return Collection<int, Company>
  66.      */
  67.     private function calculateRemoveableCompanies(SiteUserData $siteUserData): Collection
  68.     {
  69.         $relatedCompaniesMatches = $this->companyMatchUserHistorian->findHistoryForUser($siteUserData);
  71.         $companies = $relatedCompaniesMatches->map(fn (CompanyMatchUser $companyMatchUser) => $companyMatchUser->getCompany());
  72.         if (ApproachStrategy::NotApproachable === $siteUserData->getApproachStrategy()) {
  73.             return $companies;
  74.         }
  76.         if (ApproachStrategy::SpecificallyApproachable === $siteUserData->getApproachStrategy()) {
  77.             if (!$siteUserData->hasCompaniesAllowedToApproach()) {
  78.                 return $companies;
  79.             }
  81.             /** @var PersistentCollection<int, Company> $collection */
  82.             $collection = $siteUserData->getCompaniesAllowedToApproach();
  83.             /** @var Company[] $deleteDiff */
  84.             $deleteDiff = $collection->getDeleteDiff();
  86.             return new ArrayCollection($deleteDiff);
  87.         }
  89.         return new ArrayCollection();
  90.     }
  91. }