Improve index & remove entity message handler

Setono · Feb 20, 2025 · 68079c6 · 68079c6
1 parent adecef0
commit 68079c6
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 1 deletion.
diff --git a/src/Message/Handler/AbstractEntityHandler.php b/src/Message/Handler/AbstractEntityHandler.php
@@ -22,7 +22,7 @@ public function __construct(ManagerRegistry $managerRegistry, private readonly I
         $this->managerRegistry = $managerRegistry;
     }
 
-    public function __invoke(RemoveEntity|IndexEntity $message): void
+    protected function handle(RemoveEntity|IndexEntity $message): void
     {
         $entity = $this->getManager($message->class)->find($message->class, $message->id);
         if (null === $entity) {

diff --git a/src/Message/Handler/IndexEntityHandler.php b/src/Message/Handler/IndexEntityHandler.php
@@ -5,10 +5,16 @@
 namespace Setono\SyliusMeilisearchPlugin\Message\Handler;
 
 use Setono\SyliusMeilisearchPlugin\Config\Index;
+use Setono\SyliusMeilisearchPlugin\Message\Command\IndexEntity;
 use Setono\SyliusMeilisearchPlugin\Model\IndexableInterface;
 
 final class IndexEntityHandler extends AbstractEntityHandler
 {
+    public function __invoke(IndexEntity $message): void
+    {
+        $this->handle($message);
+    }
+
     protected function execute(IndexableInterface $entity, Index $index): void
     {
         $index->indexer()->indexEntity($entity);

diff --git a/src/Message/Handler/RemoveEntityHandler.php b/src/Message/Handler/RemoveEntityHandler.php
@@ -5,10 +5,16 @@
 namespace Setono\SyliusMeilisearchPlugin\Message\Handler;
 
 use Setono\SyliusMeilisearchPlugin\Config\Index;
+use Setono\SyliusMeilisearchPlugin\Message\Command\RemoveEntity;
 use Setono\SyliusMeilisearchPlugin\Model\IndexableInterface;
 
 final class RemoveEntityHandler extends AbstractEntityHandler
 {
+    public function __invoke(RemoveEntity $message): void
+    {
+        $this->handle($message);
+    }
+
     protected function execute(IndexableInterface $entity, Index $index): void
     {
         $index->indexer()->removeEntity($entity);