onStart parameter in HttpServer plugin

src/Plugin/HttpServer/HttpServer.php

@@ -6,19 +6,21 @@
 
 use Amp\Future;
 use Amp\Http\Server\Driver\HttpDriver;
-use Amp\Http\Server\HttpErrorException;
-use Amp\Http\Server\Request;
-use Amp\Http\Server\RequestHandler\ClosureRequestHandler;
-use Amp\Http\Server\Response;
+use Amp\Http\Server\RequestHandler;
 use Luzrain\PHPStreamServer\Internal\MasterProcess;
 use Luzrain\PHPStreamServer\Plugin\PluginInterface;
 use Luzrain\PHPStreamServer\WorkerProcess;
 use function Amp\async;
 
 final readonly class HttpServer implements PluginInterface
 {
+    /**
+     * @param Listen|string|array<Listen> $listen
+     * @param \Closure(WorkerProcess): RequestHandler $onStart
+     */
     public function __construct(
-        private Listen|array $listen,
+        private Listen|string|array $listen,
+        private \Closure $onStart,
         private string $name = 'HTTP Server',
         private int $count = 1,
         private bool $reloadable = true,
@@ -44,16 +46,18 @@ public function start(MasterProcess $masterProcess): void
             user: $this->user,
             group: $this->group,
             onStart: function (WorkerProcess $worker) {
-                $requestHandler = new ClosureRequestHandler(function (Request $request) : Response {
-                    return match ($request->getUri()->getPath()) {
-                        '/' => new Response(body: 'Hello world1'),
-                        '/ping' => new Response(body: 'pong2'),
-                        default => throw new HttpErrorException(404),
-                    };
-                });
+                $requestHandler = ($this->onStart)($worker);
+
+                if (!$requestHandler instanceof RequestHandler) {
+                    throw new \RuntimeException(sprintf(
+                        'onStart() closure: Return value must be of type %s, %s returned',
+                        RequestHandler::class,
+                        \get_debug_type($requestHandler)),
+                    );
+                }
 
                 $worker->startWorkerModule(new HttpServerModule(
-                    listen: $this->listen,
+                    listen: self::createListenList($this->listen),
                     requestHandler: $requestHandler,
                     middleware: $this->middleware,
                     connectionLimit: $this->connectionLimit,
@@ -72,4 +76,24 @@ public function stop(): Future
     {
         return async(static fn() => null);
     }
+
+    /**
+     * @return list<Listen>
+     */
+    public static function createListenList(self|string|array $listen): array
+    {
+        $listen = \is_array($listen) ? $listen : [$listen];
+        $ret = [];
+        foreach ($listen as $listenItem) {
+            if ($listenItem instanceof Listen) {
+                $ret[] = $listenItem;
+            } elseif (\is_string($listenItem)) {
+                $ret[] = new Listen($listenItem);
+            } else {
+                throw new \InvalidArgumentException('Invalid listen');
+            }
+        }
+
+        return $ret;
+    }
 }

src/Plugin/HttpServer/Listen.php

@@ -19,6 +19,10 @@ public function __construct(
         $this->host = $p['host'] ?? $p;
         $this->port = $p['port'] ?? ($tls ? 443 : 80);
 
+        if (\str_contains($listen, '://')) {
+            throw new \InvalidArgumentException('Listen should not contain schema');
+        }
+
         if ($this->port < 0 || $this->port > 65535) {
             throw new \InvalidArgumentException('Port number must be an integer between 0 and 65535; got ' . $this->port);
         }