Implementing ACID Transactions

config/packages/messenger.php

@@ -11,7 +11,11 @@
         'messenger' => [
             'default_bus' => 'command.bus',
             'buses' => [
-                'command.bus' => [],
+                'command.bus' => [
+                    'middleware' => [
+                        'messenger.middleware.doctrine_transaction',
+                    ],
+                ],
                 'query.bus' => [],
             ],
             'transports' => [

src/BookStore/Application/Command/AnonymizeBooksCommandHandler.php

@@ -22,8 +22,6 @@ public function __invoke(AnonymizeBooksCommand $command): void
             $book->update(
                 author: new Author($command->anonymizedName),
             );
-
-            $this->bookRepository->save($book);
         }
     }
 }

src/BookStore/Application/Command/CreateBookCommandHandler.php

@@ -10,7 +10,7 @@
 
 final readonly class CreateBookCommandHandler implements CommandHandlerInterface
 {
-    public function __construct(private readonly BookRepositoryInterface $bookRepository)
+    public function __construct(private BookRepositoryInterface $bookRepository)
     {
     }
 

src/BookStore/Application/Command/DiscountBookCommandHandler.php

@@ -22,7 +22,5 @@ public function __invoke(DiscountBookCommand $command): void
         }
 
         $book->applyDiscount($command->discount);
-
-        $this->bookRepository->save($book);
     }
 }

src/BookStore/Application/Command/UpdateBookCommandHandler.php

@@ -30,8 +30,6 @@ public function __invoke(UpdateBookCommand $command): Book
             price: $command->price,
         );
 
-        $this->bookRepository->save($book);
-
         return $book;
     }
 }

src/BookStore/Infrastructure/Doctrine/DoctrineBookRepository.php

@@ -28,13 +28,11 @@ public function __construct(EntityManagerInterface $em)
     public function save(Book $book): void
     {
         $this->em->persist($book);
-        $this->em->flush();
     }
 
     public function remove(Book $book): void
     {
         $this->em->remove($book);
-        $this->em->flush();
     }
 
     public function ofId(BookId $id): ?Book