src/AppBundle/EventSubscriber/WebhookSubscriber.php line 54

Open in your IDE?
  1. <?php
  3. namespace AppBundle\EventSubscriber;
  5. use AppBundle\Annotation\Webhook;
  6. use AppBundle\Logger\ApiLoggerInterface;
  7. use AppBundle\Logger\ZohoSubcriptionWebhookLogger;
  8. use Doctrine\Common\Annotations\AnnotationReader;
  9. use Doctrine\ORM\Exception\ORMException;
  10. use Psr\Container\ContainerInterface;
  11. use Symfony\Contracts\Service\ServiceSubscriberInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. class WebhookSubscriber implements ServiceSubscriberInterface, EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var ContainerInterface
  21.      */
  22.     private $container;
  24.     public function __construct(ContainerInterface $container)
  25.     {
  26.         $this->container = $container;
  27.     }
  29.     /**
  30.      * @return array<mixed>
  31.      */
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             KernelEvents::RESPONSE => ['onKernelResponse', 1000],
  36.         ];
  37.     }
  39.     /**
  40.      * @return array<string>
  41.      */
  42.     public static function getSubscribedServices(): array
  43.     {
  44.         return [
  45.             ZohoSubcriptionWebhookLogger::class,
  46.         ];
  47.     }
  49.     /**
  50.      * @param ResponseEvent $responseEvent
  51.      * @return void
  52.      * @throws ORMException
  53.      */
  54.     public function onKernelResponse(ResponseEvent $responseEvent): void
  55.     {
  56.         $request = $responseEvent->getRequest();
  57.         $response = $responseEvent->getResponse();
  58.         $annotation = $this->getWehookAnnotation($request);
  59.         if ($annotation && $annotation->getLogger()) {
  60.             /** @var ApiLoggerInterface $logger */
  61.             $logger = $this->container->get((string) $annotation->getLogger());
  62.             $logger->log($request, $response);
  63.         }
  64.     }
  66.     /**
  67.      * @param Request $request
  68.      * @return Webhook|null
  69.      */
  70.     private function getWehookAnnotation(Request $request): ?Webhook {
  71.         try {
  72.             $annotations = [];
  73.             if ($controller = $request->attributes->get('_controller')) {
  74.                 /** @var string[] $splittedController */
  75.                 $splittedController = explode(':', $controller);
  76.                 /** @var string $controllerName */
  77.                 $controllerName = count($splittedController) > 0 ? $splittedController[0] : $controller;
  78.                 $reflectedMethod = new \ReflectionClass($controllerName);
  79.                 $annotations = array_filter(
  80.                     (new AnnotationReader())->getClassAnnotations($reflectedMethod),
  81.                     static function ($annotation) { return $annotation instanceof Webhook; }
  82.                 );
  83.             }
  85.             return count($annotations) > 0 ? current($annotations) : null;
  86.         } catch (\Exception $e) {
  87.         }
  89.         return null;
  90.     }
  91. }