src/Subscriber/Livecam/LivecamLogSubscriber.php line 75

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Livecam;
  5. use App\Dictionary\LivecamLogStatus;
  6. use App\Dictionary\LiveChatMessageSource;
  7. use App\Event\Livecam\LivecamLogCreatedEvent;
  8. use App\Event\Livecam\LivecamLogFinishedEvent;
  9. use App\Event\Livecam\LivecamLogUpdatedEvent;
  10. use App\Lib\Purchase\LivecamPurchase;
  11. use App\Service\Livecam\LiveChatMessageService;
  12. use App\Service\Payment\PurchaseService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class LivecamLogSubscriber implements EventSubscriberInterface
  16. {
  17.     protected PurchaseService $service;
  19.     protected LiveChatMessageService $messageService;
  21.     public function __construct(LiveChatMessageService $messageService, PurchaseService $service)
  22.     {
  23.         $this->messageService = $messageService;
  24.         $this->service = $service;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             LivecamLogFinishedEvent::class => [
  31.                 ['onLivecamFinishedCreatePurchase', 0],
  32.                 ['onLivecamFinishedSendLiveChatMessage', 1],
  33.             ],
  34.             LivecamLogUpdatedEvent::class => [
  35.                 ['onLivecamLogUpdatedSendCoinUpdate', 0],
  36.             ],
  37.             LivecamLogCreatedEvent::class => [
  38.                 ['onLivecamLogCreatedSendLiveChatMessage', 0],
  39.             ],
  40.         ];
  41.     }
  43.     /**
  44.      * @return void
  45.      *
  46.      * @throws \App\Exception\Purchase\CoinsLockedException
  47.      * @throws \App\Exception\Purchase\InsufficientCoinsException
  48.      * @throws \Doctrine\ORM\ORMException
  49.      * @throws \Doctrine\ORM\OptimisticLockException
  50.      */
  51.     public function onLivecamFinishedCreatePurchase(LivecamLogFinishedEvent $event)
  52.     {
  53.         $entity = $event->getEntity();
  54.         if (LivecamLogStatus::FINISHED !== $entity->getState()) {
  55.             return;
  56.         }
  58.         $coins = $entity->getUsedCoins();
  59.         if (0 === $coins) {
  60.             return;
  61.         }
  62.         $consumer = $entity->getConsumer();
  63.         if ($consumer->getIsAmateur() || $consumer->getAccount()->getAdmin()) {
  64.             // no money transfer
  65.             return;
  66.         }
  68.         $purchase = new LivecamPurchase($entity->getAmateur(), $coins, $entity->getId());
  69.         $this->service->handlePurchase($purchase, $entity->getConsumer());
  70.     }
  72.     /**
  73.      * @return void
  74.      */
  75.     public function onLivecamLogUpdatedSendCoinUpdate(LivecamLogUpdatedEvent $event)
  76.     {
  77.     }
  79.     /**
  80.      * @return void
  81.      *
  82.      * @throws \Doctrine\ORM\ORMException
  83.      * @throws \Doctrine\ORM\OptimisticLockException
  84.      */
  85.     public function onLivecamLogCreatedSendLiveChatMessage(LivecamLogCreatedEvent $event)
  86.     {
  87.         $sender = $event->getEntity()->getConsumer();
  88.         $message = $this->messageService->createLiveChatMessageBySender($sender);
  89.         $message->setSource(LiveChatMessageSource::SYSTEM);
  90.         $message->setMessage('Ich habe Deine Cam betreten.');
  92.         $recipient = $event->getEntity()->getAmateur();
  93.         $this->messageService->sendLiveChatMessageToRecipient($message, $recipient);
  94.     }
  96.     /**
  97.      * @return void
  98.      *
  99.      * @throws \Doctrine\ORM\ORMException
  100.      * @throws \Doctrine\ORM\OptimisticLockException
  101.      */
  102.     public function onLivecamFinishedSendLiveChatMessage(LivecamLogFinishedEvent $event)
  103.     {
  104.         $entity = $event->getEntity();
  105.         if (LivecamLogStatus::FINISHED !== $entity->getState()) {
  106.             return;
  107.         }
  109.         $sender = $event->getEntity()->getConsumer();
  110.         $message = $this->messageService->createLiveChatMessageBySender($sender);
  111.         $message->setSource(LiveChatMessageSource::SYSTEM);
  112.         $message->setMessage('Ich habe Deine Cam verlassen.');
  114.         $recipient = $event->getEntity()->getAmateur();
  115.         $this->messageService->sendLiveChatMessageToRecipient($message, $recipient);
  116.     }
  117. }