chore: add httpserver

Author: ChiragAgg5k

src/Http/Adapter/Swoole/HttpServer.php

@@ -0,0 +1,88 @@
+<?php
+
+namespace Utopia\Http\Adapter\Swoole;
+
+use Swoole\Coroutine;
+use Utopia\Http\Adapter;
+use Utopia\DI\Container;
+use Swoole\Http\Server as SwooleServer;
+use Swoole\Http\Request as SwooleRequest;
+use Swoole\Http\Response as SwooleResponse;
+
+class HttpServer extends Adapter
+{
+    protected SwooleServer $server;
+    protected const REQUEST_CONTAINER_CONTEXT_KEY = '__utopia_http_request_container';
+    protected Container $container;
+    protected ?Container $requestContainer = null;
+    protected bool $coroutines;
+
+    public function __construct(string $host, ?string $port = null, array $settings = [], ?Container $container = null, bool $coroutines = false)
+    {
+        $this->coroutines = $coroutines;
+        $this->server = new SwooleServer($host, (int) $port);
+        $this->server->set(\array_merge($settings, [
+            'open_http2_protocol' => true,
+            'dispatch_mode' => 2,
+            'enable_coroutine' => $coroutines,
+        ]));
+        $this->container = $container ?? new Container();
+    }
+
+    public function onRequest(callable $callback)
+    {
+        $this->server->on('request', function (SwooleRequest $request, SwooleResponse $response) use ($callback) {
+            $handler = function () use ($request, $response, $callback) {
+                $requestContainer = new Container($this->container);
+                $requestContainer->set('swooleRequest', fn () => $request);
+                $requestContainer->set('swooleResponse', fn () => $response);
+
+                if ($this->coroutines && Coroutine::getCid() !== -1) {
+                    Coroutine::getContext()[self::REQUEST_CONTAINER_CONTEXT_KEY] = $requestContainer;
+                } else {
+                    $this->requestContainer = $requestContainer;
+                }
+
+                \call_user_func($callback, new Request($request), new Response($response));
+            };
+
+            if ($this->coroutines) {
+                go($handler);
+            } else {
+                $handler();
+            }
+        });
+    }
+
+    public function getContainer(): Container
+    {
+        if ($this->coroutines && Coroutine::getCid() !== -1) {
+            return Coroutine::getContext()[self::REQUEST_CONTAINER_CONTEXT_KEY] ?? $this->container;
+        }
+
+        return $this->requestContainer ?? $this->container;
+    }
+
+    public function getServer(): SwooleServer
+    {
+        return $this->server;
+    }
+
+    public function onStart(callable $callback)
+    {
+        $this->server->on('start', function () use ($callback) {
+            if ($this->coroutines) {
+                go(function () use ($callback) {
+                    \call_user_func($callback, $this);
+                });
+            } else {
+                \call_user_func($callback, $this);
+            }
+        });
+    }
+
+    public function start()
+    {
+        return $this->server->start();
+    }
+}

src/Http/Adapter/Swoole/Server.php

@@ -16,15 +16,14 @@ class Server extends Adapter
     protected SwooleServer $server;
     protected const REQUEST_CONTAINER_CONTEXT_KEY = '__utopia_http_request_container';
     protected Container $container;
-    protected ?Container $requestContainer = null;
 
     public function __construct(string $host, ?string $port = null, array $settings = [], ?Container $container = null)
     {
         $this->server = new SwooleServer($host, $port);
-        $this->server->set(\array_merge([
+        $this->server->set(\array_merge($settings, [
             'enable_coroutine' => true,
             'http_parse_cookie' => false,
-        ], $settings));
+        ]));
         $this->container = $container ?? new Container();
     }
 
@@ -35,11 +34,7 @@ public function onRequest(callable $callback)
             $requestContainer->set('swooleRequest', fn () => $request);
             $requestContainer->set('swooleResponse', fn () => $response);
 
-            if (Coroutine::getCid() !== -1) {
-                Coroutine::getContext()[self::REQUEST_CONTAINER_CONTEXT_KEY] = $requestContainer;
-            } else {
-                $this->requestContainer = $requestContainer;
-            }
+            Coroutine::getContext()[self::REQUEST_CONTAINER_CONTEXT_KEY] = $requestContainer;
 
             $utopiaRequest = new Request($request);
             $utopiaResponse = new Response($response);
@@ -50,11 +45,12 @@ public function onRequest(callable $callback)
 
     public function getContainer(): Container
     {
-        if (Coroutine::getCid() !== -1) {
-            return Coroutine::getContext()[self::REQUEST_CONTAINER_CONTEXT_KEY] ?? $this->container;
-        }
+        return Coroutine::getContext()[self::REQUEST_CONTAINER_CONTEXT_KEY] ?? $this->container;
+    }
 
-        return $this->requestContainer ?? $this->container;
+    public function getServer(): SwooleServer
+    {
+        return $this->server;
     }
 
     public function onStart(callable $callback)