atomic service

Author: rez1dent3

.phpstorm.meta.php

@@ -7,8 +7,8 @@
     use Bavix\Wallet\Internal\Assembler\TransferLazyDtoAssemblerInterface;
     use Bavix\Wallet\Internal\Repository\TransactionRepositoryInterface;
     use Bavix\Wallet\Internal\Repository\TransferRepositoryInterface;
-    use Bavix\Wallet\Services\AtomicKeyService;
-    use Bavix\Wallet\Services\AtomicKeyServiceInterface;
+    use Bavix\Wallet\Services\AtomicService;
+    use Bavix\Wallet\Services\AtomicServiceInterface;
     use Bavix\Wallet\Services\CastServiceInterface;
     use Bavix\Wallet\Internal\Service\JsonServiceInterface;
     use Bavix\Wallet\Services\DiscountServiceInterface;
@@ -72,7 +72,7 @@
         // services
         AssistantServiceInterface::class => AssistantServiceInterface::class,
         AtmServiceInterface::class => AtmServiceInterface::class,
-        AtomicKeyServiceInterface::class => AtomicKeyServiceInterface::class,
+        AtomicServiceInterface::class => AtomicServiceInterface::class,
         BasketServiceInterface::class => BasketServiceInterface::class,
         BookkeeperServiceInterface::class => BookkeeperServiceInterface::class,
         CastServiceInterface::class => CastServiceInterface::class,

config/config.php

@@ -22,7 +22,7 @@
 use Bavix\Wallet\Models\Wallet;
 use Bavix\Wallet\Services\AssistantService;
 use Bavix\Wallet\Services\AtmService;
-use Bavix\Wallet\Services\AtomicKeyService;
+use Bavix\Wallet\Services\AtomicService;
 use Bavix\Wallet\Services\BasketService;
 use Bavix\Wallet\Services\BookkeeperService;
 use Bavix\Wallet\Services\CastService;
