Queue implementation

composer.json

@@ -28,6 +28,8 @@
     },
     "require": {
         "php": "~8.2.0 || ~8.3.0",
+        "ext-sockets": "*",
+        "clue/socket-raw": "^v1.6.0",
         "dotkernel/dot-cache": "^4.3.0",
         "dotkernel/dot-cli": "^3.9.0",
         "dotkernel/dot-data-fixtures": "^1.4.0",
@@ -79,7 +81,8 @@
             "Core\\App\\": "src/Core/src/App/src",
             "Core\\Security\\": "src/Core/src/Security/src",
             "Core\\Setting\\": "src/Core/src/Setting/src",
-            "Core\\User\\": "src/Core/src/User/src"
+            "Core\\User\\": "src/Core/src/User/src",
+            "Core\\NotificationSystem\\": "src/Core/src/NotificationSystem/src"
         }
     },
     "autoload-dev": {

config/config.php

@@ -74,6 +74,7 @@ class_exists(Mezzio\Tooling\ConfigProvider::class)
     Core\Security\ConfigProvider::class,
     Core\Setting\ConfigProvider::class,
     Core\User\ConfigProvider::class,
+    Core\NotificationSystem\ConfigProvider::class,
 
     // Load application config in a pre-defined order in such a way that local settings
     // overwrite global settings. (Loaded as first to last):

src/Core/src/NotificationSystem/src/ConfigProvider.php

@@ -0,0 +1,41 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Core\NotificationSystem;
+
+use Core\NotificationSystem\Service\NotificationService;
+use Dot\DependencyInjection\Factory\AttributedServiceFactory;
+
+/**
+ * @phpstan-type ConfigType array{
+ *      dependencies: DependenciesType,
+ * }
+ * @phpstan-type DependenciesType array{
+ *       factories: array<class-string, class-string>,
+ * }
+ */
+class ConfigProvider
+{
+    /**
+     * @return ConfigType
+     */
+    public function __invoke(): array
+    {
+        return [
+            'dependencies' => $this->getDependencies(),
+        ];
+    }
+
+    /**
+     * @return DependenciesType
+     */
+    public function getDependencies(): array
+    {
+        return [
+            'factories' => [
+                NotificationService::class => AttributedServiceFactory::class,
+            ],
+        ];
+    }
+}

src/Core/src/NotificationSystem/src/Service/NotificationService.php

@@ -0,0 +1,52 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Core\NotificationSystem\Service;
+
+use Core\User\Entity\User;
+use Dot\DependencyInjection\Attribute\Inject;
+use Laminas\Json\Encoder;
+use Socket\Raw\Factory;
+use Socket\Raw\Socket;
+
+class NotificationService
+{
+    /**
+     * @param array<non-empty-string, mixed> $config
+     */
+    #[Inject(
+        'config.notification.server',
+    )]
+    public function __construct(
+        private readonly array $config
+    ) {
+    }
+
+    public function createClient(): Socket
+    {
+        $socketRawFactory = new Factory();
+        return $socketRawFactory->createClient(
+            $this->config['protocol'] . '://' . $this->config['host'] . ':' . $this->config['port']
+        );
+    }
+
+    public function send(string $message): void
+    {
+        $this->createClient()->write($message . $this->config['eof']);
+    }
+
+    /**
+     * @param array<non-empty-string, mixed> $data
+     */
+    protected function encodeEmailMessage(array $data): string
+    {
+        return Encoder::encode($data);
+    }
+
+    public function sendNewAccountNotification(User $user): void
+    {
+        $data['userUuid'] = $user->getUuid()->toString();
+        $this->send($this->encodeEmailMessage($data));
+    }
+}

src/User/src/Handler/PostUserCreateHandler.php

@@ -12,6 +12,7 @@
 use Admin\User\Service\UserServiceInterface;
 use Core\App\Message;
 use Core\App\Service\MailService;
+use Core\NotificationSystem\Service\NotificationService;
 use Dot\DependencyInjection\Attribute\Inject;
 use Dot\FlashMessenger\FlashMessengerInterface;
 use Dot\Log\Logger;
@@ -41,6 +42,7 @@
         FlashMessengerInterface::class,
         CreateUserForm::class,
         MailService::class,
+        NotificationService::class,
         'dot-log.default_logger',
         'config',
     )]
@@ -51,6 +53,7 @@
         protected FlashMessengerInterface $messenger,
         protected CreateUserForm $createUserForm,
         protected MailService $mailService,
+        protected NotificationService $notificationService,
         protected Logger $logger,
         protected array $config,
     ) {
@@ -71,11 +74,7 @@
                 $user = $this->userService->saveUser($data);
                 $this->messenger->addSuccess(Message::USER_CREATED);
                 if ($user->hasEmail()) {
-                    $body = $this->template->render('user::welcome', [
-                        'config' => $this->config,
-                        'user'   => $user,
-                    ]);
-                    $this->mailService->sendWelcomeMail($user, $body);
+                    $this->notificationService->sendNewAccountNotification($user);
                 }
 
                 return new EmptyResponse(StatusCodeInterface::STATUS_CREATED);
@@ -87,14 +86,14 @@
                 ]),
                 StatusCodeInterface::STATUS_UNPROCESSABLE_ENTITY
             );
         } catch (MailException $exception) {
             $this->logger->err('Send user welcome email', [
                 'error' => $exception->getMessage(),
                 'file'  => $exception->getFile(),
                 'line'  => $exception->getLine(),
                 'trace' => $exception->getTraceAsString(),
             ]);
             $this->messenger->addError(Message::mailNotSentTo($user->getEmail()));
             return new EmptyResponse(StatusCodeInterface::STATUS_CREATED);
         } catch (BadRequestException | ConflictException | NotFoundException $exception) {
             return new HtmlResponse(