src/EventSubscriber/Klaviyo.php line 17

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Event\CartItemAdded;
  6. use App\Service\Klaviyo\KlaviyoEmail;
  7. use App\Service\Klaviyo\KlaviyoEventService;
  8. use Exception;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\HttpFoundation\RequestStack;
  11. use App\Event\EmailEntered;
  12. use App\Service\Klaviyo\KlaviyoProfileService;
  13. use App\Event\OrderMakedEvent;
  14. use App\Repository\ProdRepository;
  15. use App\Env;
  17. class Klaviyo implements EventSubscriberInterface
  18. {
  19.     public function __construct(
  20.         private KlaviyoEventService $klaviyoEventService,
  21.         private RequestStack $requestStack,
  22.         private KlaviyoEmail $klaviyoEmail,
  23.         private ProdRepository $prodRepository,  
  24.     )
  25.     {
  26.         
  27.     }
  29.     public function onCartItemAdded(CartItemAdded $event): void
  30.     {
  31.         try {
  32.             $this->klaviyoEventService->track(
  33.                 'Added to Cart',
  34.                 $this->klaviyoEmail->getEmail(),
  35.                 [
  36.                     'product_id'   => $event->getProd()->getId(),
  37.                     'product_name' => $event->getProd()->getName(),
  38.                     'price'        => $event->getProd()->getPrice(),
  39.                     'quantity'     => $event->getNum(),
  40.                     'cart_value'   => $event->getCartAmount(),
  41.                     'url'          => $this->requestStack->getCurrentRequest()->getUri(),
  42.                 ]
  43.             );
  44.         } catch (Exception $e) {
  45.             echo $e->getMessage();die();
  46.         }
  47.     }
  49.     public function onEmailEntered(EmailEntered $event): void
  50.     {
  51.         try {
  52.             $this->klaviyoEmail->setEmail($event->getEmail());
  53.             $this->klaviyoProfileService->identify($event->getEmail());
  54.         } catch (Exception $e) {
  56.         }
  57.     }
  59.     public function onOrderMaked(OrderMakedEvent $event): void
  60.     {
  61.         try {
  62.             $this->klaviyoEventService->track(
  63.                 'Order Placed',
  64.                 $event->getOrder()->getEmail(),
  65.                 [
  66.                     'order_id'    => $event->getOrder()->getId(),
  67.                     'total'       => $event->getOrder()->getAmount(),
  68.                     'currency'    => Env::currency_code(),
  69.                     'items'       => array_values(array_map(fn($item) => [
  70.                         'product_id' => $item['id'],
  71.                         'name'       => $this->prodRepository->find($item['id'])->getName(),
  72.                         'price'      => $item['price'],
  73.                         'quantity'   => $item['num'],
  74.                     ], $event->getCartItems())),
  75.                 ]
  76.             );            
  77.         } catch (Exception $e) {
  78.             dd($e);
  79.         }
  80.     }
  82.     public static function getSubscribedEvents(): array
  83.     {
  84.         return [
  85.             CartItemAdded::NAME => 'onCartItemAdded',
  86.             EmailEntered::NAME => 'onEmailEntered',
  87.             OrderMakedEvent::NAME => 'onOrderMakedEvent',
  88.         ];
  89.     }
  90. }