[UC-30] Introduce cookie queue handling and implement CookieFlusherSubscriber

Author: tomkalon

config/services/cookie.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+
+<container xmlns="http://symfony.com/schema/dic/services" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
+    <services>
+        <defaults autowire="false" autoconfigure="false"/>
+        <service id="bit_bag.sylius_user_com_plugin.cookie.cookie_queue" class="BitBag\SyliusUserComPlugin\Cookie\CookieQueue" />
+    </services>
+</container>

config/services/event_subscriber.xml

@@ -15,5 +15,13 @@
             <argument type="service" id="monolog.logger.user_com"/>
             <tag name="kernel.event_subscriber"/>
         </service>
+
+        <service id="bit_bag.sylius_user_com_plugin.event_subscriber.cookie_flusher_subscriber" class="BitBag\SyliusUserComPlugin\EventSubscriber\CookieFlusherSubscriber">
+            <argument type="service" id="bit_bag.sylius_user_com_plugin.cookie.cookie_queue" />
+            <tag name="kernel.event_listener"
+                 event="kernel.response"
+                 method="onResponse"
+                 priority="0"/>
+        </service>
     </services>
 </container>

config/services/manager.xml

@@ -9,6 +9,7 @@
         >
             <argument type="service" id="request_stack"/>
             <argument type="service" id="security.token_storage"/>
+            <argument type="service" id="bit_bag.sylius_user_com_plugin.cookie.cookie_queue"/>
         </service>
 
         <service

src/Cookie/CookieQueue.php

@@ -0,0 +1,33 @@
+<?php
+
+/*
+ * This file has been created by developers from BitBag.
+ * Feel free to contact us once you face any issues or want to start
+ * You can find more information about us on https://bitbag.io and write us
+ * an email on hello@bitbag.io.
+ */
+
+declare(strict_types=1);
+
+namespace BitBag\SyliusUserComPlugin\Cookie;
+
+use Symfony\Component\HttpFoundation\Cookie;
+
+final class CookieQueue implements CookieQueueInterface
+{
+    private array $queued = [];
+
+    public function queue(Cookie $cookie): void
+    {
+        $this->queued[] = $cookie;
+    }
+
+    /** @return Cookie[] */
+    public function pullAll(): array
+    {
+        $all = $this->queued;
+        $this->queued = [];
+
+        return $all;
+    }
+}

src/Cookie/CookieQueueInterface.php

@@ -0,0 +1,22 @@
+<?php
+
+/*
+ * This file has been created by developers from BitBag.
+ * Feel free to contact us once you face any issues or want to start
+ * You can find more information about us on https://bitbag.io and write us
+ * an email on hello@bitbag.io.
+ */
+
+declare(strict_types=1);
+
+namespace BitBag\SyliusUserComPlugin\Cookie;
+
+use Symfony\Component\HttpFoundation\Cookie;
+
+interface CookieQueueInterface
+{
+    public function queue(Cookie $cookie): void;
+
+    /** @return  Cookie[] */
+    public function pullAll(): array;
+}

src/EventSubscriber/CookieFlusherSubscriber.php

@@ -0,0 +1,31 @@
+<?php
+
+/*
+ * This file has been created by developers from BitBag.
+ * Feel free to contact us once you face any issues or want to start
+ * You can find more information about us on https://bitbag.io and write us
+ * an email on hello@bitbag.io.
+ */
+
+declare(strict_types=1);
+
+namespace BitBag\SyliusUserComPlugin\EventSubscriber;
+
+use BitBag\SyliusUserComPlugin\Cookie\CookieQueueInterface;
+use Symfony\Component\HttpKernel\Event\ResponseEvent;
+
+final class CookieFlusherSubscriber
+{
+    public function __construct(private readonly CookieQueueInterface $queue)
+    {
+    }
+
+    public function onResponse(ResponseEvent $event): void
+    {
+        $response = $event->getResponse();
+
+        foreach ($this->queue->pullAll() as $cookie) {
+            $response->headers->setCookie($cookie);
+        }
+    }
+}

src/Manager/CookieManager.php

@@ -11,7 +11,9 @@
 
 namespace BitBag\SyliusUserComPlugin\Manager;
 
+use BitBag\SyliusUserComPlugin\Cookie\CookieQueueInterface;
 use Sylius\Component\Core\Model\AdminUserInterface;
+use Symfony\Component\HttpFoundation\Cookie;
 use Symfony\Component\HttpFoundation\RequestStack;
 use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
 
@@ -20,6 +22,7 @@ final class CookieManager implements CookieManagerInterface
     public function __construct(
         private readonly RequestStack $requestStack,
         private readonly TokenStorageInterface $tokenStorage,
+        private readonly CookieQueueInterface $queue,
     ) {
     }
 
@@ -41,11 +44,14 @@ public function getUserComCookie(): ?string
 
     public function setUserComCookie(string $value): void
     {
-        $request = $this->requestStack->getCurrentRequest();
-        if (null === $request) {
-            return;
-        }
-        $request->cookies->set(self::CHAT_COOKIE_NAME, $value);
+        $cookie = Cookie::create(self::CHAT_COOKIE_NAME)
+            ->withValue($value)
+            ->withPath('/')
+            ->withSecure(true)
+            ->withHttpOnly(true)
+            ->withSameSite('lax');
+
+        $this->queue->queue($cookie);
     }
 
     private function isShopUser(): bool

src/Updater/CustomerWithKeyUpdater.php

@@ -154,7 +154,7 @@ private function updateForUserWithoutEmail(
             $this->userApi->mergeUsers($apiAwareResource, $customerFoundByEmail['id'], [$userFromUserKey['id']]);
         }
 
-        $this->sendEvent($apiAwareResource, $email, $eventName, $payload);
+        $this->changeCookieWithEvent($user, $apiAwareResource, $eventName);
 
         return $user;
     }