diff --git a/HttpServer/Events/OnPacket.php b/HttpServer/Events/OnPacket.php index 3fee2f95..b4aa3d79 100644 --- a/HttpServer/Events/OnPacket.php +++ b/HttpServer/Events/OnPacket.php @@ -36,7 +36,7 @@ class OnPacket extends Callback public function onHandler(Server $server, string $data, array $clientInfo): mixed { try { - $request = Request::createListenRequest($clientInfo, $this->port, $server, $data); + $request = Request::createListenRequest($clientInfo, $server, $data); [$host, $port] = [$clientInfo['address'], $clientInfo['port']]; diff --git a/HttpServer/Events/OnReceive.php b/HttpServer/Events/OnReceive.php index 7ace506b..8dcf0bbf 100644 --- a/HttpServer/Events/OnReceive.php +++ b/HttpServer/Events/OnReceive.php @@ -36,7 +36,7 @@ class OnReceive extends Callback public function onHandler(Server $server, int $fd, int $reID, string $data): mixed { try { - $request = Request::createListenRequest($fd, $this->port, $server, $data, $reID); + $request = Request::createListenRequest($fd, $server, $data, $reID); $router = Snowflake::app()->getRouter(); if (($node = $router->find_path($request)) === null) { diff --git a/HttpServer/Http/Request.php b/HttpServer/Http/Request.php index 780d6dbd..6b70e29c 100644 --- a/HttpServer/Http/Request.php +++ b/HttpServer/Http/Request.php @@ -505,7 +505,6 @@ class Request extends HttpService /** * @param $fd - * @param $port * @param Server $server * @param $data * @param int $reID @@ -514,7 +513,7 @@ class Request extends HttpService * @throws ReflectionException * @throws Exception */ - public static function createListenRequest($fd, $port, Server $server, $data, $reID = 0): Request + public static function createListenRequest($fd, Server $server, $data, $reID = 0): Request { /** @var Request $sRequest */ $sRequest = Snowflake::createObject(Request::class); @@ -523,6 +522,8 @@ class Request extends HttpService $sRequest->clientInfo = self::getClientInfo($fd, $reID); $sRequest->startTime = microtime(true); + $port = $sRequest->clientInfo['server_port']; + $sRequest->params = new HttpParams(['body' => $data], [], []); $sRequest->headers = new HttpHeaders([]);