src/EventSubscriber/AccountSubscriber.php line 51

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Account;
  6. use Doctrine\ORM\EntityManagerInterface;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpFoundation\Response;
  9. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  12. class AccountSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(
  15.         private readonly EntityManagerInterface $entityManager,
  16.     ) {}
  18.     public static function getSubscribedEvents(): array
  19.     {
  20.         return [
  21.             KernelEvents::RESPONSE => [
  22.                 ['storeAdditionalDataToEntity', 10],
  23.                 ['addAdditionalDataToResponse', -10],
  24.             ],
  25.         ];
  26.     }
  28.     public function storeAdditionalDataToEntity(ResponseEvent $event): void
  29.     {
  30.         $requestRoute = $event->getRequest()->attributes->get('_route');
  31.         $persistRoutes = ['sulu_contact.post_account', 'sulu_contact.put_account'];
  32.         if (!\in_array($requestRoute, $persistRoutes, true)) {
  33.             return;
  34.         }
  36.         $account = $this->getEntityForResponse($event->getResponse());
  37.         if (!$account) {
  38.             return;
  39.         }
  41.         $requestData = $event->getRequest()->request->all();
  43.         $account->setIdentificationNumber($requestData['in']);
  44.         $account->setTaxIdentificationNumber($requestData['tin']);
  45.         $account->setCaseNumber($requestData['case_number']);
  47.         $this->entityManager->persist($account);
  48.         $this->entityManager->flush();
  49.     }
  51.     public function addAdditionalDataToResponse(ResponseEvent $event): void
  52.     {
  53.         $requestRoute = $event->getRequest()->attributes->get('_route');
  54.         $serializeRoutes = ['sulu_contact.get_account'];
  55.         if (!\in_array($requestRoute, $serializeRoutes, true)) {
  56.             return;
  57.         }
  59.         $account = $this->getEntityForResponse($event->getResponse());
  60.         if (!$account) {
  61.             return;
  62.         }
  64.         $responseData = json_decode($event->getResponse()->getContent() ?: '{}', true);
  66.         $responseData['in'] = $account->getIdentificationNumber();
  67.         $responseData['tin'] = $account->getTaxIdentificationNumber();
  68.         $responseData['case_number'] = $account->getCaseNumber();
  70.         $event->getResponse()->setContent(json_encode($responseData) ?: null);
  71.     }
  73.     protected function getEntityForResponse(Response $response): ?Account
  74.     {
  75.         $id = json_decode($response->getContent() ?: '{}', true)['id'] ?? null;
  76.         return $id ? $this->entityManager->getRepository(Account::class)->find($id) : null;
  77.     }
  78. }