<?php declare(strict_types=1);
namespace VioB2BLogin\Core\Checkout\Customer\Subscriber;
use Shopware\Core\Checkout\Customer\CustomerEntity;
use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
use Shopware\Core\System\SalesChannel\Context\SalesChannelContextRestorer;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
use VioB2BLogin\Core\Checkout\Customer\Event\EmployeeCreateEvent;
use VioB2BLogin\Core\Services\EmployeeService;
use VioB2BLogin\Core\System\SalesChannel\Context\SalesChannelContextFactory;
use VioB2BLogin\Entity\Employee\EmployeeDefinition;
use VioB2BLogin\Entity\Employee\EmployeeEntity;
class EmployeeFlowEventsSubscriber implements EventSubscriberInterface
{
private EventDispatcherInterface $dispatcher;
private SalesChannelContextRestorer $restorer;
private EmployeeService $employeeService;
/**
* @internal
*/
public function __construct(
EventDispatcherInterface $dispatcher,
SalesChannelContextRestorer $restorer,
EmployeeService $employeeService
) {
$this->dispatcher = $dispatcher;
$this->restorer = $restorer;
$this->employeeService = $employeeService;
}
/**
* @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
*/
public static function getSubscribedEvents(): array
{
return [
EmployeeDefinition::ENTITY_NAME.'.written' => 'onEmployeeWritten',
];
}
public function onEmployeeWritten(EntityWrittenEvent $event): void
{
if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
return;
}
$payloads = $event->getPayloads();
foreach ($payloads as $payload) {
if (!empty($payload['createdAt'])
&& !empty($payload['id'])
&& !empty($payload['customerId'])
) {
$this->dispatchEmployeeCreatedEvent($payload['id'], $payload['customerId'], $event);
}
}
}
private function dispatchEmployeeCreatedEvent(string $employeeId, string $customerId, EntityWrittenEvent $event): void
{
$context = $event->getContext();
$salesChannelContext = $this->restorer->restoreByCustomer($customerId, $context);
if (!($salesChannelContext->getCustomer() instanceof CustomerEntity) ) {
return;
}
$employee = $this->employeeService->loadEmployeeById($employeeId, $context);
if (!$employee instanceof EmployeeEntity) {
return;
}
$salesChannelContext->addExtension(SalesChannelContextFactory::EMPLOYEE_KEY, $employee);
$customerCreated = new EmployeeCreateEvent(
$salesChannelContext,
$employee
);
$this->dispatcher->dispatch($customerCreated);
}
}