src/Controller/Email/EmailWebhooksController.php line 56

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Email;
  5. use App\Message\EmailWebhookQueued;
  6. use App\Model\Email\Webhook\Webhook;
  7. use Psr\Log\LoggerInterface;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Component\HttpFoundation\IpUtils;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  13. use Symfony\Component\Messenger\MessageBusInterface;
  14. use Symfony\Component\Routing\Annotation\Route;
  15. use Symfony\Component\Serializer\Normalizer\AbstractObjectNormalizer;
  16. use Symfony\Component\Serializer\SerializerInterface;
  18. /**
  19.  * @see https://developers.brevo.com/docs/how-to-use-webhooks
  20.  * @see https://help.brevo.com/hc/en-us/articles/27824932835474-New-webhooks-Create-outbound-webhooks-to-send-real-time-data-from-Brevo-to-an-external-app
  21.  * @see https://developers.brevo.com/docs/transactional-webhooks
  22.  * @see https://developers.brevo.com/docs/send-a-transactional-email#tracking-your-transactional-activity-through-webhooks
  23.  * @see https://developers.brevo.com/reference/sendtransacemail
  24.  *
  25.  * @Route("/email/webhooks")
  26.  */
  27. class EmailWebhooksController extends AbstractController
  28. {
  29.     /**
  30.      * @Route("/", name="email_webhooks", methods={"GET", "POST"})
  31.      */
  32.     public function webhooks(
  33.         Request $request,
  34.         SerializerInterface $serializer,
  35.         MessageBusInterface $bus,
  36.         LoggerInterface $logger): Response
  37.     {
  38.         // Brevo webhooks IP ranges (@see https://help.brevo.com/hc/en-us/articles/15127404548498-Brevo-IP-ranges-List-of-publicly-exposed-services
  39.         $limitIps = ['1.179.112.0/20', '172.246.240.0/20'];
  40.         if (!IpUtils::checkIp($request->getClientIp(), $limitIps)) {
  41.             throw new AccessDeniedHttpException('Acceso restringido por IP.');
  42.         }
  44.         if ($request->isMethod('POST')) {
  45.             if (str_contains($request->getContentType(), 'json')) {
  46.                 $body = $request->getContent();
  47.                 if ($body) {
  48.                     $logger->info('EmailWebhooksController $body = ' .$body);
  49.                     $context = [
  50.                         AbstractObjectNormalizer::SKIP_NULL_VALUES => true,
  51.                         AbstractObjectNormalizer::DISABLE_TYPE_ENFORCEMENT => true
  52.                     ];
  53.                     $webhook = $serializer->deserialize($body, Webhook::class, 'json', $context); // to deserialize a list of objects, you have to append [] to the type parameter
  54.                     $logger->info('EmailWebhooksController $webhook = ' .$serializer->serialize($webhook, 'json'));
  56.                     $bus->dispatch(new EmailWebhookQueued($webhook)); // async worker will process the queued webhook
  58.                     return new Response('', Response::HTTP_OK);
  59.                 }
  60.             }
  61.         }
  62.         //$logger->info('EmailWebhooksController BAD REQUEST');
  63.         return new Response('', Response::HTTP_BAD_REQUEST);
  64.     }
  65. }