src/EventSubscriber/Klaviyo.php line 19

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;
  16. use App\Event\OrderStartedEvent;
  17. use App\Event\ProdViewedEvent;
  19. class Klaviyo implements EventSubscriberInterface
  20. {
  21.     public function __construct(
  22.         private KlaviyoEventService $klaviyoEventService,
  23.         private RequestStack $requestStack,
  24.         private KlaviyoEmail $klaviyoEmail,
  25.         private ProdRepository $prodRepository,  
  26.     )
  27.     {
  28.         
  29.     }
  31.     public function onCartItemAdded(CartItemAdded $event): void
  32.     {
  33.         try {
  34.             $this->klaviyoEventService->track(
  35.                 'Added to Cart',
  36.                 $this->klaviyoEmail->getEmail(),
  37.                 [
  38.                     'product_id'   => $event->getProd()->getId(),
  39.                     'product_name' => $event->getProd()->getName(),
  40.                     'price'        => $event->getProd()->getPrice(),
  41.                     'quantity'     => $event->getNum(),
  42.                     'cart_value'   => $event->getCartAmount(),
  43.                     'url'          => $this->requestStack->getCurrentRequest()->getUri(),
  44.                 ]
  45.             );
  46.         } catch (Exception $e) {
  47.             echo $e->getMessage();die();
  48.         }
  49.     }
  51.     public function onEmailEntered(EmailEntered $event): void
  52.     {
  53.         try {
  54.             $this->klaviyoEmail->setEmail($event->getEmail());
  55.             $this->klaviyoProfileService->identify($event->getEmail());
  56.         } catch (Exception $e) {
  58.         }
  59.     }
  61.     public function onOrderStarted(OrderStartedEvent $event): void
  62.     {
  63.         try {
  64.             $items = [];
  66.             foreach ($event->getCartItems() as $item) {
  68.                 if (empty($item['id'])) {
  69.                     continue;
  70.                 }
  72.                 $product = $this->prodRepository->find($item['id']);
  74.                 if (!$product) {
  75.                     continue;
  76.                 }
  78.                 $items[] = [
  79.                     'product_id' => $product->getId(),
  80.                     'name'       => $product->getName(),
  81.                     'price'      => $item['price'],
  82.                     'quantity'   => $item['num'],
  83.                 ];
  84.             }
  86.             $this->klaviyoEventService->track(
  87.                 'Started Checkout',
  88.                 $this->klaviyoEmail->getEmail(),
  89.                 [
  90.                     'total'    => $event->getAmount(),
  91.                     'currency' => Env::currency_code(),
  92.                     'items'    => $items,
  93.                 ]
  94.             );
  96.         } catch (Exception $e) {
  97.             dd($e);
  98.         }
  99.     }
  101.     public function onOrderMaked(OrderMakedEvent $event): void
  102.     {
  103.         try {
  104.             $this->klaviyoEventService->track(
  105.                 'Order Placed',
  106.                 $event->getOrder()->getEmail(),
  107.                 [
  108.                     'order_id'    => $event->getOrder()->getId(),
  109.                     'total'       => $event->getOrder()->getAmount(),
  110.                     'currency'    => Env::currency_code(),
  111.                     'items'       => array_values(array_map(fn($item) => [
  112.                         'product_id' => $item['id'],
  113.                         'name'       => $this->prodRepository->find($item['id'])->getName(),
  114.                         'price'      => $item['price'],
  115.                         'quantity'   => $item['num'],
  116.                     ], $event->getCartItems())),
  117.                 ]
  118.             );            
  119.         } catch (Exception $e) {
  120.             dd($e);
  121.         }
  122.     }
  124.     public function onProdViewed(ProdViewedEvent $event): void
  125.     {
  126.         try {
  128.             $product = $event->getProd();
  130.             $this->klaviyoEventService->track(
  131.                 'Viewed Product',
  132.                 $this->klaviyoEmail->getEmail(),
  133.                 [
  134.                     'product_id' => $product->getId(),
  135.                     'name'       => $product->getName(),
  136.                     'price'      => $product->getPrice(),
  137.                     'url'        => $this->requestStack->getCurrentRequest()?->getUri() ?? '',
  138.                 ]
  139.             );
  141.         } catch (Exception $e) {
  142.             dd($e);
  143.         }
  144.     }
  146.     public static function getSubscribedEvents(): array
  147.     {
  148.         return [
  149.             CartItemAdded::NAME => 'onCartItemAdded',
  150.             EmailEntered::NAME => 'onEmailEntered',
  151.             OrderMakedEvent::NAME => 'onOrderMakedEvent',
  152.             OrderStartedEvent::NAME => 'onOrderStarted',
  153.             ProdViewedEvent::NAME => 'onProdViewed',            
  154.         ];
  155.     }
  156. }