src/App/Subscriber/ProposalNotificationSubscriber.php line 31

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Subscriber;
  5. use App\Doctrine\Common\Cache\TaggedMemcachedCache;
  6. use App\Entity\Deal;
  7. use App\Entity\Project;
  8. use App\Entity\Proposal;
  9. use App\Event\ProposalCanceledEvent;
  10. use App\Event\ProposalFundedEvent;
  11. use App\Repository\Message\MessageReceptionRepository;
  12. use App\Service\NotificationMessageProvider;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class ProposalNotificationSubscriber implements EventSubscriberInterface
  16. {
  18.     private NotificationMessageProvider $notificationMessageProvider;
  20.     private TaggedMemcachedCache $taggedMemcachedCache;
  22.     private MessageReceptionRepository $messageReceptionRepository;
  24.     public function __construct(NotificationMessageProvider $notificationMessageProvider, MessageReceptionRepository $messageReceptionRepository, TaggedMemcachedCache $taggedMemcachedCache)
  25.     {
  26.         $this->notificationMessageProvider = $notificationMessageProvider;
  27.         $this->taggedMemcachedCache = $taggedMemcachedCache;
  28.         $this->messageReceptionRepository = $messageReceptionRepository;
  29.     }
  31.     public function onFunded(ProposalFundedEvent $event): void
  32.     {
  33.         $proposal = $event->getProposal();
  35.         if ($proposal instanceof Deal) {
  36.             $bidders = $this->getBiddersToNotify($proposal);
  38.             $dealSuccessMessage = $this->notificationMessageProvider->getDealSuccessfulNotification();
  39.             assert(null !== $dealSuccessMessage->getId());
  40.             $this->messageReceptionRepository->sendTo($dealSuccessMessage->getId(), $bidders, $this->taggedMemcachedCache, null, [
  41.                 'proposalTitle' => $proposal->getTitle(),
  42.                 'proposalStringId' => $proposal->getStringId(),
  43.             ]);
  44.         }
  45.     }
  47.     public function onCanceled(ProposalCanceledEvent $event): void
  48.     {
  49.         $proposal = $event->getProposal();
  51.         if ($proposal instanceof Deal) {
  52.             $bidders = $this->getBiddersToNotify($proposal);
  54.             $dealFailedMessage = $this->notificationMessageProvider->getDealFailedNotification();
  55.             assert(null !== $dealFailedMessage->getId());
  56.             $this->messageReceptionRepository->sendTo($dealFailedMessage->getId(), $bidders, $this->taggedMemcachedCache, null, [
  57.                 'proposalTitle' => $proposal->getTitle(),
  58.                 'proposalStringId' => $proposal->getStringId(),
  59.             ]);
  60.         }
  61.     }
  63.     /**
  64.      * @param Project|Deal $proposal
  65.      * @return array<int, int> $bidders
  66.      */
  67.     private function getBiddersToNotify(Proposal $proposal): array
  68.     {
  69.         $bidders = [];
  71.         foreach ($proposal->getBids() as $proposalBid) {
  72.             $bidUser = $proposalBid->getUser();
  74.             if (null === $bidUser->getId()) {
  75.                 continue;
  76.             }
  78.             if (isset($bidders[$bidUser->getId()])) {
  79.                 continue;
  80.             }
  82.             if (!$proposalBid->isJustRefunded() && ($proposalBid->isRefunded() || $proposalBid->isCanceled())) {
  83.                 continue;
  84.             }
  86.             $bidders[] = $bidUser->getId();
  87.         }
  89.         return $bidders;
  90.     }
  92.     /**
  93.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  94.      */
  95.     public static function getSubscribedEvents(): array
  96.     {
  97.         return [
  98.             ProposalFundedEvent::class => 'onFunded',
  99.             ProposalCanceledEvent::class => 'onCanceled',
  100.         ];
  101.     }
  103. }