src/Subscriber/Guestbook/NotificationSubscriber.php line 98

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Guestbook;
  5. use App\Entity\Member;
  6. use App\Event\Guestbook\GuestbookEntryAcceptedEvent;
  7. use App\Event\Guestbook\GuestbookEntryCreatedEvent;
  8. use App\Event\RedisEventManager;
  9. use App\Event\User\RegistrationEvent;
  10. use App\Service\Media\MemberMediaService;
  11. use App\Subscriber\AbstractRedisEventManagerSubscriber;
  12. use Frivol\Common\Service\Notification\Activity\NewRegistrationActivity;
  13. use Frivol\Common\Service\Notification\GuestbookAcceptedNotification;
  14. use Frivol\Common\Service\Notification\GuestbookCreatedNotification;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Routing\RouterInterface;
  18. class NotificationSubscriber extends AbstractRedisEventManagerSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var MemberMediaService
  22.      */
  23.     protected $memberMediaService;
  25.     /**
  26.      * NotificationSubscriber constructor.
  27.      */
  28.     public function __construct(MemberMediaService $memberMediaService, RedisEventManager $redisEventManager,
  29.         RouterInterface $router)
  30.     {
  31.         $this->memberMediaService = $memberMediaService;
  33.         parent::__construct($redisEventManager, $router);
  34.     }
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             GuestbookEntryCreatedEvent::class => [
  40.                 ['onNewGuestbookEntryCreateNotification', 0],
  41.             ],
  42.             GuestbookEntryAcceptedEvent::class => [
  43.                 ['onAcceptedCreateNotification', 0],
  44.             ],
  45.             RegistrationEvent::class => [
  46.                 ['onRegistrationSendActivityNotification', 0],
  47.             ],
  48.         ];
  49.     }
  51.     public function onAcceptedCreateNotification(GuestbookEntryAcceptedEvent $event)
  52.     {
  53.         $sender = $event->getEntry()->getSender();
  54.         $recipient = $event->getEntry()->getRecipient();
  56.         $notification = new GuestbookAcceptedNotification();
  57.         $notification->setData([
  58.             'username' => $recipient->getUsername(),
  59.             'image' => $this->getMediaUrl($recipient),
  60.             'url' => $this->getGuestbookRoute($recipient),
  61.         ]);
  62.         $this->getRedisEventManager()->publishToMemberWithFrom($sender, $recipient, $notification);
  63.     }
  65.     /**
  66.      * @throws \Exception
  67.      */
  68.     public function onNewGuestbookEntryCreateNotification(GuestbookEntryCreatedEvent $event)
  69.     {
  70.         $sender = $event->getEntry()->getSender();
  71.         $recipient = $event->getEntry()->getRecipient();
  73.         $notification = new GuestbookCreatedNotification();
  74.         $notification->setData([
  75.             'username' => $sender->getUsername(),
  76.             'image' => $this->getMediaUrl($sender),
  77.             'toUsername' => $recipient->getUsername(),
  78.         ]);
  79.         $this->getRedisEventManager()->publishToMemberWithFrom($sender, $recipient, $notification);
  80.     }
  82.     public function getMediaUrl(Member $sender): ?string
  83.     {
  84.         if (!$sender->getMainPhoto()) {
  85.             return null;
  86.         }
  88.         return $this->memberMediaService->getUrlForMemberMedia($sender->getMainPhoto(), false, '100x100');
  89.     }
  91.     public function getGuestbookRoute(Member $member): string
  92.     {
  93.         return $this->getRouter()->generate('frivol_frontend_profile_user', [
  94.             'username' => $member->getUsername(),
  95.         ]).'/gaestebuch';
  96.     }
  98.     public function onRegistrationSendActivityNotification(RegistrationEvent $event): void
  99.     {
  100.         if (!$event->getAccount() || !$event->getAccount()->getMember()) {
  101.             return;
  102.         }
  104.         $notification = new NewRegistrationActivity();
  105.         $notification->setFromMemberId($event->getAccount()->getMember()->getId());
  106.         $notification->setFromUsername($event->getAccount()->getMember()->getUsername());
  107.         $this->getRedisEventManager()->publishToHomepage($notification);
  108.     }
  109. }