Format code (#5172)

Author: limingxinleo

src/CoreMiddleware.php

@@ -19,9 +19,11 @@
 use Hyperf\Rpc\Protocol;
 use Hyperf\Rpc\Response as RPCResponse;
 use Hyperf\RpcMultiplex\Contract\HttpMessageBuilderInterface;
+use InvalidArgumentException;
 use Psr\Container\ContainerInterface;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
+use Throwable;
 
 class CoreMiddleware extends \Hyperf\RpcServer\CoreMiddleware
 {
@@ -53,14 +55,14 @@ protected function handleFound(Dispatched $dispatched, ServerRequestInterface $r
 
             try {
                 $parameters = $this->parseMethodParameters($controller, $action, $request->getParsedBody());
-            } catch (\InvalidArgumentException $exception) {
+            } catch (InvalidArgumentException $exception) {
                 $data = $this->buildErrorData($request, 400, 'The params is invalid.', $exception);
                 return $this->responseBuilder->buildResponse($request, $data);
             }
 
             try {
                 $response = $controllerInstance->{$action}(...$parameters);
-            } catch (\Throwable $exception) {
+            } catch (Throwable $exception) {
                 $data = $this->buildErrorData($request, 500, $exception->getMessage(), $exception);
                 $response = $this->responseBuilder->buildResponse($request, $data);
                 $this->responseBuilder->persistToContext($response);
@@ -88,7 +90,7 @@ protected function transferToResponse($response, ServerRequestInterface $request
         return $this->responseBuilder->buildResponse($request, $response);
     }
 
-    protected function buildErrorData(ServerRequestInterface $request, int $code, string $message = null, \Throwable $throwable = null): array
+    protected function buildErrorData(ServerRequestInterface $request, int $code, string $message = null, Throwable $throwable = null): array
     {
         $id = $request->getAttribute(Constant::REQUEST_ID);
 

src/DataFormatter.php

@@ -19,6 +19,7 @@
 use Hyperf\RpcClient\Exception\RequestException;
 use Hyperf\RpcMultiplex\Contract\DataFetcherInterface;
 use Hyperf\Utils\Codec\Json;
+use Throwable;
 
 class DataFormatter implements DataFormatterInterface, DataFetcherInterface
 {
@@ -51,7 +52,7 @@ public function formatResponse(Response $response): array
     public function formatErrorResponse(ErrorResponse $response): array
     {
         $exception = $response->getException();
-        if ($exception instanceof \Throwable) {
+        if ($exception instanceof Throwable) {
             $exception = [
                 'class' => get_class($exception),
                 'code' => $exception->getCode(),

src/Exception/NoAvailableNodesException.php

@@ -11,6 +11,8 @@
  */
 namespace Hyperf\RpcMultiplex\Exception;
 
-class NoAvailableNodesException extends \RuntimeException
+use RuntimeException;
+
+class NoAvailableNodesException extends RuntimeException
 {
 }

src/Exception/NotSupportException.php

@@ -11,6 +11,8 @@
  */
 namespace Hyperf\RpcMultiplex\Exception;
 
-class NotSupportException extends \RuntimeException
+use RuntimeException;
+
+class NotSupportException extends RuntimeException
 {
 }

src/Transporter.php

@@ -18,6 +18,7 @@
 use Multiplex\Exception\ChannelClosedException;
 use Multiplex\Exception\ClientConnectFailedException;
 use Psr\Container\ContainerInterface;
+use Throwable;
 
 class Transporter implements TransporterInterface
 {
@@ -48,7 +49,7 @@ public function send(string $data)
         $result = retry($retryCount, function () use ($data) {
             try {
                 return $this->factory->get()->request($data);
-            } catch (\Throwable $exception) {
+            } catch (Throwable $exception) {
                 if ($this->shouldBeRetry($exception)) {
                     throw $exception;
                 }
@@ -80,7 +81,7 @@ public function setLoadBalancer(LoadBalancerInterface $loadBalancer): Transporte
         return $this;
     }
 
-    protected function shouldBeRetry(\Throwable $throwable): bool
+    protected function shouldBeRetry(Throwable $throwable): bool
     {
         return $throwable instanceof ClientConnectFailedException
             || $throwable instanceof ChannelClosedException;

tests/Cases/AbstractTestCase.php

@@ -13,6 +13,7 @@
 
 use Mockery;
 use PHPUnit\Framework\TestCase;
+use ReflectionClass;
 
 /**
  * Class AbstractTestCase.
@@ -26,7 +27,7 @@ protected function tearDown(): void
 
     protected function invoke($class, string $method)
     {
-        $ref = new \ReflectionClass($class);
+        $ref = new ReflectionClass($class);
         $method = $ref->getMethod($method);
         $method->setAccessible(true);
         return $method->invoke($method);

tests/Cases/SocketFactoryTest.php

@@ -20,6 +20,7 @@
 use Hyperf\RpcMultiplex\SocketFactory;
 use Hyperf\Utils\Reflection\ClassInvoker;
 use HyperfTest\RpcMultiplex\Stub\ContainerStub;
+use Mockery;
 
 /**
  * @internal
@@ -42,7 +43,7 @@ public function testSocketConfig()
             'client_count' => 4,
         ]);
 
-        $balancer = \Mockery::mock(LoadBalancerInterface::class);
+        $balancer = Mockery::mock(LoadBalancerInterface::class);
         $balancer->shouldReceive('isAutoRefresh')->andReturnFalse();
         $factory->setLoadBalancer($balancer);
         $balancer->shouldReceive('getNodes')->andReturn([
@@ -168,7 +169,7 @@ public function testSocketRefreshInMoreThanOneCoroutine()
         ]);
 
         go(function () use ($factory) {
-            $balancer = \Mockery::mock(LoadBalancerInterface::class);
+            $balancer = Mockery::mock(LoadBalancerInterface::class);
             $balancer->shouldReceive('isAutoRefresh')->andReturnFalse();
             $factory->setLoadBalancer($balancer);
             $balancer->shouldReceive('getNodes')->andReturn([