format

src/Connection/AsyncUdpConnection.php

@@ -14,9 +14,22 @@
 
 namespace Workerman\Connection;
 
+use Exception;
 use Throwable;
+use Workerman\Protocols\ProtocolInterface;
 use Workerman\Worker;
-use Exception;
+use function class_exists;
+use function explode;
+use function fclose;
+use function stream_context_create;
+use function stream_set_blocking;
+use function stream_socket_client;
+use function stream_socket_recvfrom;
+use function stream_socket_sendto;
+use function strlen;
+use function substr;
+use function ucfirst;
+use const STREAM_CLIENT_CONNECT;
 
 /**
  * AsyncUdpConnection.
@@ -60,20 +73,20 @@ class AsyncUdpConnection extends UdpConnection
     public function __construct($remoteAddress, $contextOption = [])
     {
         // Get the application layer communication protocol and listening address.
-        list($scheme, $address) = \explode(':', $remoteAddress, 2);
+        list($scheme, $address) = explode(':', $remoteAddress, 2);
         // Check application layer protocol class.
         if ($scheme !== 'udp') {
-            $scheme = \ucfirst($scheme);
+            $scheme = ucfirst($scheme);
             $this->protocol = '\\Protocols\\' . $scheme;
-            if (!\class_exists($this->protocol)) {
+            if (!class_exists($this->protocol)) {
                 $this->protocol = "\\Workerman\\Protocols\\$scheme";
-                if (!\class_exists($this->protocol)) {
+                if (!class_exists($this->protocol)) {
                     throw new Exception("class \\Protocols\\$scheme not exist");
                 }
             }
         }
 
-        $this->remoteAddress = \substr($address, 2);
+        $this->remoteAddress = substr($address, 2);
         $this->contextOption = $contextOption;
     }
 
@@ -86,14 +99,16 @@ class AsyncUdpConnection extends UdpConnection
      */
     public function baseRead($socket)
     {
-        $recvBuffer = \stream_socket_recvfrom($socket, Worker::MAX_UDP_PACKAGE_SIZE, 0, $remoteAddress);
+        $recvBuffer = stream_socket_recvfrom($socket, Worker::MAX_UDP_PACKAGE_SIZE, 0, $remoteAddress);
         if (false === $recvBuffer || empty($remoteAddress)) {
             return;
         }
 
         if ($this->onMessage) {
             if ($this->protocol) {
-                $recvBuffer = $this->protocol::decode($recvBuffer, $this);
+                /** @var ProtocolInterface $parser */
+                $parser = $this->protocol;
+                $recvBuffer = $parser::decode($recvBuffer, $this);
             }
             ++ConnectionInterface::$statistics['total_request'];
             try {
@@ -105,29 +120,6 @@ class AsyncUdpConnection extends UdpConnection
     }
 
     /**
-     * Sends data on the connection.
-     *
-     * @param mixed $sendBuffer
-     * @param bool $raw
-     * @return void|boolean
-     * @throws Throwable
-     */
-    public function send(mixed $sendBuffer, bool $raw = false)
-    {
-        if (false === $raw && $this->protocol) {
-            $parser = $this->protocol;
-            $sendBuffer = $parser::encode($sendBuffer, $this);
-            if ($sendBuffer === '') {
-                return;
-            }
-        }
-        if ($this->connected === false) {
-            $this->connect();
-        }
-        return \strlen($sendBuffer) === \stream_socket_sendto($this->socket, $sendBuffer, 0);
-    }
-
-    /**
      * Close connection.
      *
      * @param mixed|null $data
@@ -141,7 +133,7 @@ class AsyncUdpConnection extends UdpConnection
             $this->send($data, $raw);
         }
         $this->eventLoop->offReadable($this->socket);
-        \fclose($this->socket);
+        fclose($this->socket);
         $this->connected = false;
         // Try to emit onClose callback.
         if ($this->onClose) {
@@ -155,6 +147,30 @@ class AsyncUdpConnection extends UdpConnection
     }
 
     /**
+     * Sends data on the connection.
+     *
+     * @param mixed $sendBuffer
+     * @param bool $raw
+     * @return void|boolean
+     * @throws Throwable
+     */
+    public function send(mixed $sendBuffer, bool $raw = false)
+    {
+        if (false === $raw && $this->protocol) {
+            /** @var ProtocolInterface $parser */
+            $parser = $this->protocol;
+            $sendBuffer = $parser::encode($sendBuffer, $this);
+            if ($sendBuffer === '') {
+                return;
+            }
+        }
+        if ($this->connected === false) {
+            $this->connect();
+        }
+        return strlen($sendBuffer) === stream_socket_sendto($this->socket, $sendBuffer, 0);
+    }
+
+    /**
      * Connect.
      *
      * @return void
@@ -169,19 +185,19 @@ class AsyncUdpConnection extends UdpConnection
             $this->eventLoop = Worker::$globalEvent;
         }
         if ($this->contextOption) {
-            $context = \stream_context_create($this->contextOption);
-            $this->socket = \stream_socket_client("udp://{$this->remoteAddress}", $errno, $errmsg,
-                30, \STREAM_CLIENT_CONNECT, $context);
+            $context = stream_context_create($this->contextOption);
+            $this->socket = stream_socket_client("udp://$this->remoteAddress", $errno, $errmsg,
+                30, STREAM_CLIENT_CONNECT, $context);
         } else {
-            $this->socket = \stream_socket_client("udp://{$this->remoteAddress}", $errno, $errmsg);
+            $this->socket = stream_socket_client("udp://$this->remoteAddress", $errno, $errmsg);
         }
 
         if (!$this->socket) {
-            Worker::safeEcho(new \Exception($errmsg));
+            Worker::safeEcho(new Exception($errmsg));
             return;
         }
 
-        \stream_set_blocking($this->socket, false);
+        stream_set_blocking($this->socket, false);
 
         if ($this->onMessage) {
             $this->eventLoop->onWritable($this->socket, [$this, 'baseRead']);

src/Connection/ConnectionInterface.php

@@ -14,12 +14,9 @@
 
 namespace Workerman\Connection;
 
-use Closure;
-use JetBrains\PhpStorm\Pure;
 use Throwable;
 use Workerman\Events\Event;
 use Workerman\Events\EventInterface;
-use Workerman\Events\Revolt;
 use Workerman\Worker;
 
 /**
@@ -58,7 +55,7 @@ abstract class ConnectionInterface
      * Application layer protocol.
      * The format is like this Workerman\\Protocols\\Http.
      *
-     * @var ?class-string
+     * @var ?string
      */
     public ?string $protocol = null;
 

src/Connection/TcpConnection.php

@@ -18,6 +18,7 @@ use stdClass;
 use Throwable;
 use Workerman\Events\EventInterface;
 use Workerman\Protocols\Http\Request;
+use Workerman\Protocols\ProtocolInterface;
 use Workerman\Worker;
 
 /**
@@ -355,7 +356,9 @@ class TcpConnection extends ConnectionInterface implements \JsonSerializable
 
         // Try to call protocol::encode($sendBuffer) before sending.
         if (false === $raw && $this->protocol !== null) {
-            $sendBuffer = $this->protocol::encode($sendBuffer, $this);
+            /** @var ProtocolInterface $parser */
+            $parser = $this->protocol;
+            $sendBuffer = $parser::encode($sendBuffer, $this);
             if ($sendBuffer === '') {
                 return;
             }
@@ -628,7 +631,9 @@ class TcpConnection extends ConnectionInterface implements \JsonSerializable
                 } else {
                     // Get current package length.
                     try {
-                        $this->currentPackageLength = $this->protocol::input($this->recvBuffer, $this);
+                        /** @var ProtocolInterface $parser */
+                        $parser = $this->protocol;
+                        $this->currentPackageLength = $parser::input($this->recvBuffer, $this);
                     } catch (Throwable $e) {
                     }
                     // The packet length is unknown.
@@ -663,7 +668,9 @@ class TcpConnection extends ConnectionInterface implements \JsonSerializable
                 $this->currentPackageLength = 0;
                 try {
                     // Decode request buffer before Emitting onMessage callback.
-                    $request = $this->protocol::decode($oneRequestBuffer, $this);
+                    /** @var ProtocolInterface $parser */
+                    $parser = $this->protocol;
+                    $request = $parser::decode($oneRequestBuffer, $this);
                     if (static::$enableCache && (!\is_object($request) || $request instanceof Request) && $one && !isset($oneRequestBuffer[512])) {
                         $requests[$oneRequestBuffer] = $request;
                         if (\count($requests) > 512) {

src/Connection/UdpConnection.php

@@ -14,6 +14,8 @@
 
 namespace Workerman\Connection;
 
+use Workerman\Protocols\ProtocolInterface;
+
 /**
  * UdpConnection.
  */
@@ -62,6 +64,7 @@ class UdpConnection extends ConnectionInterface implements \JsonSerializable
     public function send(mixed $sendBuffer, bool $raw = false)
     {
         if (false === $raw && $this->protocol) {
+            /** @var ProtocolInterface $parser */
             $parser = $this->protocol;
             $sendBuffer = $parser::encode($sendBuffer, $this);
             if ($sendBuffer === '') {