transaction created event

Author: rez1dent3

config/config.php

@@ -6,12 +6,14 @@
 use Bavix\Wallet\Internal\Assembler\BalanceUpdatedEventAssembler;
 use Bavix\Wallet\Internal\Assembler\ExtraDtoAssembler;
 use Bavix\Wallet\Internal\Assembler\OptionDtoAssembler;
+use Bavix\Wallet\Internal\Assembler\TransactionCreatedEventAssembler;
 use Bavix\Wallet\Internal\Assembler\TransactionDtoAssembler;
 use Bavix\Wallet\Internal\Assembler\TransactionQueryAssembler;
 use Bavix\Wallet\Internal\Assembler\TransferDtoAssembler;
 use Bavix\Wallet\Internal\Assembler\TransferLazyDtoAssembler;
 use Bavix\Wallet\Internal\Assembler\TransferQueryAssembler;
 use Bavix\Wallet\Internal\Events\BalanceUpdatedEvent;
+use Bavix\Wallet\Internal\Events\TransactionCreatedEvent;
 use Bavix\Wallet\Internal\Events\WalletCreatedEvent;
 use Bavix\Wallet\Internal\Repository\TransactionRepository;
 use Bavix\Wallet\Internal\Repository\TransferRepository;
@@ -139,6 +141,7 @@
         'transaction' => TransactionDtoAssembler::class,
         'transfer_lazy' => TransferLazyDtoAssembler::class,
         'transfer' => TransferDtoAssembler::class,
+        'transaction_created_event' => TransactionCreatedEventAssembler::class,
         'transaction_query' => TransactionQueryAssembler::class,
         'transfer_query' => TransferQueryAssembler::class,
     ],
