From 0c5f8a37c03a4eeb011a2d2bb033d031e5f188cc Mon Sep 17 00:00:00 2001
From: Oleksii Skorobogatko <skorobogatko.oleksii@gmail.com>
Date: Sat, 31 Aug 2024 21:18:36 +0300
Subject: [PATCH] #4 subscriber notifications, wip

---
 config/services.yaml                          |  4 ++
 .../NotifySubscribersListener.php             | 23 +++++++++++
 ...ificationHandlerNotRegisteredException.php | 16 ++++++++
 .../Notification/HttpNotificationHandler.php  | 39 ++++++++++++++++++
 .../NotificationHandlerCollection.php         | 41 +++++++++++++++++++
 .../NotificationHandlerInterface.php          | 13 ++++++
 6 files changed, 136 insertions(+)
 create mode 100644 src/EventListener/NotifySubscribersListener.php
 create mode 100644 src/Subscriber/Exception/NotificationHandlerNotRegisteredException.php
 create mode 100644 src/Subscriber/Notification/HttpNotificationHandler.php
 create mode 100644 src/Subscriber/Notification/NotificationHandlerCollection.php
 create mode 100644 src/Subscriber/Notification/NotificationHandlerInterface.php

diff --git a/config/services.yaml b/config/services.yaml
index aff476e..e8e28ec 100644
--- a/config/services.yaml
+++ b/config/services.yaml
@@ -36,3 +36,7 @@ services:
     App\Order\OrderTotalAmountCalculator:
         arguments:
             $currencyCode: 'UAH'
+
+    App\Subscriber\Notification\HttpNotificationHandler:
+        tags:
+            - { name: 'app.subscriber.notification', type: 'http' }
diff --git a/src/EventListener/NotifySubscribersListener.php b/src/EventListener/NotifySubscribersListener.php
new file mode 100644
index 0000000..2b1c843
--- /dev/null
+++ b/src/EventListener/NotifySubscribersListener.php
@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\EventListener;
+
+use App\Event\OrderStatusWasChanged;
+use App\Repository\SubscriberRepository;
+use Symfony\Component\EventDispatcher\Attribute\AsEventListener;
+
+final class NotifySubscribersListener
+{
+    public function __construct(
+        private readonly SubscriberRepository $subscriberRepository,
+    ) {
+    }
+
+    #[AsEventListener(event: OrderStatusWasChanged::class)]
+    public function onOrderStatusWasChanged(OrderStatusWasChanged $event): void
+    {
+        $subscribers = $this->subscriberRepository->getList($event->order->getStatus());
+    }
+}
diff --git a/src/Subscriber/Exception/NotificationHandlerNotRegisteredException.php b/src/Subscriber/Exception/NotificationHandlerNotRegisteredException.php
new file mode 100644
index 0000000..2d875a1
--- /dev/null
+++ b/src/Subscriber/Exception/NotificationHandlerNotRegisteredException.php
@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Subscriber\Exception;
+
+use Exception;
+
+final class NotificationHandlerNotRegisteredException extends Exception
+{
+    public function __construct(
+        public readonly string $notificationHandlerType,
+    ) {
+        parent::__construct("Subscriber notification handler type \"$this->notificationHandlerType\" is not registered.");
+    }
+}
diff --git a/src/Subscriber/Notification/HttpNotificationHandler.php b/src/Subscriber/Notification/HttpNotificationHandler.php
new file mode 100644
index 0000000..4a5a990
--- /dev/null
+++ b/src/Subscriber/Notification/HttpNotificationHandler.php
@@ -0,0 +1,39 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Subscriber\Notification;
+
+use App\Entity\Order;
+use App\Payment\Common\Message\ResponseInterface;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
+
+final readonly class HttpNotificationHandler implements NotificationHandlerInterface
+{
+    public function __construct(
+        private HttpClientInterface $httpClient,
+    ) {
+    }
+
+    /**
+     * @param Order $order
+     * @param ResponseInterface $response
+     * @param array{url: string, method: string} $params
+     * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
+     */
+    public function send(Order $order, ResponseInterface $response, array $params): void
+    {
+        $url = $params['url'] ?? '';
+        $method = $params['method'] ?? '';
+
+        $data = [
+            'order_num' => $order->getExternalOrderId(),
+            'order_status' => $order->getStatus()->value,
+            'response' => $response,
+        ];
+
+        $this->httpClient->request($method, $url, [
+            'json' => $data,
+        ]);
+    }
+}
diff --git a/src/Subscriber/Notification/NotificationHandlerCollection.php b/src/Subscriber/Notification/NotificationHandlerCollection.php
new file mode 100644
index 0000000..79ac7d7
--- /dev/null
+++ b/src/Subscriber/Notification/NotificationHandlerCollection.php
@@ -0,0 +1,41 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Subscriber\Notification;
+
+use App\Subscriber\Exception\NotificationHandlerNotRegisteredException;
+use Symfony\Component\DependencyInjection\Attribute\TaggedIterator;
+
+class NotificationHandlerCollection
+{
+    /**
+     * @var array<string, NotificationHandlerInterface>
+     */
+    private readonly array $handlers;
+
+    public function __construct(
+        #[TaggedIterator('app.subscriber.notification', indexAttribute: 'type')]
+        iterable $handlers,
+    ) {
+        $this->handlers = iterator_to_array($handlers);
+    }
+
+    /**
+     * @param non-empty-string $type
+     * @throws NotificationHandlerNotRegisteredException
+     */
+    public function getHandler(string $type): NotificationHandlerInterface
+    {
+        return $this->handlers[$type]
+            ?? throw new NotificationHandlerNotRegisteredException($type);
+    }
+
+    /**
+     * @return string[]
+     */
+    public function getHandlerTypes(): array
+    {
+        return array_keys($this->handlers);
+    }
+}
diff --git a/src/Subscriber/Notification/NotificationHandlerInterface.php b/src/Subscriber/Notification/NotificationHandlerInterface.php
new file mode 100644
index 0000000..dd12cbf
--- /dev/null
+++ b/src/Subscriber/Notification/NotificationHandlerInterface.php
@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Subscriber\Notification;
+
+use App\Entity\Order;
+use App\Payment\Common\Message\ResponseInterface;
+
+interface NotificationHandlerInterface
+{
+    public function send(Order $order, ResponseInterface $response, array $params): void;
+}