src/Entrepreneurs/Bundle/AppBundle/Controller/ApiController.php line 17

Open in your IDE?
  1. <?php
  3. namespace Entrepreneurs\Bundle\AppBundle\Controller;
  5. use Entrepreneurs\Bundle\AppBundle\Propel\SentEmailMailjetTrack;
  6. use Entrepreneurs\Bundle\AppBundle\Propel\SentEmailMailjetTrackQuery;
  7. use Entrepreneurs\Bundle\AppBundle\Propel\SentEmailQuery;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\Routing\Annotation\Route;
  14. class ApiController extends AbstractController
  15. {
  16.     #[Route('/api/mail/webhook/{hash}', name: 'api_mails_webhook')]
  17.     public function webhook(Request $request, string $hash, string $webhookHash): Response
  18.     {
  19.         if ($hash !== $webhookHash) {
  20.             return new JsonResponse(['error' => 'Accès non autorisé'], Response::HTTP_FORBIDDEN);
  21.         }
  23.         $content = $request->getContent();
  24.         $event = json_decode($content, true);
  26.         if ($event) {
  27.             $messageId = $event['CustomID'] ?? null;
  28.             $eventType = $event['event'] ?? null;
  29.             if (in_array($eventType, ['sent', 'open', 'click', 'bounce'])) {
  30.                 $sentMail = SentEmailQuery::create()->filterByMessageId($messageId)->findOne();
  31.                 if ($sentMail) {
  32.                     $sentMailJetTrack = SentEmailMailjetTrackQuery::create()
  33.                         ->select('id')
  34.                         ->filterBySentEmailId($sentMail->getId())
  35.                         ->filterByMailjetEventType($eventType)
  36.                         ->findOne()
  37.                     ;
  38.                     $date = new \DateTime();
  39.                     if (!$sentMailJetTrack) {
  40.                         $sentMailJetTrack = new SentEmailMailjetTrack();
  41.                         $sentMailJetTrack->setSentEmailId($sentMail->getId());
  42.                         $sentMailJetTrack->setMailjetEventType($eventType);
  43.                         $sentMailJetTrack->setDate($date);
  44.                         $sentMailJetTrack->setRecipient($event['email']);
  45.                         $sentMailJetTrack->setTargetLinkUrl($event['url'] ?? null);
  46.                         $sentMailJetTrack->setMessageId($messageId);
  47.                         $sentMailJetTrack->setFailReason($event['error'] ?? null);
  48.                         $sentMailJetTrack->save();
  50.                         $sentMail->setLastStatus($sentMail->describeEvent($eventType, $date));
  51.                         $sentMail->save();
  52.                     }
  53.                 }
  54.             }
  55.         }
  57.         return new JsonResponse(['status' => 'success']);
  58.     }
  59. }