step 9: introduce the query bus

KnpLabs · Apr 29, 2024 · a394968 · a394968
1 parent db7781c
commit a394968
Show file tree

Hide file tree

Showing 21 changed files with 472 additions and 41 deletions.
diff --git a/config/packages/messenger.yaml b/config/packages/messenger.yaml
@@ -8,3 +8,5 @@ framework:
       command.bus:
         middleware:
           - doctrine_transaction
+
+      query.bus: ~
diff --git a/config/services/messenger.yaml b/config/services/messenger.yaml
@@ -11,3 +11,8 @@ services:
   Application\MessageBus\CommandBus:
     alias: Infrastructure\Symfony\Messenger\CommandBus
 
+  Infrastructure\Symfony\Messenger\QueryBus:
+    $messageBus: '@query.bus'
+
+  Application\MessageBus\QueryBus:
+    alias: Infrastructure\Symfony\Messenger\QueryBus
diff --git a/config/services/queries.yaml b/config/services/queries.yaml
@@ -0,0 +1,11 @@
+---
+services:
+  _defaults:
+    autowire: true
+    autoconfigure: true
+    public: false
+
+  Domain\Query\:
+    resource: '%kernel.project_dir%/src/Domain/Query/**/Handler.php'
+    tags:
+      - { name: messenger.message_handler, bus: query.bus }
diff --git a/src/Application/Controller/DinosaursController.php b/src/Application/Controller/DinosaursController.php
@@ -5,7 +5,10 @@
 use Application\Form\Type\DinosaurType;
 use Application\Form\Type\SearchType;
 use Application\MessageBus\CommandBus;
-use Domain\Collection\DinosaursCollection;
+use Application\MessageBus\QueryBus;
+use Domain\Exception\DinosaurNotFoundException;
+use Domain\Query\GetSingleDinosaur;
+use Domain\Query\GetAllDinosaurs;
 use Domain\UseCase\CreateDinosaur;
 use Domain\UseCase\EditDinosaur;
 use Domain\UseCase\RemoveDinosaur;
@@ -18,8 +21,8 @@
 final class DinosaursController extends AbstractController
 {
     public function __construct(
-        private DinosaursCollection $dinosaursCollection,
-        private CommandBus $commandBus
+        private CommandBus $commandBus,
+        private QueryBus $queryBus
     ) {
     }
 
@@ -37,9 +40,7 @@ public function list(Request $request): Response
             $q = $search['q'];
         }
 
