diff --git a/HttpServer/Events/OnHandshake.php b/HttpServer/Events/OnHandshake.php index d9cd976c..05611483 100644 --- a/HttpServer/Events/OnHandshake.php +++ b/HttpServer/Events/OnHandshake.php @@ -9,6 +9,7 @@ use Exception; use HttpServer\Abstracts\Callback; use HttpServer\Http\HttpParams; use HttpServer\Http\Request; +use HttpServer\Http\Response; use Snowflake\Event; use Snowflake\Snowflake; use Swoole\Http\Request as SRequest; @@ -133,7 +134,7 @@ class OnHandshake extends Callback if (($node = $router->find_path($sRequest)) === null) { return $this->disconnect($response, 502); } - return $node->dispatch($request, $response); + return $node->dispatch($sRequest, Response::create($response)); } diff --git a/HttpServer/Http/Response.php b/HttpServer/Http/Response.php index 1196c18c..e9cb2711 100644 --- a/HttpServer/Http/Response.php +++ b/HttpServer/Http/Response.php @@ -283,6 +283,18 @@ class Response extends HttpService } + /** + * @param int $statusCode + * @param string $message + * @return mixed + * @throws Exception + */ + public function close($statusCode = 200, $message = ''): mixed + { + return $this->send($message, $statusCode); + } + + /** * @param string $path * @param int $offset @@ -296,7 +308,6 @@ class Response extends HttpService $stat = fstat($open); - $this->headers(null); while ($file = fread($open, $limit)) { $this->response->write($file); fseek($open, $offset);