@@ -149,6 +152,7 @@
     'events' => [
         'balance_updated' => BalanceUpdatedEvent::class,
         'wallet_created' => WalletCreatedEvent::class,
+        'transaction_created' => TransactionCreatedEvent::class,
     ],
 
     /**

src/Internal/Assembler/TransactionCreatedEventAssembler.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Assembler;
+
+use Bavix\Wallet\Internal\Events\TransactionCreatedEvent;
+use Bavix\Wallet\Internal\Events\TransactionCreatedEventInterface;
+use Bavix\Wallet\Internal\Service\ClockServiceInterface;
+use Bavix\Wallet\Models\Transaction;
+
+final class TransactionCreatedEventAssembler implements TransactionCreatedEventAssemblerInterface
+{
+    public function __construct(
+        private ClockServiceInterface $clockService
+    ) {
+    }
+
+    public function create(Transaction $transaction): TransactionCreatedEventInterface
+    {
+        return new TransactionCreatedEvent(
+            (int) $transaction->getKey(),
+            $transaction->type,
+            $transaction->wallet_id,
+            $this->clockService->now(),
+        );
+    }
+}

src/Internal/Assembler/TransactionCreatedEventAssemblerInterface.php

@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Assembler;
+
+use Bavix\Wallet\Internal\Events\TransactionCreatedEventInterface;
+use Bavix\Wallet\Models\Transaction;
+
+interface TransactionCreatedEventAssemblerInterface
+{
+    public function create(Transaction $transaction): TransactionCreatedEventInterface;
+}

src/Internal/Events/TransactionCreatedEvent.php

@@ -0,0 +1,38 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Events;
+
+use DateTimeImmutable;
+
+final class TransactionCreatedEvent implements TransactionCreatedEventInterface
+{
+    public function __construct(
+        private int $id,
+        private string $type,
+        private int $walletId,
+        private DateTimeImmutable $createdAt,
+    ) {
+    }
+
+    public function getId(): int
+    {
+        return $this->id;
+    }
+
+    public function getType(): string
+    {
+        return $this->type;
+    }
+
+    public function getWalletId(): int
+    {
+        return $this->walletId;
+    }
+
+    public function getCreatedAt(): DateTimeImmutable
+    {
+        return $this->createdAt;
+    }
+}

src/Internal/Events/TransactionCreatedEventInterface.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bavix\Wallet\Internal\Events;
+
+use DateTimeImmutable;
+
+interface TransactionCreatedEventInterface extends EventInterface
+{
+    public function getId(): int;
+
+    public function getType(): string;
+
+    public function getWalletId(): int;
+
+    public function getCreatedAt(): DateTimeImmutable;
+}

src/Services/TransactionService.php

@@ -5,14 +5,18 @@
 namespace Bavix\Wallet\Services;
 
 use Bavix\Wallet\Interfaces\Wallet;
+use Bavix\Wallet\Internal\Assembler\TransactionCreatedEventAssemblerInterface;
 use Bavix\Wallet\Internal\Dto\TransactionDtoInterface;
 use Bavix\Wallet\Internal\Exceptions\LockProviderNotFoundException;
 use Bavix\Wallet\Internal\Exceptions\RecordNotFoundException;
+use Bavix\Wallet\Internal\Service\DispatcherServiceInterface;
 use Bavix\Wallet\Models\Transaction;
 
 final class TransactionService implements TransactionServiceInterface
 {
     public function __construct(
+        private TransactionCreatedEventAssemblerInterface $transactionCreatedEventAssembler,
+        private DispatcherServiceInterface $dispatcherService,
         private AssistantServiceInterface $assistantService,
         private RegulatorServiceInterface $regulatorService,
         private PrepareServiceInterface $prepareService,
@@ -69,6 +73,10 @@ public function apply(array $wallets, array $objects): array
             $this->regulatorService->increase($object, $total);
         }
 
+        foreach ($transactions as $transaction) {
+            $this->dispatcherService->dispatch($this->transactionCreatedEventAssembler->create($transaction));
+        }
+
         return $transactions;
     }
 }

src/WalletServiceProvider.php

@@ -13,6 +13,8 @@
 use Bavix\Wallet\Internal\Assembler\ExtraDtoAssemblerInterface;
 use Bavix\Wallet\Internal\Assembler\OptionDtoAssembler;
 use Bavix\Wallet\Internal\Assembler\OptionDtoAssemblerInterface;
+use Bavix\Wallet\Internal\Assembler\TransactionCreatedEventAssembler;
+use Bavix\Wallet\Internal\Assembler\TransactionCreatedEventAssemblerInterface;
 use Bavix\Wallet\Internal\Assembler\TransactionDtoAssembler;
 use Bavix\Wallet\Internal\Assembler\TransactionDtoAssemblerInterface;
 use Bavix\Wallet\Internal\Assembler\TransactionQueryAssembler;
@@ -27,6 +29,8 @@
 use Bavix\Wallet\Internal\Assembler\WalletCreatedEventAssemblerInterface;
 use Bavix\Wallet\Internal\Events\BalanceUpdatedEvent;
 use Bavix\Wallet\Internal\Events\BalanceUpdatedEventInterface;
+use Bavix\Wallet\Internal\Events\TransactionCreatedEvent;
+use Bavix\Wallet\Internal\Events\TransactionCreatedEventInterface;
 use Bavix\Wallet\Internal\Events\WalletCreatedEvent;
 use Bavix\Wallet\Internal\Events\WalletCreatedEventInterface;
 use Bavix\Wallet\Internal\Repository\TransactionRepository;
@@ -290,6 +294,11 @@ private function assemblers(array $configure): void
             WalletCreatedEventAssemblerInterface::class,
             $configure['wallet_created_event'] ?? WalletCreatedEventAssembler::class
         );
+
+        $this->app->singleton(
+            TransactionCreatedEventAssemblerInterface::class,
+            $configure['transaction_created_event'] ?? TransactionCreatedEventAssembler::class
+        );
     }
 
     private function transformers(array $configure): void
@@ -316,6 +325,11 @@ private function events(array $configure): void
             WalletCreatedEventInterface::class,
             $configure['wallet_created'] ?? WalletCreatedEvent::class
         );
+
+        $this->app->bind(
+            TransactionCreatedEventInterface::class,
+            $configure['transaction_created'] ?? TransactionCreatedEvent::class
+        );
     }
 
     private function bindObjects(array $configure): void