Removed requirement ext-swoole from socketio-server. (#5844)

Author: limingxinleo

src/Sender.php

@@ -13,6 +13,8 @@
 
 use Hyperf\Contract\ConfigInterface;
 use Hyperf\Contract\StdoutLoggerInterface;
+use Hyperf\Engine\Contract\WebSocket\FrameInterface;
+use Hyperf\Engine\WebSocket\Response as WsResponse;
 use Hyperf\Server\CoroutineServer;
 use Hyperf\WebSocketServer\Exception\InvalidMethodException;
 use Psr\Container\ContainerInterface;
@@ -21,6 +23,8 @@
 use Swoole\Server;
 use Swow\Psr7\Server\ServerConnection;
 
+use function Hyperf\Engine\swoole_get_flags_from_frame;
+
 /**
  * @method push(int $fd, $data, int $opcode = null, $finish = null)
  * @method disconnect(int $fd, int $code = null, string $reason = null)
@@ -56,6 +60,7 @@ public function __call($name, $arguments)
                 if ($method === 'disconnect') {
                     $method = 'close';
                 }
+
                 $this->responses[$fd]->{$method}(...$arguments);
                 $this->logger->debug("[WebSocket] Worker send to #{$fd}");
             }
@@ -67,6 +72,24 @@ public function __call($name, $arguments)
         }
     }
 
+    public function pushFrame(int $fd, FrameInterface $frame): bool
+    {
+        if ($this->isCoroutineServer) {
+            if (isset($this->responses[$fd])) {
+                return (new WsResponse($this->responses[$fd]))->init($fd)->push($frame);
+            }
+
+            return false;
+        }
+
+        if ($this->check($fd)) {
+            return (new WsResponse($this->getServer()))->init($fd)->push($frame);
+        }
+
+        $this->sendPipeMessage('push', [$fd, (string) $frame->getPayloadData(), $frame->getOpcode(), swoole_get_flags_from_frame($frame)]);
+        return false;
+    }
+
     public function proxy(int $fd, string $method, array $arguments): bool
     {
         $result = $this->check($fd);