src/Modules/Chat/Event/Subscriber/UpdateContractChatParticipants.php line 67

Open in your IDE?
  1. <?php
  2. namespace App\Modules\Chat\Event\Subscriber;
  4. use App\Modules\Chat\Event\MessageSent;
  5. use App\Modules\Chat\Repository\ChatRepositoryInterface;
  6. use App\Modules\Contract\Repository\ContractRepositoryInterface;
  7. use App\Modules\Contract\ValueObject\Participant;
  8. use App\Modules\User\Event\AdministratorAddedToCircleMembers;
  9. use App\Modules\User\Event\CircleMemberUpdated;
  10. use App\Modules\User\Event\PartnerUpdated;
  11. use App\Modules\User\Service\RepresentativesService;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class UpdateContractChatParticipants implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var ChatRepositoryInterface
  18.      */
  19.     private $chatRepository;
  20.     /**
  21.      * @var ContractRepositoryInterface
  22.      */
  23.     private $contractRepository;
  24.     /**
  25.      * @var RepresentativesService
  26.      */
  27.     private $representativesService;
  29.     public function __construct(
  30.         ChatRepositoryInterface $chatRepository,
  31.         ContractRepositoryInterface $contractRepository,
  32.         RepresentativesService $representativesService
  33.     )
  34.     {
  35.         $this->chatRepository = $chatRepository;
  36.         $this->contractRepository = $contractRepository;
  37.         $this->representativesService = $representativesService;
  38.     }
  40.     /**
  41.      * Returns an array of event names this subscriber wants to listen to.
  42.      *
  43.      * The array keys are event names and the value can be:
  44.      *
  45.      *  * The method name to call (priority defaults to 0)
  46.      *  * An array composed of the method name to call and the priority
  47.      *  * An array of arrays composed of the method names to call and respective
  48.      *    priorities, or 0 if unset
  49.      *
  50.      * For instance:
  51.      *
  52.      *  * ['eventName' => 'methodName']
  53.      *  * ['eventName' => ['methodName', $priority]]
  54.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  55.      *
  56.      * @return array The event names to listen to
  57.      */
  58.     public static function getSubscribedEvents()
  59.     {
  60.         return [
  61.             PartnerUpdated::class => 'onPartnerUpdated',
  62.             CircleMemberUpdated::class => 'onCircleMemberUpdated',
  63.             AdministratorAddedToCircleMembers::class => 'onAdministratorAddedToCircleMember'
  64.         ];
  65.     }
  67.     public function onPartnerUpdated(PartnerUpdated $event)
  68.     {
  69.         $partner = $event->getPartner();
  71.         $participants[] = [
  72.             'id' => $partner->getId(),
  73.             'type' => Participant::PARTNER
  74.         ];
  76.         $this->updateParticipantsContractsChats($participants);
  77.     }
  79.     public function onCircleMemberUpdated(CircleMemberUpdated $event)
  80.     {
  81.         $circleMember = $event->getCircleMember();
  83.         $participants[] = [
  84.             'id' => $circleMember->getId(),
  85.             'type' => Participant::CIRCLE_MEMBER
  86.         ];
  88.         $this->updateParticipantsContractsChats($participants);
  89.     }
  91.     public function onAdministratorAddedToCircleMember(AdministratorAddedToCircleMembers $event)
  92.     {
  93.         $circleMembersIds = $event->getCircleMembersIds();
  94.         $participants = [];
  96.         foreach ($circleMembersIds as $circleMemberId) {
  97.             $participants[] = [
  98.                 'id' => $circleMemberId,
  99.                 'type' => Participant::CIRCLE_MEMBER
  100.             ];
  101.         }
  103.         $this->updateParticipantsContractsChats($participants);
  104.     }
  106.     private function updateParticipantsContractsChats(array $participants)
  107.     {
  108.         $contractsIds = $this->contractRepository->findIdsByParticipants($participants);
  110.         if (empty($contractsIds)) {
  111.             return;
  112.         }
  114.         $chats = $this->chatRepository->findByContracts($contractsIds);
  116.         foreach ($chats as $chat) {
  117.             if (!is_null($contract = $chat->getContract())) {
  118.                 $initiator = $contract->getInitiator();
  119.                 $executor = $contract->getExecutor();
  121.                 $initiatorRepresentatives = $this->representativesService->get($initiator->getId(), $initiator->getType());
  122.                 $executorRepresentatives = $this->representativesService->get($executor->getId(), $executor->getType());
  124.                 $chat->removeParticipants();
  125.                 $chat->addParticipant(... $initiatorRepresentatives);
  126.                 $chat->addParticipant(... $executorRepresentatives);
  128.                 $this->chatRepository->save($chat);
  129.             }
  130.         }
  131.     }
  132. }