feat(bus): add disable transaction contract when dispatch command

pandawa · Oct 14, 2021 · 10bff60 · 10bff60
1 parent 3a351f8
commit 10bff60
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 2 deletions.
diff --git a/src/Component/Bus/Contract/DisableTransaction.php b/src/Component/Bus/Contract/DisableTransaction.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Pandawa\Component\Bus\Contract;
+
+/**
+ * @author  Iqbal Maulana <iq.bluejack@gmail.com>
+ */
+interface DisableTransaction
+{
+}
diff --git a/src/Component/Bus/Pipe/DatabaseTransactionPipe.php b/src/Component/Bus/Pipe/DatabaseTransactionPipe.php
@@ -12,9 +12,10 @@
 
 namespace Pandawa\Component\Bus\Pipe;
 
+use Illuminate\Support\Facades\DB;
+use Pandawa\Component\Bus\Contract\DisableTransaction;
 use Pandawa\Component\Message\AbstractCommand;
 use Pandawa\Component\Message\AbstractMessage;
-use DB;
 
 /**
  * @author  Iqbal Maulana <iq.bluejack@gmail.com>
@@ -33,7 +34,7 @@ final class DatabaseTransactionPipe
      */
     public function handle($message, $next)
     {
-        if ($message instanceof AbstractCommand) {
+        if ($message instanceof AbstractCommand && !$message instanceof DisableTransaction) {
             return DB::transaction(
                 function () use ($message, $next) {
                     return $next($message);