[Customer] Refactor customer assignment to command

src/EventListener/CartBlamerListener.php

@@ -6,37 +6,42 @@
 
 use Doctrine\Common\Persistence\ObjectManager;
 use Lexik\Bundle\JWTAuthenticationBundle\Event\JWTCreatedEvent;
-use Sylius\Component\Core\Model\OrderInterface;
 use Sylius\Component\Core\Model\ShopUserInterface;
 use Sylius\Component\Core\Repository\OrderRepositoryInterface;
-use Sylius\Component\Order\Context\CartContextInterface;
-use Sylius\Component\Order\Context\CartNotFoundException;
+use Sylius\Component\Order\Processor\OrderProcessorInterface;
+use Sylius\ShopApiPlugin\Command\Cart\AssignCustomerToCart;
 use Symfony\Component\HttpFoundation\RequestStack;
+use Symfony\Component\Messenger\MessageBusInterface;
 use Webmozart\Assert\Assert;
 
 final class CartBlamerListener
 {
     /** @var ObjectManager */
     private $cartManager;
 
-    /** @var CartContextInterface */
-    private $cartContext;
-
     /** @var OrderRepositoryInterface */
     private $cartRepository;
 
+    /** @var MessageBusInterface */
+    private $bus;
+
+    /** @var OrderProcessorInterface */
+    private $orderProcessor;
+
     /** @var RequestStack */
     private $requestStack;
 
     public function __construct(
         ObjectManager $cartManager,
-        CartContextInterface $cartContext,
         OrderRepositoryInterface $cartRepository,
+        MessageBusInterface $bus,
+        OrderProcessorInterface $orderProcessor,
         RequestStack $requestStack
     ) {
         $this->cartManager = $cartManager;
-        $this->cartContext = $cartContext;
         $this->cartRepository = $cartRepository;
+        $this->bus = $bus;
+        $this->orderProcessor = $orderProcessor;
         $this->requestStack = $requestStack;
     }
 
@@ -51,33 +56,24 @@ public function onJwtLogin(JWTCreatedEvent $interactiveLoginEvent): void
             return;
         }
 
-        $cart = $this->getCart($request->request->get('token'));
+        $token = $request->request->get('token');
+
+        $cart = $this->cartRepository->findOneBy(['tokenValue' => $token]);
 
         if (null === $cart) {
             return;
         }
 
-        $cart->setCustomer($user->getCustomer());
-        $this->cartManager->persist($cart);
-        $this->cartManager->flush();
-    }
-
-    private function getCart(?string $token): ?OrderInterface
-    {
-        if (null !== $token) {
-            /** @var OrderInterface $cart */
-            $cart = $this->cartRepository->findOneBy(['tokenValue' => $token]);
-
-            return $cart;
-        }
+        $this->bus->dispatch(
+            new AssignCustomerToCart(
+                $token,
+                $user->getCustomer()->getEmail()
+            )
+        );
 
-        try {
-            /** @var OrderInterface $cart */
-            $cart = $this->cartContext->getCart();
+        $this->orderProcessor->process($cart);
 
-            return $cart;
-        } catch (CartNotFoundException $exception) {
-            return null;
-        }
+        $this->cartManager->persist($cart);
+        $this->cartManager->flush();
     }
 }