feat: support custom listening hosts

Author: roxblnfk

src/Application.php

@@ -57,7 +57,7 @@ public function __construct(
         $feConfig = $this->container->get(FrontendConfig::class);
         $feSeparated = !\in_array(
             $feConfig->port,
-            \array_map(static fn(SocketServer $item): ?int => $item->type === 'tcp' ? $item->port : null, $map, ),
+            \array_map(static fn(SocketServer $item): ?int => $item->protocol === 'tcp' ? $item->port : null, $map),
             true,
         );
         $withFrontend and $this->configureFrontend($feSeparated);
@@ -104,7 +104,7 @@ public function __construct(
         $this->configureFileObserver();
 
         foreach ($map as $config) {
-            $withFrontend && !$feSeparated && $config->type === 'tcp' && $config->port === $feConfig->port
+            $withFrontend && !$feSeparated && $config->protocol === 'tcp' && $config->port === $feConfig->port
                 ? $this->prepareServerFiber($config, $inspectorWithFrontend, $this->logger)
                 : $this->prepareServerFiber($config, $inspector, $this->logger);
         }
@@ -225,7 +225,7 @@ private function configureFrontend(bool $separated): void
         $tcpConfig = $this->container->get(TcpPorts::class);
         $config = $this->container->get(FrontendConfig::class);
         $this->prepareServerFiber(
-            new SocketServer(port: $config->port, pollingInterval: $tcpConfig->pollingInterval),
+            new SocketServer(port: $config->port, host: $config->host, pollingInterval: $tcpConfig->pollingInterval),
             $inspector,
             $this->logger,
         );
@@ -255,6 +255,8 @@ private function createServer(SocketServer $config, Inspector $inspector): Serve
         };
 
         return Server::init(
+            $config->protocol,
+            $config->host,
             $config->port,
             payloadSize: 524_288,
             acceptPeriod: \max(50, $config->pollingInterval) / 1e6,

src/Command/Run.php

@@ -72,7 +72,7 @@ public function getServers(Container $container): array
             $port > 0 && $port < 65536 or throw new \InvalidArgumentException(
                 \sprintf('Invalid port `%s`. It must be in range 1-65535.', $port),
             );
-            $servers[] = new SocketServer($port, $config->host, $config->type, $config->pollingInterval);
+            $servers[] = new SocketServer($port, $config->host, $config->protocol, $config->pollingInterval);
         }
         return $servers;
     }

src/Config/Server/Frontend.php

@@ -18,4 +18,9 @@ final class Frontend
     #[InputOption('ui')]
     #[XPath('/trap/frontend/@port')]
     public int $port = 8000;
+
+    /** @var non-empty-string */
+    #[Env('TRAP_UI_HOST')]
+    #[XPath('/trap/frontend/@host')]
+    public string $host = '127.0.0.1';
 }

src/Config/Server/SocketServer.php

@@ -18,7 +18,7 @@ final class SocketServer
     public function __construct(
         public readonly int $port,
         public readonly string $host = '127.0.0.1',
-        public readonly string $type = 'tcp',
+        public readonly string $protocol = 'tcp',
         public int $pollingInterval = 1_000,
     ) {}
 }

src/Config/Server/TcpPorts.php

@@ -32,7 +32,7 @@ final class TcpPorts
     #[Env('TRAP_TCP_HOST')]
     public string $host = '127.0.0.1';
 
-    public string $type = 'tcp';
+    public string $protocol = 'tcp';
 
     /**
      * Time to wait between socket_accept() and socket_select() calls in microseconds.

src/Service/Container.php

@@ -37,7 +37,7 @@ public function __construct()
     }
 
     /**
-     * @template T of object
+     * @template T
      * @param class-string<T> $id
      * @param array $arguments Will be used if the object is created for the first time.
      * @return T

src/Socket/Server.php

@@ -30,41 +30,56 @@ final class Server implements Processable, Cancellable, Destroyable
     private float $lastAccept = 0;
 
     /**
-     * @param null|\Closure(Client, int $id): void $clientInflector
+     * @param non-empty-string $protocol
+     * @param non-empty-string $address
+     * @param int<1, 65535> $port
+     * @param null|\Closure(Client, int $id): mixed $clientInflector
      * @param positive-int $payloadSize Max payload size.
      * @param float $acceptPeriod Time to wait between socket_accept() calls in seconds.
      */
     private function __construct(
+        string $protocol,
+        string $address,
         int $port,
         private readonly int $payloadSize,
         private readonly float $acceptPeriod,
         private readonly ?\Closure $clientInflector,
         private readonly Logger $logger,
     ) {
-        $this->socket = @\socket_create_listen($port) ?: throw new \RuntimeException('Socket create failed.');
+        $this->socket = \socket_create(\AF_INET, \SOCK_STREAM, \getprotobyname($protocol))
+            ?: throw new \RuntimeException('Socket create failed.');
+        @\socket_set_nonblock($this->socket)
+            ?: throw new \RuntimeException('Socket set nonblock failed.');
+        @\socket_bind($this->socket, $address, $port)
+            ?: throw new \RuntimeException('Socket bind failed.');
 
         /** @link https://github.com/buggregator/trap/pull/14 */
         // \socket_set_option($this->socket, \SOL_SOCKET, \SO_LINGER, ['l_linger' => 0, 'l_onoff' => 1]);
 
-        \socket_set_nonblock($this->socket);
+        @\socket_listen($this->socket, \SOMAXCONN)
+            ?: throw new \RuntimeException('Socket listen failed.');
 
-        $logger->status('App', 'Server started on 127.0.0.1:%s', $port);
+        $logger->status('App', 'Server started on %s:%s', $address, $port);
     }
 
     /**
+     * @param non-empty-string $protocol
+     * @param non-empty-string $address
      * @param int<1, 65535> $port
      * @param positive-int $payloadSize Max payload size.
      * @param float $acceptPeriod Time to wait between socket_accept() calls in seconds.
-     * @param null|\Closure(Client, int $id): void $clientInflector
+     * @param null|\Closure(Client, int $id): mixed $clientInflector
      */
     public static function init(
-        int $port = 9912,
+        string $protocol,
+        string $address,
+        int $port,
         int $payloadSize = 10485760,
         float $acceptPeriod = .001,
         ?\Closure $clientInflector = null,
         Logger $logger = new Logger(),
     ): self {
-        return new self($port, $payloadSize, $acceptPeriod, $clientInflector, $logger);
+        return new self($protocol, $address, $port, $payloadSize, $acceptPeriod, $clientInflector, $logger);
     }
 
     public function destroy(): void