foramt codes

Author: inhere

src/rpc-client/src/Annotation/Parser/ReferenceParser.php

@@ -43,9 +43,8 @@ public function parse(int $type, $annotationObject): array
         $propClassType   = $phpReader->getPropertyClass($reflectProperty);
 
         if (empty($propClassType)) {
-            throw new RpcClientException(
-                sprintf('`@Reference`(%s->%s) must to define `@var xxx`', $this->className, $this->propertyName)
-            );
+            throw new RpcClientException(sprintf('`@Reference`(%s->%s) must to define `@var xxx`', $this->className,
+                    $this->propertyName));
         }
 
         $className = Proxy::newClassName($propClassType);
@@ -57,4 +56,4 @@ public function parse(int $type, $annotationObject): array
         ReferenceRegister::register($className, $annotationObject->getPool(), $annotationObject->getVersion());
         return [$className, true];
     }
-}
+}

src/rpc-client/src/Client.php

@@ -97,9 +97,7 @@ public function getSetting(): array
     public function getPacket(): PacketInterface
     {
         if (empty($this->packet)) {
-            throw new RpcClientException(
-                sprintf('Client(%s) packet can not be null', __CLASS__)
-            );
+            throw new RpcClientException(sprintf('Client(%s) packet can not be null', __CLASS__));
         }
 
         return $this->packet;

src/rpc-client/src/Concern/ServiceTrait.php

@@ -49,10 +49,8 @@ protected function __proxyCall(string $interfaceClass, string $methodName, array
 
         $protocol = Protocol::new($version, $interfaceClass, $methodName, $params, $ext);
         $data     = $packet->encode($protocol);
-        $message  = sprintf(
-            'Rpc call failed.interface=%s method=%s pool=%s version=%s',
-            $interfaceClass, $methodName, $poolName, $version
-        );
+        $message  = sprintf('Rpc call failed.interface=%s method=%s pool=%s version=%s', $interfaceClass, $methodName,
+            $poolName, $version);
 
         $result = $this->sendAndRecv($connection, $data, $message);
         $connection->release();
@@ -64,10 +62,8 @@ protected function __proxyCall(string $interfaceClass, string $methodName, array
             $errorData = $response->getError()->getData();
 
             // Record rpc error message
-            $errorMsg = sprintf(
-                'Rpc call error!code=%d message=%s data=%s pool=%s version=%s',
-                $code, $message, JsonHelper::encode($errorData), $poolName, $version
-            );
+            $errorMsg = sprintf('Rpc call error!code=%d message=%s data=%s pool=%s version=%s', $code, $message,
+                JsonHelper::encode($errorData), $poolName, $version);
 
             Error::log($errorMsg);
 

src/rpc-client/src/Connection.php

@@ -8,7 +8,6 @@
 use Swoft\Log\Debug;
 use Swoft\Rpc\Client\Client as RpcClient;
 use Swoft\Rpc\Client\Contract\ConnectionInterface;
-use Swoft\Rpc\Client\Contract\ProviderInterface;
 use Swoft\Rpc\Client\Exception\RpcClientException;
 use Swoft\Rpc\Contract\PacketInterface;
 use Swoft\Stdlib\Helper\JsonHelper;
@@ -141,7 +140,7 @@ public function recv()
     private function getHostPort(): array
     {
         $provider = $this->client->getProvider();
-        if (!$provider || !$provider instanceof ProviderInterface) {
+        if (!$provider) {
             return [$this->client->getHost(), $this->client->getPort()];
         }
 

src/rpc-client/src/Pool.php

@@ -25,9 +25,7 @@ class Pool extends AbstractPool
     public function createConnection(): ConnectionInterface
     {
         if (empty($this->client)) {
-            throw new RpcClientException(
-                sprintf('Pool(%s) client can not be null!', __CLASS__)
-            );
+            throw new RpcClientException(sprintf('Pool(%s) client can not be null!', __CLASS__));
         }
 
         return $this->client->createConnection($this);

src/rpc-client/src/Proxy.php

@@ -30,8 +30,8 @@ public static function newClassName(string $className): string
             throw new RpcClientException('`@var` for `@Reference` must be exist interface!');
         }
 
-        $proxyId   = sprintf('IGNORE_%s', Str::getUniqid());
-        $visitor   = new ProxyVisitor($proxyId);
+        $proxyId = sprintf('IGNORE_%s', Str::getUniqid());
+        $visitor = new ProxyVisitor($proxyId);
 
         return BaseProxy::newClassName($className, $visitor);
     }

src/rpc-client/src/ReferenceRegister.php

@@ -46,9 +46,7 @@ public static function getPool(string $className): string
     {
         $pool = self::$references[$className]['pool'] ?? '';
         if (empty($pool)) {
-            throw new RpcClientException(
-                sprintf('`@Reference` pool (%s) is not exist!', $className)
-            );
+            throw new RpcClientException(sprintf('`@Reference` pool (%s) is not exist!', $className));
         }
 
         return $pool;
@@ -64,11 +62,9 @@ public static function getVersion(string $className): string
     {
         $version = self::$references[$className]['version'] ?? '';
         if ($version == '') {
-            throw new RpcClientException(
-                sprintf('`@Reference` version(%s) is not exist!', $className)
-            );
+            throw new RpcClientException(sprintf('`@Reference` version(%s) is not exist!', $className));
         }
 
         return $version;
     }
-}
+}