send procedural TPC message to ping

Signed-off-by: sergiu <sergiubota@rospace.com>

Author: SergiuBota1

composer.json

@@ -28,8 +28,6 @@
     },
     "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",
@@ -81,8 +79,7 @@
             "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\\NotificationSystem\\": "src/Core/src/NotificationSystem/src"
+            "Core\\User\\": "src/Core/src/User/src"
         }
     },
     "autoload-dev": {

config/config.php

@@ -74,7 +74,6 @@ 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

@@ -12,7 +12,6 @@
 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;
@@ -27,6 +26,11 @@
 use Psr\Http\Server\RequestHandlerInterface;
 use Throwable;
 
+use function fclose;
+use function fwrite;
+use function json_encode;
+use function stream_socket_client;
+
 /**
  * @phpstan-import-type CreateUserDataType from CreateUserInputFilter
  */
@@ -42,7 +46,6 @@ class PostUserCreateHandler implements RequestHandlerInterface
         FlashMessengerInterface::class,
         CreateUserForm::class,
         MailService::class,
-        NotificationService::class,
         'dot-log.default_logger',
         'config',
     )]
@@ -53,7 +56,6 @@ public function __construct(
         protected FlashMessengerInterface $messenger,
         protected CreateUserForm $createUserForm,
         protected MailService $mailService,
-        protected NotificationService $notificationService,
         protected Logger $logger,
         protected array $config,
     ) {
@@ -74,7 +76,16 @@ public function handle(ServerRequestInterface $request): ResponseInterface
                 $user = $this->userService->saveUser($data);
                 $this->messenger->addSuccess(Message::USER_CREATED);
                 if ($user->hasEmail()) {
-                    $this->notificationService->sendNewAccountNotification($user);
+                    $client = stream_socket_client("tcp://localhost:8556", $errno, $errstr, 30);
+
+                    if (! $client) {
+                        echo "Error: $errstr ($errno)\n";
+                    } else {
+                        $data['userUuid'] = $user->getUuid()->toString();
+                        fwrite($client, json_encode($data) . "\n");
+
+                        fclose($client);
+                    }
                 }
 
                 return new EmptyResponse(StatusCodeInterface::STATUS_CREATED);