src/Subscriber/User/WebcamSubscriber.php line 58

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\User;
  5. use App\Event\User\LivecamOfflineEvent;
  6. use App\Event\User\LivecamOnlineEvent;
  7. use App\Service\ActivityFeedService;
  8. use App\Service\MemberService;
  9. use App\Service\User\MemberOnlineService;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class WebcamSubscriber implements EventSubscriberInterface
  13. {
  14.     protected MemberService $memberService;
  16.     protected ActivityFeedService $activityFeed;
  18.     protected MemberOnlineService $memberOnlineService;
  20.     public function __construct(MemberService $memberService, MemberOnlineService $memberOnlineService,
  21.         ActivityFeedService $activityFeed)
  22.     {
  23.         $this->memberService = $memberService;
  24.         $this->memberOnlineService = $memberOnlineService;
  25.         $this->activityFeed = $activityFeed;
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             LivecamOnlineEvent::class => [
  32.                 ['onWebcamOnlineSetMemberFlag', 0],
  33.                 ['onWebcamOnlineUpdateMemberOnline', 1],
  34.             ],
  35.             LivecamOfflineEvent::class => [
  36.                 ['onWebcamOfflineSetMemberFlag', 0],
  37.             ],
  38.         ];
  39.     }
  41.     /**
  42.      * @throws \Doctrine\ORM\ORMException
  43.      * @throws \Doctrine\ORM\OptimisticLockException
  44.      */
  45.     public function onWebcamOnlineSetMemberFlag(LivecamOnlineEvent $event)
  46.     {
  47.         $member = $event->getMember();
  48.         $member->setIsWebcamActive(true);
  49.         $this->memberService->storeMember($member);
  50.     }
  52.     /**
  53.      * @return void
  54.      *
  55.      * @throws \Doctrine\ORM\ORMException
  56.      * @throws \Doctrine\ORM\OptimisticLockException
  57.      */
  58.     public function onWebcamOnlineUpdateMemberOnline(LivecamOnlineEvent $event)
  59.     {
  60.         $member = $event->getMember();
  61.         if (!$existing = $this->memberOnlineService->getMemberOnlineByMember($member)) {
  62.             $existing = $this->memberOnlineService->createOnlineStatusForMember($member);
  63.         }
  64.         $this->memberOnlineService->refreshMemberOnlineStatus($existing);
  65.     }
  67.     /**
  68.      * @throws \Doctrine\ORM\ORMException
  69.      * @throws \Doctrine\ORM\OptimisticLockException
  70.      */
  71.     public function onWebcamOfflineSetMemberFlag(LivecamOfflineEvent $event)
  72.     {
  73.         $member = $event->getMember();
  74.         $member->setIsWebcamActive(false);
  75.         $this->memberService->storeMember($member);
  76.     }
  77. }