src/EventSubscriber/KernelEventsSubscriber.php line 86

Open in your IDE?
  1. <?php
  4. namespace App\EventSubscriber;
  7. use ApiPlatform\Core\EventListener\EventPriorities;
  8. use App\Entity\MediaObject;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpKernel\Event\RequestEvent;
  13. use Symfony\Component\HttpKernel\Event\ViewEvent;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  15. use Doctrine\Common\Annotations\AnnotationReader as DocReader;
  16. use Doctrine\ORM\Mapping as ORM;
  17. use Symfony\Component\PropertyAccess\PropertyAccess;
  19. class KernelEventsSubscriber implements EventSubscriberInterface
  20. {
  22.     /**
  23.      * @var LoggerInterface
  24.      */
  25.     private $logger;
  27.     /**
  28.      * @var EntityManagerInterface
  29.      */
  30.     private $manager;
  32.     /**
  33.      * List of media objects to be deleted
  34.      * @var array
  35.      */
  36.     private $suppress = [];
  38.     public function __construct(LoggerInterface $logger, EntityManagerInterface $manager)
  39.     {
  40.         $this->logger = $logger;
  41.         $this->manager = $manager;
  42.     }
  44.     public static function getSubscribedEvents()
  45.     {
  46.         return [
  47.             KernelEvents::VIEW => ['removeMediaObjects', EventPriorities::PRE_WRITE],
  48.             KernelEvents::REQUEST => ['logMediaObjects', EventPriorities::PRE_DESERIALIZE],
  49.         ];
  50.     }
  52.     /**
  53.      * Logs the media objects to be removed later
  54.      * @param RequestEvent $event
  55.      */
  56.     public function logMediaObjects(RequestEvent $event)
  57.     {
  58.         $params = $event->getRequest()->attributes->get('_route_params', []);
  59.         if(isset($params['_api_item_operation_name']) && ($operation = $params['_api_item_operation_name']) === 'PATCH'){
  60.             $class = $params['_api_resource_class'];
  61.             $id = $params['id'];
  62.             $object = $this->manager->getRepository($class)->findOneBy(['id' => $id]);
  63.             try {
  64.                 $reflection = new \ReflectionClass($class);
  65.                 $reader = new DocReader();
  66.                 foreach ($reflection->getProperties() as $property) {
  67.                     $annotation = $reader->getPropertyAnnotation($property, ORM\ManyToOne::class);
  68.                     if ($annotation instanceof ORM\ManyToOne && $annotation->targetEntity == MediaObject::class){
  69.                         $propertyAccessor = PropertyAccess::createPropertyAccessor();
  70.                         $media = $propertyAccessor->getValue($object, $property->name);
  71.                         if ($media instanceof MediaObject){
  72.                             $this->suppress[$class][] = ['name' => $property->name, "id" => $media->getId()];
  73.                         }
  74.                     }
  75.                 }
  76.             } catch (\ReflectionException $e) {
  77.                 $this->logger->error("Unable to register media object: {$e->getMessage()}");
  78.             }
  79.         }
  80.     }
  82.     /**
  83.      * Removes the media objects logged to be removed
  84.      * @param ViewEvent $event
  85.      */
  86.     public function removeMediaObjects(ViewEvent $event)
  87.     {
  88.         $object = $event->getControllerResult();
  89.         if (is_object($object) && isset($this->suppress[get_class($object)])){
  90.             $propertyAccessor = PropertyAccess::createPropertyAccessor();
  91.             $properties = $this->suppress[get_class($object)];
  92.             foreach ($properties as $property) {
  93.                 $media = $propertyAccessor->getValue($object, $property['name']);
  94.                 if ($media instanceof MediaObject){
  95.                     $oldId = $property['id'];
  96.                     if ($oldId !== $media->getId()){
  97.                         $this->manager->remove($this->manager->getRepository(MediaObject::class)->findOneBy(['id' => $oldId]));
  98.                         $this->logger->info("Marked media object #$oldId for removal");
  99.                     }
  100.                 }
  101.             }
  102.             $this->manager->flush();
  103.         }
  104.     }
  105. }