@@ -73,7 +73,7 @@
     'services' => [
         'assistant' => AssistantService::class,
         'atm' => AtmService::class,
-        'key' => AtomicKeyService::class,
+        'atomic' => AtomicService::class,
         'basket' => BasketService::class,
         'bookkeeper' => BookkeeperService::class,
         'cast' => CastService::class,

src/Services/AtomicKeyService.php

@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Services;
+
+use Bavix\Wallet\Internal\Service\LockServiceInterface;
+
+final class AtomicService implements AtomicServiceInterface
+{
+    private const PREFIX = 'wallet_atomic::';
+
+    private LockServiceInterface $lockService;
+    private CastServiceInterface $castService;
+
+    public function __construct(
+        LockServiceInterface $lockService,
+        CastServiceInterface $castService
+    ) {
+        $this->lockService = $lockService;
+        $this->castService = $castService;
+    }
+
+    /** @return mixed */
+    public function block(object $object, callable $closure)
+    {
+        return $this->lockService->block($this->key($object), $closure);
+    }
+
+    private function key(object $object): string
+    {
+        $model = $this->castService->getModel($object);
+
+        return self::PREFIX.'::'.get_class($model).'::'.$model->getKey();
+    }
+}

src/Services/AtomicKeyServiceInterface.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Services;
+
+interface AtomicServiceInterface
+{
+    /** @return mixed */
+    public function block(object $object, callable $closure);
+}

src/Services/AtomicService.php

@@ -4,27 +4,23 @@
 
 namespace Bavix\Wallet\Services;
 
-use Bavix\Wallet\Internal\Service\LockServiceInterface;
 use Bavix\Wallet\Internal\Service\MathServiceInterface;
 use Bavix\Wallet\Models\Wallet as WalletModel;
 
 final class WalletServiceLegacy
 {
     private MathServiceInterface $math;
-    private LockServiceInterface $lockService;
     private BookkeeperServiceInterface $bookkeeper;
-    private AtomicKeyServiceInterface $atomicKeyService;
+    private AtomicServiceInterface $atomicService;
 
     public function __construct(
         MathServiceInterface $math,
-        LockServiceInterface $lockService,
         BookkeeperServiceInterface $bookkeeper,
-        AtomicKeyServiceInterface $atomicKeyService
+        AtomicServiceInterface $atomicService
     ) {
         $this->math = $math;
-        $this->lockService = $lockService;
         $this->bookkeeper = $bookkeeper;
-        $this->atomicKeyService = $atomicKeyService;
+        $this->atomicService = $atomicService;
     }
 
     /**
@@ -33,7 +29,7 @@ public function __construct(
      */
     public function refresh(WalletModel $wallet): bool
     {
-        return $this->lockService->block($this->atomicKeyService->getIdentifier($wallet), function () use ($wallet) {
+        return $this->atomicService->block($wallet, function () use ($wallet) {
             $whatIs = $wallet->balance;
             $balance = $wallet->getAvailableBalance();
             if ($this->math->compare($whatIs, $balance) === 0) {

src/Services/AtomicServiceInterface.php

@@ -11,11 +11,10 @@
 use Bavix\Wallet\Exceptions\WalletOwnerInvalid;
 use Bavix\Wallet\Internal\Exceptions\ExceptionInterface;
 use Bavix\Wallet\Internal\Service\DatabaseServiceInterface;
-use Bavix\Wallet\Internal\Service\LockServiceInterface;
 use Bavix\Wallet\Internal\Service\MathServiceInterface;
 use Bavix\Wallet\Internal\Service\TranslatorServiceInterface;
 use Bavix\Wallet\Models\Transaction;
-use Bavix\Wallet\Services\AtomicKeyServiceInterface;
+use Bavix\Wallet\Services\AtomicServiceInterface;
 use Bavix\Wallet\Services\CastServiceInterface;
 use Bavix\Wallet\Services\CommonServiceLegacy;
 use Bavix\Wallet\Services\ConsistencyServiceInterface;
@@ -59,11 +58,7 @@ public function safeConfirm(Transaction $transaction): bool
      */
     public function resetConfirm(Transaction $transaction): bool
     {
-        $atomicKey = app(AtomicKeyServiceInterface::class)
-            ->getIdentifier($this)
-        ;
-
-        return app(LockServiceInterface::class)->block($atomicKey, fn () => app(DatabaseServiceInterface::class)->transaction(function () use ($transaction) {
+        return app(AtomicServiceInterface::class)->block($this, fn () => app(DatabaseServiceInterface::class)->transaction(function () use ($transaction) {
             if (!$transaction->confirmed) {
                 throw new UnconfirmedInvalid(
                     app(TranslatorServiceInterface::class)->get('wallet::errors.unconfirmed_invalid'),
@@ -98,11 +93,7 @@ public function safeResetConfirm(Transaction $transaction): bool
      */
     public function forceConfirm(Transaction $transaction): bool
     {
-        $atomicKey = app(AtomicKeyServiceInterface::class)
-            ->getIdentifier($this)
-        ;
-
-        return app(LockServiceInterface::class)->block($atomicKey, fn () => app(DatabaseServiceInterface::class)->transaction(function () use ($transaction) {
+        return app(AtomicServiceInterface::class)->block($this, fn () => app(DatabaseServiceInterface::class)->transaction(function () use ($transaction) {
             if ($transaction->confirmed) {
                 throw new ConfirmedInvalid(
                     app(TranslatorServiceInterface::class)->get('wallet::errors.confirmed_invalid'),

src/Services/WalletServiceLegacy.php

@@ -8,10 +8,9 @@
 use Bavix\Wallet\Internal\Assembler\TransferLazyDtoAssemblerInterface;
 use Bavix\Wallet\Internal\Exceptions\ExceptionInterface;
 use Bavix\Wallet\Internal\Service\DatabaseServiceInterface;
-use Bavix\Wallet\Internal\Service\LockServiceInterface;
 use Bavix\Wallet\Internal\Service\MathServiceInterface;
 use Bavix\Wallet\Models\Transfer;
-use Bavix\Wallet\Services\AtomicKeyServiceInterface;
+use Bavix\Wallet\Services\AtomicServiceInterface;
 use Bavix\Wallet\Services\CastServiceInterface;
 use Bavix\Wallet\Services\CommonServiceLegacy;
 use Bavix\Wallet\Services\ConsistencyServiceInterface;
@@ -50,11 +49,7 @@ public function safeExchange(Wallet $to, $amount, ?array $meta = null): ?Transfe
      */
     public function forceExchange(Wallet $to, $amount, ?array $meta = null): Transfer
     {
-        $atomicKey = app(AtomicKeyServiceInterface::class)
-            ->getIdentifier($this)
-        ;
-
-        return app(LockServiceInterface::class)->block($atomicKey, fn () => app(DatabaseServiceInterface::class)->transaction(function () use ($to, $amount, $meta) {
+        return app(AtomicServiceInterface::class)->block($this, fn () => app(DatabaseServiceInterface::class)->transaction(function () use ($to, $amount, $meta) {
             $prepareService = app(PrepareServiceInterface::class);
             $mathService = app(MathServiceInterface::class);
             $castService = app(CastServiceInterface::class);

src/Traits/CanConfirm.php

@@ -14,12 +14,11 @@
 use Bavix\Wallet\Internal\Assembler\TransferDtoAssemblerInterface;
 use Bavix\Wallet\Internal\Exceptions\ExceptionInterface;
 use Bavix\Wallet\Internal\Service\DatabaseServiceInterface;
-use Bavix\Wallet\Internal\Service\LockServiceInterface;
 use Bavix\Wallet\Internal\Service\MathServiceInterface;
 use Bavix\Wallet\Models\Transaction;
 use Bavix\Wallet\Models\Transfer;
 use Bavix\Wallet\Services\AtmServiceInterface;
-use Bavix\Wallet\Services\AtomicKeyServiceInterface;
+use Bavix\Wallet\Services\AtomicServiceInterface;
 use Bavix\Wallet\Services\CastServiceInterface;
 use Bavix\Wallet\Services\CommonServiceLegacy;
 use Bavix\Wallet\Services\ConsistencyServiceInterface;
@@ -56,11 +55,7 @@ public function safeGift(Wallet $to, Product $product, bool $force = false): ?Tr
      */
     public function gift(Wallet $to, Product $product, bool $force = false): Transfer
     {
-        $atomicKey = app(AtomicKeyServiceInterface::class)
-            ->getIdentifier($this)
-        ;
-
-        return app(LockServiceInterface::class)->block($atomicKey, function () use ($to, $product, $force): Transfer {
+        return app(AtomicServiceInterface::class)->block($this, function () use ($to, $product, $force): Transfer {
             /**
              * Who's giving? Let's call him Santa Claus.
              *