src/Controller/Webhook/CustomerIoController.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Webhook;
  5. use App\Traits\SentryNotifyTrait;
  6. use Doctrine\ORM\EntityManagerInterface;
  7. use Evo\Infrastructure\MappingORM\CustomerIoEvent;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Component\HttpFoundation\Response;
  10. use Symfony\Component\Routing\Annotation\Route;
  12. class CustomerIoController extends AbstractController
  13. {
  14.     use SentryNotifyTrait;
  16.     private Response $response;
  17.     private EntityManagerInterface $em;
  19.     public function __construct(EntityManagerInterface $em)
  20.     {
  21.         $this->response = new Response();
  22.         $this->em = $em;
  23.     }
  25.     /**
  26.      * @Route("/customerio", name="app_webhook_customerio", methods={"POST"})
  27.      */
  28.     public function webhook()
  29.     {
  30.         $requestBody = file_get_contents('php://input');
  32.         $customerIoData = json_decode($requestBody, null, 512, JSON_THROW_ON_ERROR);
  34.         if ($customerIoData && $customerIoData->data) {
  35.             $customerRecipient = isset($customerIoData->data->recipient) && $customerIoData->data->recipient ?: '';
  36.             $customerId = $customerIoData->data->customer_id ?: '';
  37.             $customerIoEvent = new CustomerIoEvent();
  38.             $customerIoEvent->setCustomerId($customerId);
  39.             $customerIoEvent->setMetric($customerIoData->metric);
  40.             $customerIoEvent->setObjectType($customerIoData->object_type);
  41.             $customerIoEvent->setTimestamp($customerIoData->timestamp);
  42.             $customerIoEvent->setRecipient($customerRecipient);
  44.             $this->em->persist($customerIoEvent);
  45.             $this->em->flush();
  46.         }
  48.         $this->response->setStatusCode(200);
  50.         return $this->response->send();
  51.     }
  52. }