src/EventSubscriber/KernelEventsSubscriber.php line 57

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