create purchase domain event

app/Frontend/Purchase/Exceptions/PurchaseFailedException.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Frontend\Purchase\Exceptions;
+
+use Exception;
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\Response;
+
+class PurchaseFailedException extends Exception
+{
+    public function render(): JsonResponse
+    {
+        return response()
+            ->json([
+                'message' => 'The purchase could not be completed. Please wait and try again.'
+            ], Response::HTTP_EXPECTATION_FAILED);
+    }
+}

app/Frontend/Purchase/Mail/OrderReceivedNotification.php

@@ -0,0 +1,30 @@
+<?php declare(strict_types=1);
+
+namespace App\Frontend\Purchase\Mail;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Mail\Mailable;
+use Illuminate\Queue\SerializesModels;
+use Src\Frontend\Customer\Domain\Customer;
+use Src\Frontend\Purchase\Domain\Purchase;
+
+final class OrderReceivedNotification extends Mailable
+{
+    use Queueable;
+    use SerializesModels;
+
+    public Purchase $purchase;
+
+    public function __construct(Purchase $purchase)
+    {
+        $this->purchase = $purchase;
+    }
+
+    public function build(): self
+    {
+        return $this->view('frontend.purchase.emails.order_received')
+            ->with([
+                'purchase' => $this->purchase,
+            ]);
+    }
+}

app/Frontend/Purchase/Providers/PurchaseEventServiceProvider.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace App\Frontend\Purchase\Providers;
+
+
+use Illuminate\Foundation\Support\Providers\EventServiceProvider;
+use Src\Frontend\Purchase\Domain\PurchaseCreatedDomainEvent;
+use Src\Frontend\Purchase\Infrastructure\Mailer\LaravelMailerSendOrderReceivedNotification;
+
+class PurchaseEventServiceProvider extends EventServiceProvider
+{
+    protected $listen = [
+        PurchaseCreatedDomainEvent::class => [
+            LaravelMailerSendOrderReceivedNotification::class,
+        ]
+    ];
+}

config/app.php

@@ -186,6 +186,7 @@
          */
         \App\Frontend\Auth\Providers\AuthEventServiceProvider::class,
         \App\Frontend\Product\Providers\ProductEventServiceProvider::class,
+        \App\Frontend\Purchase\Providers\PurchaseEventServiceProvider::class,
 
     ],
 

resources/views/frontend/purchase/emails/order_received.blade.php

@@ -0,0 +1 @@
+We have received your order for {{ $purchase->uuid() }}

src/Frontend/Purchase/Application/Create/PurchaseCreator.php

@@ -4,6 +4,7 @@
 
 use Exception;
 use Src\Frontend\Auth\Domain\CustomerAuthRepository;
+use Src\Frontend\Customer\Domain\CustomerUuid;
 use Src\Frontend\Purchase\Domain\Purchase;
 use Src\Frontend\Purchase\Domain\PurchasePriority;
 use Src\Frontend\Purchase\Domain\PurchaseQuantity;
@@ -28,7 +29,7 @@ public function __construct(
         PurchaseRepository $purchaseRepository,
         EventBus $eventBus,
         EnsureVariantStockRepository $ensureVariantStockRepository,
-        TransactionRepository $transactionRepository
+        TransactionRepository $transactionRepository,
     ) {
         $this->customerAuthRepository = $customerAuthRepository;
         $this->purchaseRepository = $purchaseRepository;
@@ -37,14 +38,14 @@ public function __construct(
         $this->transactionRepository = $transactionRepository;
     }
 
-    public function __invoke(array $attributes): Purchase
+    public function __invoke(array $attributes): ?Purchase
     {
         $variantUuid = new VariantUuid($attributes['variant_uuid']);
         $quantity = new PurchaseQuantity($attributes['quantity']);
 
         $purchase = Purchase::create(
             PurchaseUuid::generate(),
-            $this->customerAuthRepository->user()->uuid(),
+            new CustomerUuid('b5ac9ecb-7173-3f0f-8273-f09bcc0c9846'),
             $variantUuid,
             PurchaseState::Reserved,
             PurchasePriority::from($attributes['priority']),
@@ -65,6 +66,8 @@ public function __invoke(array $attributes): Purchase
             $this->transactionRepository->commit();
         } catch (Exception $exception) {
             $this->transactionRepository->rollback();
+
+            return null;
         }
 
         $this->eventBus->publish(...$purchase->pullDomainEvents());

src/Frontend/Purchase/Application/Listener/SendOrderReceivedNotification.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Src\Frontend\Purchase\Application\Listener;
+
+use Src\Frontend\Purchase\Domain\PurchaseCreatedDomainEvent;
+
+interface SendOrderReceivedNotification
+{
+    public function handle(PurchaseCreatedDomainEvent $event): void;
+}

src/Frontend/Purchase/Domain/Purchase.php

@@ -39,14 +39,18 @@ public static function create(
         PurchasePriority $priority,
         PurchaseQuantity $quantity
     ): self {
-        return new self(
+        $purchase = new self(
             $uuid,
             $customerUuid,
             $variantUuid,
             $state,
             $priority,
             $quantity
         );
+
+        $purchase->record(new PurchaseCreatedDomainEvent($purchase));
+
+        return $purchase;
     }
 
     public function uuid(): PurchaseUuid

src/Frontend/Purchase/Domain/PurchaseCreatedDomainEvent.php

@@ -0,0 +1,20 @@
+<?php declare(strict_types=1);
+
+namespace Src\Frontend\Purchase\Domain;
+
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Foundation\Events\Dispatchable;
+use Src\Shared\Domain\Bus\Event\DomainEvent;
+
+final class PurchaseCreatedDomainEvent implements DomainEvent
+{
+    use Dispatchable;
+    use InteractsWithSockets;
+
+    public Purchase $purchase;
+
+    public function __construct(Purchase $purchase)
+    {
+        $this->purchase = $purchase;
+    }
+}

src/Frontend/Purchase/Infrastructure/Mailer/LaravelMailerSendOrderReceivedNotification.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace Src\Frontend\Purchase\Infrastructure\Mailer;
+
+use App\Frontend\Purchase\Mail\OrderReceivedNotification;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Support\Facades\Mail;
+use Src\Frontend\Customer\Domain\CustomerRepository;
+use Src\Frontend\Purchase\Application\Listener\SendOrderReceivedNotification;
+use Src\Frontend\Purchase\Domain\PurchaseCreatedDomainEvent;
+
+class LaravelMailerSendOrderReceivedNotification implements SendOrderReceivedNotification, ShouldQueue
+{
+    private CustomerRepository $customerRepository;
+
+    public function __construct(CustomerRepository $customerRepository)
+    {
+        $this->customerRepository = $customerRepository;
+    }
+
+    public function handle(PurchaseCreatedDomainEvent $event): void
+    {
+        Mail::to(
+            $this->customerRepository
+                ->find($event->purchase->customerUuid())
+                ->email()
+                ->value()
+        )->send(new OrderReceivedNotification($event->purchase));
+    }
+}

src/Shared/Domain/Logger/Logger.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Src\Shared\Domain\Logger;
+
+interface Logger
+{
+    public function critical(string $message, array $context);
+}

src/Shared/Infrastructure/Logger/LaravelLogger.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace Src\Shared\Infrastructure\Logger;
+
+use Illuminate\Support\Facades\Log;
+use Src\Shared\Domain\Logger\Logger;
+
+class LaravelLogger implements Logger
+{
+    public function critical(string $message, array $context)
+    {
+        Log::critical($message, $context);
+    }
+}