Symfony Profiler

<?php
namespace App\EventSubscriber;
use App\Env;
use App\Event\CartItemAdded;
use App\Event\EmailEntered;
use App\Event\OrderMakedEvent;
use App\Event\OrderStartedEvent;
use App\Event\ProdViewedEvent;
use App\Repository\ProdRepository;
use App\Service\Klaviyo\KlaviyoEmail;
use App\Service\Klaviyo\KlaviyoEventService;
use App\Service\Klaviyo\KlaviyoProfileService;
use Exception;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\RequestStack;
use Symfony\Component\HttpKernel\Event\RequestEvent;
use Symfony\Component\HttpKernel\KernelEvents;
use Symfony\Component\Security\Core\Security;
class Klaviyo implements EventSubscriberInterface
{
public function __construct(
private KlaviyoProfileService $klaviyoProfileService,
private KlaviyoEventService $klaviyoEventService,
private RequestStack $requestStack,
private KlaviyoEmail $klaviyoEmail,
private ProdRepository $prodRepository,
private Security $security
)
{
}
public function onCartItemAdded(CartItemAdded $event): void
{
try {
$this->klaviyoEventService->track(
'Added to Cart',
$this->klaviyoEmail->getEmail(),
[
'product_id' => $event->getProd()->getId(),
'product_name' => $event->getProd()->getName(),
'price' => $event->getProd()->getPrice(),
'quantity' => $event->getNum(),
'cart_value' => $event->getCartAmount(),
'url' => $this->requestStack->getCurrentRequest()->getUri(),
]
);
} catch (Exception $e) {
}
}
public function onEmailEntered(EmailEntered $event): void
{
try {
$this->klaviyoEmail->setEmail($event->getEmail());
$this->klaviyoProfileService->identify($event->getEmail());
} catch (Exception $e) {
}
}
public function onOrderStarted(OrderStartedEvent $event): void
{
try {
$items = [];
foreach ($event->getCartItems() as $item) {
if (empty($item['id'])) {
continue;
}
$product = $this->prodRepository->find($item['id']);
if (!$product) {
continue;
}
$items[] = [
'product_id' => $product->getId(),
'name' => $product->getName(),
'price' => $item['price'],
'quantity' => $item['num'],
];
}
$this->klaviyoEventService->track(
'Started Checkout',
$this->klaviyoEmail->getEmail(),
[
'total' => $event->getAmount(),
'currency' => Env::currency_code(),
'items' => $items,
]
);
} catch (Exception $e) {
}
}
public function onOrderMaked(OrderMakedEvent $event): void
{
try {
$this->klaviyoEventService->track(
'Order Placed',
$event->getOrder()->getEmail(),
[
'order_id' => $event->getOrder()->getId(),
'total' => $event->getOrder()->getAmount(),
'currency' => Env::currency_code(),
'items' => array_values(array_map(fn($item) => [
'product_id' => $item['id'],
'name' => $this->prodRepository->find($item['id'])->getName(),
'price' => $item['price'],
'quantity' => $item['num'],
], $event->getCartItems())),
]
);
} catch (Exception $e) {
}
}
public function onProdViewed(ProdViewedEvent $event): void
{
try {
$product = $event->getProd();
$this->klaviyoEventService->track(
'Viewed Product',
$this->klaviyoEmail->getEmail(),
[
'product_id' => $product->getId(),
'name' => $product->getName(),
'price' => $product->getPrice(),
'url' => $this->requestStack->getCurrentRequest()?->getUri() ?? '',
]
);
} catch (Exception $e) {
}
}
public function onKernelRequest(RequestEvent $event): void
{
// if (!$event->isMainRequest()) {
// return;
// }
try {
if (!empty($this->klaviyoEmail->getEmail())) {
return;
}
/** @var \App\Entity\User $user */
$user = $this->security->getUser();
if (!$user) {
return;
}
$email = trim(strtolower($user->getEmail()));
if (!filter_var($email, FILTER_VALIDATE_EMAIL)) {
return;
}
$this->klaviyoEmail->setEmail($email);
$this->klaviyoProfileService->identify($email);
} catch (Exception $e) {
}
}
public static function getSubscribedEvents(): array
{
return [
KernelEvents::REQUEST => 'onKernelRequest',
CartItemAdded::NAME => 'onCartItemAdded',
EmailEntered::NAME => 'onEmailEntered',
OrderMakedEvent::NAME => 'onOrderMakedEvent',
OrderStartedEvent::NAME => 'onOrderStarted',
ProdViewedEvent::NAME => 'onProdViewed',
];
}
}

src/EventSubscriber/Klaviyo.php line 146