Rename classes and namespaces

src/Application.php

@@ -39,7 +39,7 @@ public function __construct(
         array $map = [],
         private readonly Logger $logger = new Logger(),
         private array $senders = [],
-        bool $configureUI = true,
+        bool $withFrontend = true,
     ) {
         $this->buffer = new Buffer(bufferSize: 10485760, timer: 0.1);
 
@@ -62,7 +62,7 @@ public function __construct(
         );
         $this->processors[] = $inspector;
 
-        $configureUI and $this->configureUI(8000);
+        $withFrontend and $this->configureFrontend(8000);
 
         foreach ($map as $config) {
             $this->prepareServerFiber($config, $inspector, $this->logger);
@@ -165,20 +165,20 @@ public function prepareServerFiber(SocketServer $config, Inspector $inspector, L
         });
     }
 
-    public function configureUI(int $port): void
+    public function configureFrontend(int $port): void
     {
-        $this->senders[] = $wsSender = Sender\WebsocketSender::create($this->logger);
+        $this->senders[] = $wsSender = Sender\FrontendSender::create($this->logger);
 
         $inspector = new Inspector(
             $this->buffer,
             $this->logger,
             new Traffic\Dispatcher\Http(
                 [
-                    new Sender\Websocket\Http\StaticFiles(),
-                    new Sender\Websocket\Http\Events($wsSender->getEventStorage()),
-                    new Sender\Websocket\Http\Version(),
+                    new Sender\Frontend\Http\StaticFiles(),
+                    new Sender\Frontend\Http\Events($wsSender->getEventStorage()),
+                    new Sender\Frontend\Http\Version(),
                 ],
-                [new Sender\Websocket\Http\RequestHandler($wsSender->getConnectionPool())],
+                [new Sender\Frontend\Http\RequestHandler($wsSender->getConnectionPool())],
                 silentMode: true,
             ),
         );

src/Sender/Websocket/ConnectionPool.php → src/Sender/Frontend/ConnectionPool.php

@@ -2,12 +2,12 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket;
+namespace Buggregator\Trap\Sender\Frontend;
 
 use Buggregator\Trap\Logger;
 use Buggregator\Trap\Processable;
-use Buggregator\Trap\Sender\Websocket\RPC\Connect;
-use Buggregator\Trap\Sender\Websocket\RPC\Response;
+use Buggregator\Trap\Sender\Frontend\Message\Connect;
+use Buggregator\Trap\Sender\Frontend\Message\Response;
 use Buggregator\Trap\Support\Json;
 use Buggregator\Trap\Support\Timer;
 use Buggregator\Trap\Support\Uuid;

src/Sender/Websocket/Event.php → src/Sender/Frontend/Event.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket;
+namespace Buggregator\Trap\Sender\Frontend;
 
 final class Event
 {

src/Sender/Websocket/EventsStorage.php → src/Sender/Frontend/EventsStorage.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket;
+namespace Buggregator\Trap\Sender\Frontend;
 
 use Buggregator\Trap\Proto\Frame;
 use IteratorAggregate;

src/Sender/Websocket/FrameHandler.php → src/Sender/Frontend/FrameHandler.php

@@ -2,11 +2,11 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket;
+namespace Buggregator\Trap\Sender\Frontend;
 
 use Buggregator\Trap\Proto\Frame;
 use Buggregator\Trap\Sender\FrameHandler as HandlerInterface;
-use Buggregator\Trap\Sender\Websocket\RPC\Push;
+use Buggregator\Trap\Sender\Frontend\Message\Push;
 use Buggregator\Trap\Support\Json;
 
 /**

src/Sender/Websocket/FrameMapper.php → src/Sender/Frontend/FrameMapper.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket;
+namespace Buggregator\Trap\Sender\Frontend;
 
 use Buggregator\Trap\Proto\Frame;
 use IteratorAggregate;

src/Sender/Websocket/Http/Events.php → src/Sender/Frontend/Http/Events.php

@@ -2,10 +2,10 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\Http;
+namespace Buggregator\Trap\Sender\Frontend\Http;
 
 use Buggregator\Trap\Handler\Http\Middleware;
-use Buggregator\Trap\Sender\Websocket\EventsStorage;
+use Buggregator\Trap\Sender\Frontend\EventsStorage;
 use Buggregator\Trap\Support\Json;
 use Nyholm\Psr7\Response;
 use Psr\Http\Message\ResponseInterface;

src/Sender/Websocket/Http/RequestHandler.php → src/Sender/Frontend/Http/RequestHandler.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\Http;
+namespace Buggregator\Trap\Sender\Frontend\Http;
 
 use Buggregator\Trap\Handler\Http\Emitter as HttpEmitter;
 use Buggregator\Trap\Handler\Http\RequestHandler as RequestHandlernterace;
@@ -22,7 +22,7 @@
 final class RequestHandler implements RequestHandlernterace
 {
     public function __construct(
-        private readonly Sender\Websocket\ConnectionPool $connectionPool,
+        private readonly Sender\Frontend\ConnectionPool $connectionPool,
     ) {
     }
 

src/Sender/Websocket/Http/StaticFiles.php → src/Sender/Frontend/Http/StaticFiles.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\Http;
+namespace Buggregator\Trap\Sender\Frontend\Http;
 
 use Buggregator\Trap\Handler\Http\Middleware;
 use Buggregator\Trap\Info;

src/Sender/Websocket/Http/Version.php → src/Sender/Frontend/Http/Version.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\Http;
+namespace Buggregator\Trap\Sender\Frontend\Http;
 
 use Buggregator\Trap\Handler\Http\Middleware;
 use Buggregator\Trap\Info;

src/Sender/Websocket/Mapper/VarDump.php → src/Sender/Frontend/Mapper/VarDump.php

@@ -2,10 +2,10 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\Mapper;
+namespace Buggregator\Trap\Sender\Frontend\Mapper;
 
 use Buggregator\Trap\Proto\Frame\VarDumper;
-use Buggregator\Trap\Sender\Websocket\Event;
+use Buggregator\Trap\Sender\Frontend\Event;
 use Buggregator\Trap\Support\Uuid;
 use Symfony\Component\VarDumper\Cloner\Data;
 use Symfony\Component\VarDumper\Cloner\Stub;

src/Sender/Websocket/RPC/Connect.php → src/Sender/Frontend/Message/Connect.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\RPC;
+namespace Buggregator\Trap\Sender\Frontend\Message;
 
 use Buggregator\Trap\Info;
 use JsonSerializable;

src/Sender/Websocket/RPC/Push.php → src/Sender/Frontend/Message/Push.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\RPC;
+namespace Buggregator\Trap\Sender\Frontend\Message;
 
 use JsonSerializable;
 

src/Sender/Websocket/RPC/Response.php → src/Sender/Frontend/Message/Response.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\RPC;
+namespace Buggregator\Trap\Sender\Frontend\Message;
 
 use JsonSerializable;
 

src/Sender/Websocket/RPC/Rpc.php → src/Sender/Frontend/Message/Rpc.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\RPC;
+namespace Buggregator\Trap\Sender\Frontend\Message;
 
 use JsonSerializable;
 

src/Sender/Websocket/RPC/Success.php → src/Sender/Frontend/Message/Success.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket\RPC;
+namespace Buggregator\Trap\Sender\Frontend\Message;
 
 use JsonSerializable;
 

src/Sender/Websocket/RPC.php → src/Sender/Frontend/RPC.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket;
+namespace Buggregator\Trap\Sender\Frontend;
 
 use Buggregator\Trap\Handler\Router\Method;
 use Buggregator\Trap\Handler\Router\Router;
@@ -27,7 +27,7 @@ public function __construct(
      *     method?: non-empty-string,
      * } $message
      */
-    public function handleMessage(mixed $message): ?RPC\Rpc
+    public function handleMessage(mixed $message): ?Message\Rpc
     {
         try {
             if (!\is_array($message)) {
@@ -45,7 +45,7 @@ public function handleMessage(mixed $message): ?RPC\Rpc
         return null;
     }
 
-    private function callMethod(string $initMethod): ?RPC\Rpc
+    private function callMethod(string $initMethod): ?Message\Rpc
     {
         [$method, $path] = \explode(':', $initMethod, 2);
 
@@ -57,6 +57,6 @@ private function callMethod(string $initMethod): ?RPC\Rpc
         }
 
         $result = $route();
-        return $result === null ? null : new RPC\Rpc(data: $result);
+        return $result === null ? null : new Message\Rpc(data: $result);
     }
 }

src/Sender/Websocket/Service.php → src/Sender/Frontend/Service.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Buggregator\Trap\Sender\Websocket;
+namespace Buggregator\Trap\Sender\Frontend;
 
 use Buggregator\Trap\Handler\Router\Attribute\RegexpRoute;
 use Buggregator\Trap\Handler\Router\Attribute\StaticRoute;
@@ -23,14 +23,21 @@ public function __construct(
     #[RegexpRoute(Method::Delete, '#^/api/events/(?<uuid>[a-f0-9-]++)#i')]
     public function eventDelete(string $uuid): bool
     {
+        $this->debug('Delete event %s', $uuid);
         $this->eventsStorage->delete($uuid);
         return true;
     }
 
     #[StaticRoute(Method::Delete, 'api/events')]
     public function eventsDelete(): bool
     {
+        $this->debug('Delete all events');
         $this->eventsStorage->clear();
         return true;
     }
+
+    private function debug(string $pattern, string ...$args): void
+    {
+        $this->logger->debug("[UI Service] $pattern", ...$args);
+    }
 }

src/Sender/WebsocketSender.php → src/Sender/FrontendSender.php

@@ -7,30 +7,30 @@
 use Buggregator\Trap\Logger;
 use Buggregator\Trap\Processable;
 use Buggregator\Trap\Proto\Frame;
-use Buggregator\Trap\Sender\Websocket\ConnectionPool;
+use Buggregator\Trap\Sender\Frontend\ConnectionPool;
 
 /**
  * @internal
  */
-final class WebsocketSender implements \Buggregator\Trap\Sender, Processable
+final class FrontendSender implements \Buggregator\Trap\Sender, Processable
 {
     public static function create(
         Logger $logger,
-        ?Websocket\ConnectionPool $connectionPool = null,
-        ?Websocket\EventsStorage $eventStorage = null,
+        ?Frontend\ConnectionPool $connectionPool = null,
+        ?Frontend\EventsStorage $eventStorage = null,
     ): self {
-        $eventStorage ??= new Websocket\EventsStorage();
-        $connectionPool ??= new Websocket\ConnectionPool($logger, new Websocket\RPC($logger, $eventStorage));
+        $eventStorage ??= new Frontend\EventsStorage();
+        $connectionPool ??= new Frontend\ConnectionPool($logger, new Frontend\RPC($logger, $eventStorage));
         return new self(
             $connectionPool,
             $eventStorage,
-            new Websocket\FrameHandler($connectionPool, $eventStorage),
+            new Frontend\FrameHandler($connectionPool, $eventStorage),
         );
     }
 
     private function __construct(
         private readonly ConnectionPool $connectionPool,
-        private readonly Websocket\EventsStorage $framesStorage,
+        private readonly Frontend\EventsStorage $framesStorage,
         private readonly FrameHandler $handler,
     ) {
     }
@@ -52,9 +52,9 @@ public function getConnectionPool(): ConnectionPool
     }
 
     /**
-     * @return Websocket\EventsStorage
+     * @return Frontend\EventsStorage
      */
-    public function getEventStorage(): Websocket\EventsStorage
+    public function getEventStorage(): Frontend\EventsStorage
     {
         return $this->framesStorage;
     }