fix: swoft-cloud/swoft/issues/1222 compatible ws setting open_websock…

…et_close_frame

src/websocket-server/src/Swoole/MessageListener.php

@@ -31,6 +31,7 @@
 use Swoole\Websocket\Server;
 use Throwable;
 use function server;
+use const WEBSOCKET_OPCODE_CLOSE;
 
 /**
  * Class MessageListener
@@ -55,14 +56,22 @@ class MessageListener implements MessageInterface
     public function onMessage(Server $server, Frame $frame): void
     {
         $fd  = $frame->fd;
-        $sid = (string)$fd;
+
+        // Fix: if setting: 'open_websocket_close_frame' => true
+        if ($frame->opcode === WEBSOCKET_OPCODE_CLOSE) {
+            CLog::info('Close ws#%d connection by close opcode message, reason: %s', $fd, $frame->reason);
+            // Swoft::getBean(CloseListener::class)->onClose($server, $fd, 0);
+            // NOTICE: swoole will auto call close event.
+            return;
+        }
 
         server()->log("Message: conn#{$fd} received message data", [], 'debug');
 
         $request  = Request::new($frame);
         $response = Response::new($fd);
 
         /** @var WsMessageContext $ctx */
+        $sid = (string)$fd;
         $ctx = WsMessageContext::new($request, $response);
 
         // Storage context