src/EventSubscriber/RegistryEntryCreator.php line 52

  1. <?php
  2. namespace App\EventSubscriber;
  4. use Symfony\Component\EventDispatcher\EventSubscriberInterface,
  5.     Symfony\Component\HttpKernel\Event\ViewEvent,
  6.     Symfony\Component\HttpKernel\KernelEvents,
  7.     Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface,
  8.     Symfony\Component\HttpFoundation\Request;
  10. use ApiPlatform\Symfony\EventListener\EventPriorities,
  11.     ApiPlatform\Api\IriConverterInterface;
  13. use App\Entity\Admin,
  14.     App\Entity\RegistryEntry,
  15.     App\Repository\AdminRepository,
  16.     App\Repository\RegistryEntryRepository;
  18. final class RegistryEntryCreator implements EventSubscriberInterface
  19. {
  20.     const ATTRIBUTE_API_RESOURCE_CLASS = '_api_resource_class';
  21.     const ATTRIBUTE_API_OPERATION_NAME = '_api_operation_name';
  22.     const ATTRIBUTE_API_WRITE_ITEM_IRI = '_api_write_item_iri';
  23.     const ATTRIBUTE_UUID = 'uuid';
  24.     const ATTRIBUTE_DATA = 'data';
  26.     private AdminRepository $adminRepository;
  27.     private RegistryEntryRepository $registryEntryRepository;
  28.     private TokenStorageInterface $tokenStorage;
  29.     private IriConverterInterface $iriConverter;
  31.     public function __construct(
  32.         AdminRepository $adminRepository,
  33.         RegistryEntryRepository $registryEntryRepository,
  34.         TokenStorageInterface $tokenStorage,
  35.         IriConverterInterface $iriConverter
  36.     ) {
  37.         $this->adminRepository = $adminRepository;
  38.         $this->registryEntryRepository = $registryEntryRepository;
  39.         $this->tokenStorage = $tokenStorage;
  40.         $this->iriConverter = $iriConverter;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             KernelEvents::VIEW => [
  47.                 ['create', EventPriorities::POST_WRITE]
  48.             ]
  49.         ];
  50.     }
  52.     public function create(ViewEvent $event): void
  53.     {
  54.         if (! $event->isMainRequest()) {
  55.             return;
  56.         }
  58.         $admin = $this->tokenStorage->getToken()?->getUser();
  60.         if (! $admin instanceof Admin) {
  61.             return;
  62.         }
  64.         $admin->setLastActivityAt(new \DateTimeImmutable());
  66.         $this->adminRepository->persist($admin, true);
  68.         $request = $event->getRequest();
  69.         $resourceClass = $request->attributes->get(self::ATTRIBUTE_API_RESOURCE_CLASS);
  71.         if (! $resourceClass || $request->isMethod(Request::METHOD_GET)) {
  72.             return;
  73.         }
  75.         $registryEntry = new RegistryEntry(
  76.             admin: $admin,
  77.             username: $admin->getUserIdentifier(),
  78.             operationName: $request->attributes->get(self::ATTRIBUTE_API_OPERATION_NAME),
  79.             resourceClass: $request->attributes->get(self::ATTRIBUTE_API_RESOURCE_CLASS),
  80.             resourceUuid: $this->getResourceUuid($request),
  81.             inputData: $request->attributes->get(self::ATTRIBUTE_DATA),
  82.             requestMethod: $request->getMethod(),
  83.             requestUri: $request->getPathInfo(),
  84.             ip: $request->getClientIp() ?? 'unknown',
  85.         );
  87.         $this->registryEntryRepository->persist($registryEntry, true);
  89.         return;
  90.     }
  92.     private function getResourceUuid(Request $request): ?string
  93.     {
  94.         if ($request->attributes->get(self::ATTRIBUTE_UUID)) {
  95.             return $request->attributes->get(self::ATTRIBUTE_UUID);
  96.         }
  98.         $data = $request->attributes->get(self::ATTRIBUTE_DATA);
  100.         if (is_object($data) && property_exists($data, self::ATTRIBUTE_UUID)) {
  101.             return $data->{'get' . ucfirst(self::ATTRIBUTE_UUID)}()->toString();
  102.         }
  104.         return $this->getIri($request);
  105.     }
  107.     private function getIri(Request $request): ?string
  108.     {
  109.         if (! $iri = $request->attributes->get(self::ATTRIBUTE_API_WRITE_ITEM_IRI)) {
  110.             return null;
  111.         }
  113.         try {
  114.             $data = $this->iriConverter->getResourceFromIri($iri);
  116.             return $data->getUuid()->toString();
  117.         } catch (\Exception $e) {
  118.             return $iri;
  119.         }
  120.     }
  121. }