Symfony Profiler

<?php
namespace NewsletterSendinblue\Subscriber;
use NewsletterSendinblue\NewsletterSendinblue;
use NewsletterSendinblue\Service\Cart\CartEventProducer;
use NewsletterSendinblue\Service\Cart\SendinblueCartProcessorService;
use NewsletterSendinblue\Service\ConfigService;
use NewsletterSendinblue\Service\Constant;
use NewsletterSendinblue\Service\Customer\CustomerProducer;
use NewsletterSendinblue\Service\NewsletterRecipient\NewsletterRecipientProducer;
use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
use Shopware\Core\Checkout\Customer\CustomerEntity;
use Shopware\Core\Checkout\Customer\Event\CustomerLoginEvent;
use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
use Shopware\Core\Checkout\Customer\Event\GuestCustomerRegisterEvent;
use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
use Shopware\Core\Content\Newsletter\Event\NewsletterConfirmEvent;
use Shopware\Core\Content\Newsletter\Event\NewsletterRegisterEvent;
use Shopware\Core\Content\Newsletter\Event\NewsletterSubscribeUrlEvent;
use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\Struct\ArrayStruct;
use Shopware\Core\System\SalesChannel\SalesChannelContext;
use Shopware\Core\System\SystemConfig\SystemConfigService;
use Shopware\Storefront\Page\Checkout\Confirm\CheckoutConfirmPageLoadedEvent;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\RequestStack;
class NewsletterRecipientSubscriber implements EventSubscriberInterface
{
/**
* @var NewsletterRecipientProducer
*/
private $newsletterRecipientProducer;
/**
* @var CustomerProducer
*/
private $customerProducer;
/**
* @var ConfigService
*/
private $configService;
/**
* @var SystemConfigService
*/
private $systemConfigService;
/**
* @var EntityRepositoryInterface
*/
private $mailTemplateRepository;
/**
* @var EntityRepositoryInterface
*/
private $customerRepository;
/**
* @var RequestStack;
*/
private $requestStack;
/**
* @var SendinblueCartProcessorService
*/
private $cartProcessorService;
/**
* @var CartEventProducer
*/
private $cartEventProducer;
/**
* @var CartService
*/
private $cartService;
/**
* @var bool
*/
private $isRecipientAlreadyUpdated = false;
/**
* @param NewsletterRecipientProducer $newsletterRecipientProducer
* @param CustomerProducer $customerProducer
* @param ConfigService $configService
* @param SystemConfigService $systemConfigService
* @param EntityRepositoryInterface $mailTemplateRepository
* @param EntityRepositoryInterface $customerRepository
* @param RequestStack $requestStack
* @param SendinblueCartProcessorService $cartProcessorService
* @param CartEventProducer $cartEventProducer
* @param CartService $cartService
*/
public function __construct(
NewsletterRecipientProducer $newsletterRecipientProducer,
CustomerProducer $customerProducer,
ConfigService $configService,
SystemConfigService $systemConfigService,
EntityRepositoryInterface $mailTemplateRepository,
EntityRepositoryInterface $customerRepository,
RequestStack $requestStack,
SendinblueCartProcessorService $cartProcessorService,
CartEventProducer $cartEventProducer,
CartService $cartService
)
{
$this->newsletterRecipientProducer = $newsletterRecipientProducer;
$this->customerProducer = $customerProducer;
$this->configService = $configService;
$this->systemConfigService = $systemConfigService;
$this->mailTemplateRepository = $mailTemplateRepository;
$this->customerRepository = $customerRepository;
$this->requestStack = $requestStack;
$this->cartProcessorService = $cartProcessorService;
$this->cartEventProducer = $cartEventProducer;
$this->cartService = $cartService;
}
/**
* @return array
*/
public static function getSubscribedEvents(): array
{
return [
NewsletterConfirmEvent::class => 'onNewsletterConfirmEvent',
NewsletterRegisterEvent::class => 'onNewsletterRegisterEvent',
NewsletterSubscribeUrlEvent::class => 'onNewsletterSubscribeUrlEvent',
EntityWrittenContainerEvent::class => 'onEntityWrittenContainerEvent',
MailBeforeValidateEvent::class => 'onMailBeforeValidateEvent',
CustomerRegisterEvent::class => 'onCustomerRegisterEvent',
GuestCustomerRegisterEvent::class => 'onCustomerRegisterEvent',
CustomerLoginEvent::class => 'onCustomerLoginEvent',
];
}
/**
* @param NewsletterSubscribeUrlEvent $event
* @return void
*/
public function onNewsletterSubscribeUrlEvent(NewsletterSubscribeUrlEvent $event): void
{
if ($this->isFooterSubscription()) {
$subscribeUrl = $event->getSubscribeUrl();
$key = 'brFt';
$val = '1';
$separator = (strpos($subscribeUrl, '?') !== false) ? '&' : '?';
$subscribeUrl .= $separator . urlencode($key) . '=' . urlencode($val);
$event->setSubscribeUrl($subscribeUrl);
}
}
/**
* @param CustomerLoginEvent $event
* @return void
*/
public function onCustomerLoginEvent(CustomerLoginEvent $event)
{
if (method_exists($event, 'getSalesChannelContext') && $event->getSalesChannelContext() instanceof SalesChannelContext) {
$salesChannelId = $event->getSalesChannelContext()->getSalesChannelId();
} else if (method_exists($event, 'getContext') && $event->getContext() instanceof SalesChannelContext) {
$salesChannelId = $event->getContext()->getSalesChannelId();
} else {
return;
}
$this->configService->setSalesChannelId($salesChannelId);
if ($this->configService->isAbandonedCartTrackingEnabled()) {
$this->cartProcessorService->setShouldCollectData(true);
}
}
/**
* @param CustomerRegisterEvent $event
*/
public function onCustomerRegisterEvent(CustomerRegisterEvent $event): void
{
// Determine the location of register: signup or checkout
$subscriptionLocation = CustomerProducer::SUBSCRIPTION_LOCATION_SIGNUP;
if ($this->requestStack
&& $this->requestStack->getCurrentRequest()
&& $this->requestStack->getCurrentRequest()->server->has('HTTP_REFERER')
) {
$referrer = $this->requestStack->getCurrentRequest()->server->get('HTTP_REFERER');
if ($referrer && strpos($referrer, '/checkout') !== false) {
$subscriptionLocation = CustomerProducer::SUBSCRIPTION_LOCATION_ORDER_CHECKOUT;
}
}
$event->getContext()->addExtension(CustomerProducer::SUBSCRIPTION_LOCATION_EXT, new ArrayStruct([
'value' => $subscriptionLocation
]));
$this->configService->setSalesChannelId($event->getSalesChannelId());
if ($this->configService->isFullCustomerSyncEnabled()) {
$customer = $event->getCustomer();
$this->customerRepository->update([[
'id' => $customer->getId(),
'customFields' => [
CustomerProducer::FULL_SYNC_CUSTOMER_REGISTERED => true
]
]], $event->getContext());
$this->customerProducer->setAdditionalUpdateData([
Constant::OPT_IN_ENABLED => 'false',
Constant::OPT_IN_CHECKED => 'false'
]);
$this->customerProducer->confirmContact($customer, $event->getContext(), $event->getSalesChannelId());
}
if ($this->configService->isAbandonedCartTrackingEnabled()) {
$salesChannelContext = $event->getSalesChannelContext();
$cart = $this->cartService->getCart($salesChannelContext->getToken(), $salesChannelContext);
if ($cart->getLineItems()->count() > 0) {
$this->cartEventProducer->processCart($cart, $salesChannelContext);
}
}
}
/**
* @param NewsletterConfirmEvent $event
*/
public function onNewsletterConfirmEvent(NewsletterConfirmEvent $event): void
{
/**
* This method is triggered when:
* 1. DOI (Double Opt-In) is enabled, after the user confirms via email.
* 2. DOI is not enabled, immediately after newsletter registration.
*/
if ($this->isRecipientAlreadyUpdated) {
$this->isRecipientAlreadyUpdated = false;
return;
}
$additionalUpdateData = [
Constant::OPT_IN_ENABLED => 'true',
Constant::OPT_IN_CHECKED => 'true'
];
if ($this->isFooterSubscription()) {
$additionalUpdateData[CustomerProducer::SUBSCRIPTION_LOCATION_KEY] =
CustomerProducer::SUBSCRIPTION_LOCATION_FOOTER;
}
$this->newsletterRecipientProducer->setAdditionalUpdateData($additionalUpdateData);
$this->newsletterRecipientProducer->confirmContact($event->getNewsletterRecipient(), $event->getContext(), $event->getSalesChannelId());
}
/**
* @param NewsletterRegisterEvent $event
*/
public function onNewsletterRegisterEvent(NewsletterRegisterEvent $event): void
{
$this->configService->setSalesChannelId($event->getSalesChannelId());
if ($this->configService->getSubscriptionMailing()) {
$additionalUpdateData = [
Constant::OPT_IN_ENABLED => 'true',
Constant::OPT_IN_CHECKED => 'true'
];
if ($this->isFooterSubscription()) {
$additionalUpdateData[CustomerProducer::SUBSCRIPTION_LOCATION_KEY] =
CustomerProducer::SUBSCRIPTION_LOCATION_FOOTER;
}
$this->newsletterRecipientProducer->setAdditionalUpdateData($additionalUpdateData);
$this->newsletterRecipientProducer->confirmContact($event->getNewsletterRecipient(), $event->getContext(), $event->getSalesChannelId());
if ($this->requestStack
&& $this->requestStack->getCurrentRequest()
&& $this->requestStack->getCurrentRequest()->hasSession()
&& $this->requestStack->getSession()->has('sbCoreDoubleOptIn')
) {
$session = $this->requestStack->getSession();
$this->systemConfigService->set('core.newsletter.doubleOptIn', $session->get('sbCoreDoubleOptIn'));
$session->remove('sbCoreDoubleOptIn');
}
}
}
/**
* @param EntityWrittenContainerEvent $event
*/
public function onEntityWrittenContainerEvent(EntityWrittenContainerEvent $event): void
{
// Stop sending calls to Brevo if they are coming from Brevo UI
if ($event->getContext()->hasExtension('brevoUiUnsubscribe')
|| $event->getContext()->hasExtension('brevoUiSubscribe')
|| $event->getContext()->hasExtension(NewsletterSendinblue::IGNORE_EVENT)
) {
return;
}
foreach ($event->getEvents()->getElements() as $eventElement) {
if ($eventElement->getName() === 'newsletter_recipient.written') {
foreach ($eventElement->getWriteResults() as $writeResult) {
if ($writeResult->getOperation() === 'update') {
$payload = $writeResult->getPayload();
$newsletterRecipientId = $writeResult->getPrimaryKey();
$salesChannelId = $payload['salesChannelId'] ?? null;
if (empty($salesChannelId)) {
if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
$salesChannelId = $event->getContext()->getSource()->getSalesChannelId();
}
}
if (isset($payload['status']) && $payload['status'] == 'optOut') {
$this->newsletterRecipientProducer->unsubscribeContact($newsletterRecipientId, $event->getContext(), $salesChannelId);
} else {
$additionalUpdateData = [
Constant::OPT_IN_ENABLED => 'true',
Constant::OPT_IN_CHECKED => 'true'
];
if ($this->isDoiFooterSubscription()) {
$additionalUpdateData[CustomerProducer::SUBSCRIPTION_LOCATION_KEY] =
CustomerProducer::SUBSCRIPTION_LOCATION_FOOTER;
}
$this->newsletterRecipientProducer->setAdditionalUpdateData($additionalUpdateData);
$this->newsletterRecipientProducer->updateContact($newsletterRecipientId, $event->getContext(), $salesChannelId);
$this->isRecipientAlreadyUpdated = true;
}
}
}
}
if ($eventElement->getName() === 'customer.written') {
foreach ($eventElement->getWriteResults() as $writeResult) {
if ($writeResult->getOperation() === 'update') {
$payload = $writeResult->getPayload();
// Skip if customer is created - not call updateContact
if (array_key_exists('customFields', $payload)
&& count($payload['customFields']) == 1
&& (array_key_exists(CustomerProducer::FULL_SYNC_CUSTOMER_REGISTERED, $payload['customFields'])
|| array_key_exists(CustomerProducer::SW_SUB_STATUS_ATTR, $payload['customFields']))
) {
continue;
}
if (array_key_exists('lastLogin', $payload)
|| array_key_exists('remoteAddress', $payload)
) {
continue;
}
if (count($payload) === 3
&& array_key_exists('newsletter', $payload)
&& array_key_exists('updatedAt', $payload)
&& !empty($payload['updatedAt'])
) {
continue;
}
$customerId = $writeResult->getPrimaryKey();
$salesChannelId = $payload['salesChannelId'] ?? null;
if (empty($salesChannelId)) {
if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
$salesChannelId = $event->getContext()->getSource()->getSalesChannelId();
}
}
$this->customerProducer->updateContact($customerId, $event->getContext(), $salesChannelId);
}
}
}
}
}
/**
* @param MailBeforeValidateEvent $event
*/
public function onMailBeforeValidateEvent(MailBeforeValidateEvent $event): void
{
$data = $event->getData();
$templateData = $event->getTemplateData();
$context = $event->getContext();
if (!isset($templateData['newsletterRecipient']) || !isset($data['templateId'])) {
return;
}
if (!$this->isNewsletterMailTemplate($data['templateId'], $context)) {
return;
}
$salesChannelId = null;
if (!empty($data['salesChannelId'])) {
$salesChannelId = $data['salesChannelId'];
}
if (empty($salesChannelId) && method_exists($context->getSource(), 'getSalesChannelId')) {
$salesChannelId = $context->getSource()->getSalesChannelId();
}
if (!empty($salesChannelId)) {
$this->configService->setSalesChannelId($salesChannelId);
}
if (!$this->configService->getSubscriptionMailing()) {
return;
}
$event->stopPropagation();
}
/**
* @param string $templateId
* @param Context $context
* @return bool
*/
private function isNewsletterMailTemplate(string $templateId, Context $context)
{
$criteria = new Criteria([$templateId]);
$criteria->addAssociation('mailTemplateType');
$mailTemplate = $this->mailTemplateRepository->search($criteria, $context)->first();
if (empty($mailTemplate)) {
return false;
}
return in_array($mailTemplate->getMailTemplateType()->getTechnicalName(), ['newsletterDoubleOptIn', 'newsletterRegister']);
}
/**
* @return bool
*/
private function isFooterSubscription(): bool
{
if ($this->requestStack
&& $this->requestStack->getCurrentRequest()
&& $this->requestStack->getCurrentRequest()->server->has('REQUEST_URI')
) {
$requestUri = $this->requestStack->getCurrentRequest()->server->get('REQUEST_URI');
if ($requestUri === Constant::FOOTER_REQUEST_URI) {
return true;
}
}
return false;
}
/**
* @return bool
*/
private function isDoiFooterSubscription(): bool
{
if ($this->requestStack
&& $this->requestStack->getCurrentRequest()
&& $this->requestStack->getCurrentRequest()->server->has('QUERY_STRING')
) {
$queryString = $this->requestStack->getCurrentRequest()->server->get('QUERY_STRING');
parse_str($queryString, $params);
if (isset($params['brFt'])) {
return true;
}
}
return false;
}
}

custom/plugins/NewsletterSendinblue/src/Subscriber/NewsletterRecipientSubscriber.php line 148