src/EventSubscriber/DateTimeFieldsResponseSubscriber.php line 38

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Service\TenantPerson\TenantPersonService;
  6. use App\Util\Converter;
  7. use Carbon\Carbon;
  8. use Carbon\Exceptions\InvalidFormatException;
  9. use Psr\Cache\InvalidArgumentException;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\JsonResponse;
  12. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  15. class DateTimeFieldsResponseSubscriber implements EventSubscriberInterface
  16. {
  17.     private $tenantPersonService;
  19.     public function __construct(TenantPersonService $tenantPersonService)
  20.     {
  21.         $this->tenantPersonService = $tenantPersonService;
  22.     }
  24.     /**
  25.      * {@inheritDoc}
  26.      */
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             // The second value of the array defines priority of the subscriber.
  31.             KernelEvents::RESPONSE => ['onKernelResponse', 200],
  32.         ];
  33.     }
  35.     /**
  36.      * @throws InvalidArgumentException
  37.      */
  38.     public function onKernelResponse(ResponseEvent $event)
  39.     {
  40.         if (!$this->tenantPersonService->isInitialized()) {
  41.             return;
  42.         }
  44.         $response = $event->getResponse();
  46.         if (!$response->isSuccessful()) {
  47.             return;
  48.         }
  50.         $contentType = $response->headers->get('Content-Type');
  52.         if (false === strpos($contentType, 'json')) {
  53.             return;
  54.         }
  56.         $content = json_decode($response->getContent(), true);
  58.         if (\JSON_ERROR_NONE !== json_last_error()) {
  59.             return;
  60.         }
  62.         if (null === $content) {
  63.             return;
  64.         }
  66.         if ('' === $content) {
  67.             return;
  68.         }
  70.         $timezone = $this->tenantPersonService->getProspectTenantTimezone();
  72.         array_walk_recursive($content, function (&$value, $key) use ($timezone) {
  73.             // If the string ends with 'At' then it's datetime field.
  75.             // Convert to snake case for simplicity.
  76.             $snakeCasedKey = Converter::toSnakeCase($key);
  78.             if ('_at' === substr($snakeCasedKey, -3)) {
  79.                 try {
  80.                     if (null !== $value) {
  81.                         $value = Carbon::parse($value)
  82.                             ->setTimezone($timezone)
  83.                             ->toISOString(true)
  84.                         ;
  85.                     }
  86.                 } catch (InvalidFormatException $e) {
  87.                     return;
  88.                 }
  89.             }
  90.         });
  92.         $jsonResponse = new JsonResponse($content, $response->getStatusCode(), $response->headers->all());
  94.         $event->setResponse($jsonResponse);
  95.     }
  96. }