src/Modules/Chat/Event/Subscriber/CreateChatForContract.php line 69

Open in your IDE?
  1. <?php
  2. namespace App\Modules\Chat\Event\Subscriber;
  4. use App\Modules\Chat\DTO\ChatDTO;
  5. use App\Modules\Chat\Entity\Chat;
  6. use App\Modules\Chat\Service\ChatService;
  7. use App\Modules\Contract\Entity\Contract;
  8. use App\Modules\Contract\StateMachine\FormState;
  9. use App\Modules\Contract\Event\ContractCreated;
  10. use App\Modules\Contract\Event\FormAccepted;
  11. use App\Modules\Contract\Event\FormDeclined;
  12. use App\Modules\Contract\Event\FormFinalized;
  13. use App\Modules\Contract\Event\FormUpdated;
  14. use App\Modules\Contract\Repository\ContractRepositoryInterface;
  15. use App\Modules\Contract\Service\ContractService;
  16. use App\Modules\Contract\ValueObject\FormValueObject;
  17. use App\Modules\User\Service\RepresentativesService;
  18. use Doctrine\Common\Collections\ArrayCollection;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class CreateChatForContract implements EventSubscriberInterface
  22. {
  24.     /**
  25.      * @var RepresentativesService
  26.      */
  27.     private $representativesService;
  28.     /**
  29.      * @var ChatService
  30.      */
  31.     private $chatService;
  32.     /**
  33.      * @var ContractRepositoryInterface
  34.      */
  35.     private $contractRepository;
  37.     public function __construct(RepresentativesService $representativesService, ChatService $chatService, ContractRepositoryInterface $contractRepository)
  38.     {
  39.         $this->representativesService = $representativesService;
  40.         $this->chatService = $chatService;
  41.         $this->contractRepository = $contractRepository;
  42.     }
  44.     /**
  45.      * Returns an array of event names this subscriber wants to listen to.
  46.      *
  47.      * The array keys are event names and the value can be:
  48.      *
  49.      *  * The method name to call (priority defaults to 0)
  50.      *  * An array composed of the method name to call and the priority
  51.      *  * An array of arrays composed of the method names to call and respective
  52.      *    priorities, or 0 if unset
  53.      *
  54.      * For instance:
  55.      *
  56.      *  * ['eventName' => 'methodName']
  57.      *  * ['eventName' => ['methodName', $priority]]
  58.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  59.      *
  60.      * @return array The event names to listen to
  61.      */
  62.     public static function getSubscribedEvents()
  63.     {
  64.         return [
  65.             ContractCreated::class => 'onContractCreated'
  66.         ];
  67.     }
  69.     public function onContractCreated(ContractCreated $event)
  70.     {
  71.         $contract = $event->getContract();
  73.         $chat = $this->createChat($contract);
  74.         $this->addChatToContract($contract, $chat);
  75.     }
  77.     private function createChat(Contract $contract): Chat
  78.     {
  79.         $initiator = $contract->getInitiator();
  80.         $executor = $contract->getExecutor();
  82.         $initiatorRepresentatives = $this->representativesService->get($initiator->getId(), $initiator->getType());
  83.         $executorRepresentatives = $this->representativesService->get($executor->getId(), $executor->getType());
  85.         $participants = new ArrayCollection();
  87.         foreach ($initiatorRepresentatives as $representative) {
  88.             $participants->add($representative);
  89.         }
  91.         foreach ($executorRepresentatives as $representative) {
  92.             $participants->add($representative);
  93.         }
  95.         $dto = new ChatDTO($participants);
  97.         $chat = $this->chatService->create($dto);
  99.         return $chat;
  100.     }
  102.     private function addChatToContract(Contract $contract, Chat $chat)
  103.     {
  104.         $contract->setChat($chat);
  106.         $this->contractRepository->save($contract);
  107.     }
  108. }