fix cache

Taskfile.yml

@@ -49,6 +49,9 @@ tasks:
     exec:
         cmds:
             - docker-compose -f docker-compose.yml exec {{.CLI_ARGS}}
+    symfony:
+        cmds:
+            - docker-compose -f docker-compose.yml exec app bash -c "php bin/console {{.CLI_ARGS}}"
     reset:
         cmds:
             - docker-compose -f docker-compose.yml exec app bash -c "php bin/console semart:reset"

lib/EventSubscriber/InvalidateDoctrineCacheSubscriber.php

@@ -0,0 +1,58 @@
+<?php
+
+declare(strict_types=1);
+
+namespace KejawenLab\ApiSkeleton\EventSubscriber;
+
+use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpKernel\Event\KernelEvent;
+use Symfony\Component\HttpKernel\Event\RequestEvent;
+use Symfony\Component\HttpKernel\Event\ResponseEvent;
+
+/**
+ * @author Muhamad Surya Iksanudin<[email protected]>
+ */
+final class InvalidateDoctrineCacheSubscriber implements EventSubscriberInterface
+{
+    public function __construct(private readonly EntityManagerInterface $entityManager)
+    {
+    }
+
+    public function invalidate(KernelEvent $event): void
+    {
+        if (!$event->isMainRequest()) {
+            return;
+        }
+
+        $request = $event->getRequest();
+        if ($request->isMethod(Request::METHOD_GET)) {
+            return;
+        }
+
+        if ($request->isMethod(Request::METHOD_HEAD)) {
+            return;
+        }
+
+        if ($request->isMethod(Request::METHOD_OPTIONS)) {
+            return;
+        }
+
+        $configuration = $this->entityManager->getConfiguration();
+
+        $configuration->getQueryCache()->clear();
+        $configuration->getResultCache()->clear();
+    }
+
+    /**
+     * @return array<string, string>
+     */
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            RequestEvent::class => [['invalidate', 27]],
+            ResponseEvent::class => [['invalidate', -27]],
+        ];
+    }
+}

lib/EventSubscriber/LogoutSubscriber.php

@@ -4,6 +4,7 @@
 
 namespace KejawenLab\ApiSkeleton\EventSubscriber;
 
+use Doctrine\ORM\EntityManagerInterface;
 use KejawenLab\ApiSkeleton\Admin\AdminContext;
 use KejawenLab\ApiSkeleton\Setting\Model\SettingInterface;
 use Psr\Cache\CacheItemPoolInterface;
@@ -20,6 +21,7 @@ final class LogoutSubscriber implements EventSubscriberInterface
     public function __construct(
         private readonly UrlGeneratorInterface $urlGenerator,
         private readonly CacheItemPoolInterface $cache,
+        private readonly EntityManagerInterface $entityManager,
     ) {
     }
 
@@ -35,6 +37,11 @@ public function redirect(LogoutEvent $event): void
         $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE);
         $this->cache->deleteItem(SettingInterface::CACHE_ID_MAX_API_PER_USER);
 
+        $configuration = $this->entityManager->getConfiguration();
+
+        $configuration->getQueryCache()->clear();
+        $configuration->getResultCache()->clear();
+
         $event->setResponse(new RedirectResponse($this->urlGenerator->generate(AdminContext::ADMIN_ROUTE)));
     }
 

lib/EventSubscriber/SingleLoginSubscriber.php

@@ -5,6 +5,7 @@
 namespace KejawenLab\ApiSkeleton\EventSubscriber;
 
 use DateTimeImmutable;
+use Doctrine\ORM\EntityManagerInterface;
 use KejawenLab\ApiSkeleton\Admin\AdminContext;
 use KejawenLab\ApiSkeleton\ApiClient\Model\ApiClientInterface;
 use KejawenLab\ApiSkeleton\Security\Model\UserInterface;
@@ -32,6 +33,7 @@ public function __construct(
         private readonly UserService $service,
         private readonly UserProviderFactory $userProviderFactory,
         private readonly CacheItemPoolInterface $cache,
+        private readonly EntityManagerInterface $entityManager,
     ) {
     }
 
@@ -72,6 +74,11 @@ public function decode(JWTDecodedEvent $event): void
             $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE);
             $this->cache->deleteItem(SettingInterface::CACHE_ID_MAX_API_PER_USER);
 
+            $configuration = $this->entityManager->getConfiguration();
+
+            $configuration->getQueryCache()->clear();
+            $configuration->getResultCache()->clear();
+
             return;
         }
 
@@ -92,6 +99,11 @@ public function decode(JWTDecodedEvent $event): void
         $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE_FIELD);
         $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE);
         $this->cache->deleteItem(SettingInterface::CACHE_ID_MAX_API_PER_USER);
+
+        $configuration = $this->entityManager->getConfiguration();
+
+        $configuration->getQueryCache()->clear();
+        $configuration->getResultCache()->clear();
     }
 
     public function create(JWTCreatedEvent $event): void
@@ -122,6 +134,11 @@ public function create(JWTCreatedEvent $event): void
         $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE_FIELD);
         $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE);
         $this->cache->deleteItem(SettingInterface::CACHE_ID_MAX_API_PER_USER);
+
+        $configuration = $this->entityManager->getConfiguration();
+
+        $configuration->getQueryCache()->clear();
+        $configuration->getResultCache()->clear();
     }
 
     /**

lib/Security/AdminAuthenticator.php

@@ -3,6 +3,7 @@
 namespace KejawenLab\ApiSkeleton\Security;
 
 use DateTimeImmutable;
+use Doctrine\ORM\EntityManagerInterface;
 use KejawenLab\ApiSkeleton\Admin\AdminContext;
 use KejawenLab\ApiSkeleton\Security\Model\UserInterface;
 use KejawenLab\ApiSkeleton\Security\Service\UserProviderFactory;
@@ -35,6 +36,7 @@ public function __construct(
         private readonly UserProviderFactory $userProviderFactory,
         private readonly UrlGeneratorInterface $urlGenerator,
         private readonly CacheItemPoolInterface $cache,
+        private readonly EntityManagerInterface $entityManager,
     ) {
     }
 
@@ -82,6 +84,10 @@ public function onAuthenticationSuccess(Request $request, TokenInterface $token,
         $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE_FIELD);
         $this->cache->deleteItem(SettingInterface::CACHE_ID_PER_PAGE);
         $this->cache->deleteItem(SettingInterface::CACHE_ID_MAX_API_PER_USER);
+        $configuration = $this->entityManager->getConfiguration();
+
+        $configuration->getQueryCache()->clear();
+        $configuration->getResultCache()->clear();
 
         return $this->redirect($session, $firewallName);
     }