Subscribe to laravel events

Author: rez1dent3

composer.json

@@ -28,7 +28,7 @@
     "brick/math": "~0.8",
     "doctrine/dbal": "^2.8|^3.0",
     "illuminate/contracts": "^9.0",
-    "illuminate/database": "^9.0",
+    "illuminate/database": "^9.37",
     "ramsey/uuid": "^4.0"
   },
   "require-dev": {

config/config.php

@@ -19,6 +19,7 @@
 use Bavix\Wallet\Internal\Repository\TransferRepository;
 use Bavix\Wallet\Internal\Repository\WalletRepository;
 use Bavix\Wallet\Internal\Service\ClockService;
+use Bavix\Wallet\Internal\Service\ConnectionService;
 use Bavix\Wallet\Internal\Service\DatabaseService;
 use Bavix\Wallet\Internal\Service\DispatcherService;
 use Bavix\Wallet\Internal\Service\JsonService;
@@ -82,6 +83,7 @@
      */
     'internal' => [
         'clock' => ClockService::class,
+        'connection' => ConnectionService::class,
         'database' => DatabaseService::class,
         'dispatcher' => DispatcherService::class,
         'json' => JsonService::class,

ecs.php

@@ -9,10 +9,10 @@
 use Symplify\CodingStandard\Fixer\LineLength\DocBlockLineLengthFixer;
 use Symplify\CodingStandard\Fixer\LineLength\LineLengthFixer;
 use Symplify\EasyCodingStandard\Config\ECSConfig;
-use Symplify\EasyCodingStandard\ValueObject\Option;
 use Symplify\EasyCodingStandard\ValueObject\Set\SetList;
 
 return static function (ECSConfig $containerConfigurator): void {
+    $containerConfigurator->parallel();
     $services = $containerConfigurator->services();
     $services->set(ArraySyntaxFixer::class)
         ->call('configure', [[
@@ -22,9 +22,6 @@
     $services->set(DeclareStrictTypesFixer::class);
     $services->set(LineLengthFixer::class);
 
-    $parameters = $containerConfigurator->parameters();
-    $parameters->set(Option::PARALLEL, true);
-
     $containerConfigurator->paths([
         __DIR__ . '/config',
         __DIR__ . '/database',

rector.php

@@ -4,12 +4,15 @@
 
 use Rector\CodeQuality\Rector\PropertyFetch\ExplicitMethodCallOverMagicGetSetRector;
 use Rector\Config\RectorConfig;
+use Rector\Laravel\Rector\Assign\CallOnAppArrayAccessToStandaloneAssignRector;
+use Rector\Laravel\Rector\ClassMethod\AddParentRegisterToEventServiceProviderRector;
 use Rector\Laravel\Set\LaravelSetList;
 use Rector\Php74\Rector\Property\TypedPropertyRector;
 use Rector\PHPUnit\Set\PHPUnitSetList;
 use Rector\Set\ValueObject\SetList;
 
 return static function (RectorConfig $containerConfigurator): void {
+    $containerConfigurator->parallel();
     $containerConfigurator->paths([
         __DIR__ . '/src',
         __DIR__ . '/tests',
@@ -29,4 +32,6 @@
 
     // register a single rule
     $services->set(TypedPropertyRector::class);
+    $services->set(CallOnAppArrayAccessToStandaloneAssignRector::class);
+    $services->set(AddParentRegisterToEventServiceProviderRector::class);
 };

src/Internal/Exceptions/ExceptionInterface.php

@@ -31,6 +31,4 @@ interface ExceptionInterface extends Throwable
     public const TRANSACTION_FAILED = 1 << 10;
 
     public const MODEL_NOT_FOUND = 1 << 11;
-
-    public const TRANSACTION_START = 1 << 12;
 }

src/Internal/Exceptions/TransactionRollbackException.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Exceptions;
+
+use InvalidArgumentException;
+
+final class TransactionRollbackException extends InvalidArgumentException implements ExceptionInterface
+{
+    public function __construct(
+        private mixed $result
+    ) {
+        parent::__construct();
+    }
+
+    public function getResult(): mixed
+    {
+        return $this->result;
+    }
+}

src/Internal/Exceptions/TransactionStartException.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Listeners;
+
+use Bavix\Wallet\Internal\Service\ConnectionServiceInterface;
+use Bavix\Wallet\Services\RegulatorServiceInterface;
+
+final class TransactionBeginningListener
+{
+    public function __construct(
+        private ConnectionServiceInterface $connectionService,
+        private RegulatorServiceInterface $regulatorService
+    ) {
+    }
+
+    public function __invoke(): void
+    {
+        if ($this->connectionService->get()->transactionLevel() === 1) {
+            $this->regulatorService->purge();
+        }
+    }
+}

src/Internal/Listeners/TransactionBeginningListener.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Listeners;
+
+use Bavix\Wallet\Internal\Service\ConnectionServiceInterface;
+use Bavix\Wallet\Services\RegulatorServiceInterface;
+
+final class TransactionCommittedListener
+{
+    public function __construct(
+        private ConnectionServiceInterface $connectionService,
+        private RegulatorServiceInterface $regulatorService
+    ) {
+    }
+
+    public function __invoke(): void
+    {
+        if ($this->connectionService->get()->transactionLevel() === 0) {
+            $this->regulatorService->committed();
+        }
+    }
+}

src/Internal/Listeners/TransactionCommittedListener.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Listeners;
+
+use Bavix\Wallet\Internal\Service\ConnectionServiceInterface;
+use Bavix\Wallet\Services\RegulatorServiceInterface;
+
+final class TransactionCommittingListener
+{
+    public function __construct(
+        private ConnectionServiceInterface $connectionService,
+        private RegulatorServiceInterface $regulatorService
+    ) {
+    }
+
+    public function __invoke(): void
+    {
+        /**
+         * In fact, this if is not needed here.
+         * But in order to protect the code from changes in the framework, I added a check here.
+         */
+        if ($this->connectionService->get()->transactionLevel() === 1) {
+            $this->regulatorService->committing();
+        }
+    }
+}