src/App/Subscriber/Sharing/SharingSubscriber.php line 47

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Sharing;
  5. use App\Entity\Content\AbstractObject;
  6. use App\Enum\ChannelEnum;
  7. use App\Service\Sharing\SharingHandlerInterface;
  8. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  9. use Platform\QueueBundle\Event\AsyncEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. final class SharingSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var EntityManager
  16.      */
  17.     private EntityManager $em;
  19.     /**
  20.      * @var SharingHandlerInterface
  21.      */
  22.     private SharingHandlerInterface $sharingHandler;
  24.     /**
  25.      * @param EntityManager $em
  26.      * @param SharingHandlerInterface $sharingHandler
  27.      */
  28.     public function __construct(EntityManager $em, SharingHandlerInterface $sharingHandler)
  29.     {
  30.         $this->em = $em;
  31.         $this->sharingHandler = $sharingHandler;
  32.     }
  34.     /**
  35.      * {@inheritDoc}
  36.      */
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             SharingHandlerInterface::EVENTS__SHARE_CHANNEL => ['onShareChannel', 0],
  41.         ];
  42.     }
  44.     /**
  45.      * @param AsyncEvent $event
  46.      */
  47.     public function onShareChannel(AsyncEvent $event): void
  48.     {
  49.         $object = $this->em->getRepository(AbstractObject::class)->find(
  50.             $event->getBody()->get('object'),
  51.         );
  52.         if ( ! $object instanceof AbstractObject) {
  53.             throw new \RuntimeException();
  54.         }
  56.         $event->getOutput()->writeln(
  57.             sprintf(
  58.                 'Sharing to channel %s...',
  59.                 array_search(
  60.                     $channel = $event->getBody()->get('channel'),
  61.                     ChannelEnum::SOCIAL_CHANNELS,
  62.                     true,
  63.                 ),
  64.             )
  65.         );
  67.         $this->sharingHandler->handleChannel(
  68.             $object,
  69.             $channel,
  70.         );
  72.         $event->getOutput()->writeln('Shared to channel.');
  73.     }
  74. }