Don't record the close message when the server is not websocket server. (#2182)

* fix #2180

* fix typo && remove unnecessary qualifier

* Deleted useless code.

* Update CHANGELOG-2.0.md

Co-authored-by: 李铭昕 <[email protected]>

Author: yansongda

src/Security.php

@@ -28,7 +28,7 @@ public function isInvalidSecurityKey(string $key): bool
         return preg_match(self::PATTEN, $key) === 0 || strlen(base64_decode($key)) !== 16;
     }
 
-    public function handShakeHeaders(string $key): array
+    public function handshakeHeaders(string $key): array
     {
         return [
             'Upgrade' => 'websocket',

src/Server.php

@@ -45,6 +45,7 @@
 use Swoole\WebSocket\CloseFrame;
 use Swoole\WebSocket\Frame;
 use Swoole\WebSocket\Server as WebSocketServer;
+use Throwable;
 
 class Server implements MiddlewareInitializerInterface, OnHandShakeInterface, OnCloseInterface, OnMessageInterface
 {
@@ -141,7 +142,7 @@ public function onHandShake(SwooleRequest $request, SwooleResponse $response): v
             $security = $this->container->get(Security::class);
 
             $psr7Request = $this->initRequest($request);
-            $psr7Response = $this->initResponse($response);
+            $psr7Response = $this->initResponse();
 
             $this->logger->debug(sprintf('WebSocket: fd[%d] start a handshake request.', $fd));
 
@@ -151,9 +152,9 @@ public function onHandShake(SwooleRequest $request, SwooleResponse $response): v
             }
 
             $psr7Request = $this->coreMiddleware->dispatch($psr7Request);
+            $middlewares = $this->middlewares;
             /** @var Dispatched $dispatched */
             $dispatched = $psr7Request->getAttribute(Dispatched::class);
-            $middlewares = $this->middlewares;
             if ($dispatched->isFound()) {
                 $registedMiddlewares = MiddlewareManager::get($this->serverName, $dispatched->handler->route, $psr7Request->getMethod());
                 $middlewares = array_merge($middlewares, $registedMiddlewares);
@@ -196,7 +197,7 @@ public function onHandShake(SwooleRequest $request, SwooleResponse $response): v
                     $this->deferOnOpen($request, $class, $server);
                 }
             }
-        } catch (\Throwable $throwable) {
+        } catch (Throwable $throwable) {
             // Delegate the exception to exception handler.
             $psr7Response = $this->exceptionHandlerDispatcher->dispatch($throwable, $this->exceptionHandlers);
         } finally {
@@ -235,18 +236,20 @@ public function onMessage($server, Frame $frame): void
 
     public function onClose($server, int $fd, int $reactorId): void
     {
-        $this->logger->debug(sprintf('WebSocket: fd[%d] closed.', $fd));
-
         $fdObj = FdCollector::get($fd);
         if (! $fdObj) {
             return;
         }
+
+        $this->logger->debug(sprintf('WebSocket: fd[%d] closed.', $fd));
+
         Context::set(WsContext::FD, $fd);
         defer(function () use ($fd) {
             // Move those functions to defer, because onClose may throw exceptions
             FdCollector::del($fd);
             WsContext::release($fd);
         });
+
         $instance = $this->container->get($fdObj->class);
         if ($instance instanceof OnCloseInterface) {
             $instance->onClose($server, $fd, $reactorId);
@@ -279,7 +282,7 @@ protected function initRequest(SwooleRequest $request): ServerRequestInterface
     /**
      * Initialize PSR-7 Response.
      */
-    protected function initResponse(SwooleResponse $response): ResponseInterface
+    protected function initResponse(): ResponseInterface
     {
         Context::set(ResponseInterface::class, $psr7Response = new Psr7Response());
         return $psr7Response;