-        $dinosaurs = $this
-            ->dinosaursCollection
-            ->search($q);
+        $dinosaurs = $this->queryBus->dispatch(new GetAllDinosaurs\Query($q));
 
         return $this->render('dinosaurs-list.html.twig', [
             'dinosaurs' => $dinosaurs,
@@ -108,29 +109,22 @@ public function create(Request $request): Response
     )]
     public function edit(Request $request, int $id): Response
     {
-        $dinosaur = $this
-            ->dinosaursCollection
-            ->find($id);
-
-        if (false === $dinosaur) {
-            throw $this->createNotFoundException('The dinosaur you are looking for does not exists.');
+        try {
+            $dinosaur = $this->queryBus->dispatch(new GetSingleDinosaur\Query($id));
+        } catch (DinosaurNotFoundException $e) {
+            throw $this->createNotFoundException(
+                'The dinosaur you are looking for does not exists.'
+            );
         }
 
-        $form = $this->createForm(DinosaurType::class, $dinosaur->toArray());
+        $form = $this->createForm(DinosaurType::class, $dinosaur);
 
         $form->handleRequest($request);
 
         if ($form->isSubmitted() && $form->isValid()) {
             $dinosaur = $form->getData();
 
-            $input = new EditDinosaur\Input(
-                $id,
-                $dinosaur['name'],
-                $dinosaur['gender'],
-                $dinosaur['species']->getId(),
-                $dinosaur['age'],
-                $dinosaur['eyesColor']
-            );
+            $input = EditDinosaur\Input::fromReadModel($dinosaur);
 
             try {
                 $this->commandBus->dispatch($input);

diff --git a/src/Application/Controller/SpeciesController.php b/src/Application/Controller/SpeciesController.php
@@ -6,9 +6,11 @@
 
 use Application\Form\Type\SpeciesType;
 use Application\MessageBus\CommandBus;
-use Domain\Collection\SpeciesCollection;
+use Application\MessageBus\QueryBus;
 use Domain\Exception\SpeciesAlreadyExistsException;
 use Domain\Exception\SpeciesNotFoundException;
+use Domain\Query\GetAllSpecies;
+use Domain\Query\GetSingleSpecies;
 use Domain\UseCase\CreateSpecies;
 use Domain\UseCase\EditSpecies;
 use Domain\UseCase\RemoveSpecies;
@@ -20,17 +22,15 @@
 final class SpeciesController extends AbstractController
 {
     public function __construct(
-        private SpeciesCollection $speciesCollection,
-        private CommandBus $commandBus
+        private CommandBus $commandBus,
+        private QueryBus $queryBus
     ) {
     }
 
     #[Route('/species', name: 'app_list_species')]
     public function list(): Response
     {
-        $speciesList = $this
-            ->speciesCollection
-            ->findAll();
+        $speciesList = $this->queryBus->dispatch(new GetAllSpecies\Query());
 
         return $this->render('species-list.html.twig', [
             'speciesList' => $speciesList,
@@ -76,26 +76,21 @@ public function create(Request $request): Response
     )]
     public function edit(Request $request, string $id): Response
     {
-        $species = $this
-            ->speciesCollection
-            ->find($id);
-
-        if (false === $species) {
-            throw $this->createNotFoundException('The species you are looking for does not exists.');
+        try {
+            $species = $this->queryBus->dispatch(new GetSingleSpecies\Query($id));
+        } catch (SpeciesNotFoundException $e) {
+            throw $this->createNotFoundException(
+                'The species you are looking for does not exists.'
+            );
         }
 
-        $form = $this->createForm(SpeciesType::class, $species->toArray());
+        $form = $this->createForm(SpeciesType::class, $species);
         $form->handleRequest($request);
 
         if ($form->isSubmitted() && $form->isValid()) {
-            $rawSpecies = $form->getData();
+            $species = $form->getData();
 
-            $input = new EditSpecies\Input(
-                speciesId: $id,
-                name: $rawSpecies['name'],
-                habitats: $rawSpecies['habitats'],
-                feeding: $rawSpecies['feeding']
-            );
+            $input = EditSpecies\Input::fromReadModel($species);
 
             try {
                 $this->commandBus->dispatch($input);

diff --git a/src/Application/Form/DataTransformer/SpeciesReadToModel.php b/src/Application/Form/DataTransformer/SpeciesReadToModel.php
@@ -0,0 +1,45 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Application\Form\DataTransformer;
+
+use Domain\Collection\SpeciesCollection;
+use Domain\Exception\SpeciesNotFoundException;
+use Domain\Model\Species as ModelSpecies;
+use Domain\ReadModel\Species;
+use Symfony\Component\Form\DataTransformerInterface;
+
+class SpeciesReadToModel implements DataTransformerInterface
+{
+    public function __construct(
+        private SpeciesCollection $speciesCollection
+    ) {
+    }
+
+    public function transform(mixed $value)
+    {
+        if (!$value instanceof Species) {
+            return $value;
+        }
+
+        $speciesId = (string) $value->getId();
+
+        $species = $this->speciesCollection->find($speciesId);
+
+        if ($species === null) {
+            throw new SpeciesNotFoundException($speciesId);
+        }
+
+        return $species;
+    }
+
+    public function reverseTransform(mixed $value)
+    {
+        if (!$value instanceof ModelSpecies) {
+            return $value;
+        }
+
+        return new Species($value);
+    }
+}
diff --git a/src/Application/Form/Type/DinosaurType.php b/src/Application/Form/Type/DinosaurType.php
@@ -2,6 +2,7 @@
 
 namespace Application\Form\Type;
 
+use Application\Form\DataTransformer\SpeciesReadToModel;
 use Domain\Model\Species;
 use Symfony\Bridge\Doctrine\Form\Type\EntityType;
 use Symfony\Component\Form\AbstractType;
@@ -13,6 +14,11 @@
 
 final class DinosaurType extends AbstractType
 {
+    public function __construct(
+        private SpeciesReadToModel $speciesReadToModel
+    ) {
+    }
+
     public function buildForm(FormBuilderInterface $builder, array $options): void
     {
         $builder
@@ -30,5 +36,7 @@ public function buildForm(FormBuilderInterface $builder, array $options): void
             ->add('age', NumberType::class)
             ->add('eyesColor', ColorType::class)
             ->add('submit', SubmitType::class);
+
+        $builder->get('species')->addModelTransformer($this->speciesReadToModel);
     }
 }
diff --git a/src/Application/MessageBus/QueryBus.php b/src/Application/MessageBus/QueryBus.php
@@ -0,0 +1,10 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Application\MessageBus;
+
+interface QueryBus
+{
+    public function dispatch(object $input): mixed;
+}
diff --git a/src/Domain/Query/GetAllDinosaurs/Handler.php b/src/Domain/Query/GetAllDinosaurs/Handler.php
@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Domain\Query\GetAllDinosaurs;
+
+use Domain\Collection\DinosaursCollection;
+use Domain\Model\Dinosaur as ModelDinosaur;
+use Domain\ReadModel\Dinosaur;
+
+class Handler
+{
+    public function __construct(
+        private DinosaursCollection $dinosaursCollection
+    ) {
+    }
+
+    public function __invoke(Query $query): array
+    {
+        $dinosaurs = $this->dinosaursCollection->search($query->search);
+
+        return array_map(
+            fn (ModelDinosaur $dinosaur) => new Dinosaur($dinosaur),
+            $dinosaurs
+        );
+    }
+}
diff --git a/src/Domain/Query/GetAllDinosaurs/Query.php b/src/Domain/Query/GetAllDinosaurs/Query.php
@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Domain\Query\GetAllDinosaurs;
+
+final class Query
+{
+    public function __construct(
+        public readonly ?string $search = null
+    ) {
+    }
+}
diff --git a/src/Domain/Query/GetAllSpecies/Handler.php b/src/Domain/Query/GetAllSpecies/Handler.php
@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Domain\Query\GetAllSpecies;
+
+use Domain\Collection\SpeciesCollection;
+use Domain\Model\Species as ModelSpecies;
+use Domain\ReadModel\Species;
+
+class Handler
+{
+    public function __construct(
+        private SpeciesCollection $speciesCollection
+    ) {
+    }
+
+    public function __invoke(Query $query): array
+    {
+        $species = $this->speciesCollection->findAll();
+
+        return array_map(
+            fn (ModelSpecies $species) => new Species($species),
+            $species
+        );
+    }
+}
diff --git a/src/Domain/Query/GetAllSpecies/Query.php b/src/Domain/Query/GetAllSpecies/Query.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Domain\Query\GetAllSpecies;
+
+final class Query
+{
+    public function __construct(
+    ) {
+    }
+}
diff --git a/src/Domain/Query/GetSingleDinosaur/Handler.php b/src/Domain/Query/GetSingleDinosaur/Handler.php
@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Domain\Query\GetSingleDinosaur;
+
+use Domain\Collection\DinosaursCollection;
+use Domain\Exception\DinosaurNotFoundException;
+use Domain\ReadModel\Dinosaur;
+
+class Handler
+{
+    public function __construct(
+        private DinosaursCollection $dinosaursCollection
+    ) {
+    }
+
+    public function __invoke(Query $query): Dinosaur
+    {
+        $dinosaur = $this->dinosaursCollection->find($query->id);
+
+        if ($dinosaur === null) {
+            throw new DinosaurNotFoundException($query->id);
+        }
+
+        return new Dinosaur($dinosaur);
+    }
+}
diff --git a/src/Domain/Query/GetSingleDinosaur/Query.php b/src/Domain/Query/GetSingleDinosaur/Query.php
@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Domain\Query\GetSingleDinosaur;
+
+final class Query
+{
+    public function __construct(
+        public readonly string $id,
+    ) {
+    }
+}