[9.x] Fixed WalletService::create() without db::transaction()

bavix · Mar 15, 2023 · 2f6355b · 2f6355b
1 parent b45381c
commit 2f6355b
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 1 deletion.
diff --git a/src/Internal/Service/DispatcherService.php b/src/Internal/Service/DispatcherService.php
@@ -15,7 +15,8 @@ final class DispatcherService implements DispatcherServiceInterface
     private array $events = [];
 
     public function __construct(
-        private Dispatcher $dispatcher
+        private Dispatcher $dispatcher,
+        private ConnectionServiceInterface $connectionService
     ) {
     }
 
@@ -43,4 +44,11 @@ public function forgot(): void
 
         $this->events = [];
     }
+
+    public function lazyFlush(): void
+    {
+        if ($this->connectionService->get()->transactionLevel() === 0) {
+            $this->flush();
+        }
+    }
 }
diff --git a/src/Internal/Service/DispatcherServiceInterface.php b/src/Internal/Service/DispatcherServiceInterface.php
@@ -13,4 +13,6 @@ public function dispatch(EventInterface $event): void;
     public function forgot(): void;
 
     public function flush(): void;
+
+    public function lazyFlush(): void;
 }
diff --git a/src/Services/WalletService.php b/src/Services/WalletService.php
@@ -41,6 +41,7 @@ public function create(Model $model, array $data): Wallet
 
         $event = $this->walletCreatedEventAssembler->create($wallet);
         $this->dispatcherService->dispatch($event);
+        $this->dispatcherService->lazyFlush();
 
         return $wallet;
     }