Upgrade to Hyperf 3 (#62)

Author: leocavalcante

composer.json

@@ -18,23 +18,23 @@
         }
     },
     "require": {
-        "php": ">=7.4",
-        "ext-swoole": ">=4.4",
-        "hyperf/pool": "^2.2|^3.0",
-        "hyperf/process": "^2.2|^3.0",
-        "spiral/goridge": "^2.4.1",
-        "symfony/event-dispatcher": "^5.1"
+        "php": ">=8.1",
+        "ext-swoole": ">=5.0",
+        "hyperf/pool": "^3.0",
+        "hyperf/process": "^3.0",
+        "spiral/goridge": "^2.4",
+        "symfony/event-dispatcher": "^6.3"
     },
     "require-dev": {
-        "friendsofphp/php-cs-fixer": "^3.0",
-        "hyperf/command": "^2.2|^3.0",
-        "hyperf/config": "^2.2|^3.0",
-        "hyperf/di": "^2.2|^3.0",
-        "hyperf/framework": "^2.2|^3.0",
-        "hyperf/testing": "^2.2|^3.0",
-        "mockery/mockery": "^1.3",
-        "phpstan/phpstan": "^1.0",
-        "swoole/ide-helper": "^4.5"
+        "friendsofphp/php-cs-fixer": "^3.21",
+        "hyperf/command": "^3.0",
+        "hyperf/config": "^3.0",
+        "hyperf/di": "^3.0",
+        "hyperf/framework": "^3.0",
+        "hyperf/testing": "^3.0",
+        "mockery/mockery": "^1.6",
+        "phpstan/phpstan": "^1.10",
+        "swoole/ide-helper": "^5.0"
     },
     "config": {
         "sort-packages": true

src/Config/DomainConfig.php

@@ -15,14 +15,9 @@
 
 class DomainConfig
 {
-    /**
-     * @var ConfigInterface
-     */
-    private $config;
-
-    public function __construct(ConfigInterface $config)
-    {
-        $this->config = $config;
+    public function __construct(
+        private ConfigInterface $config
+    ) {
     }
 
     public function getProcessName(): string

src/ConfigProvider.php

@@ -17,6 +17,8 @@
 use Hyperf\GoTask\Listener\PipeLockListener;
 use Hyperf\GoTask\Process\GoTaskProcess;
 
+use function Hyperf\Support\env;
+
 class ConfigProvider
 {
     public function __invoke(): array
@@ -69,7 +71,7 @@ public function __invoke(): array
         ];
     }
 
-    public static function address()
+    public static function address(): string
     {
         if (defined('BASE_PATH')) {
             $root = BASE_PATH . '/runtime';

src/GoTaskConnection.php

@@ -13,6 +13,7 @@
 
 use Hyperf\Contract\ConnectionInterface;
 use Hyperf\Contract\StdoutLoggerInterface;
+use Hyperf\GoTask\IPC\SocketIPCSender;
 use Hyperf\Pool\Connection;
 use Hyperf\Pool\Exception\ConnectionException;
 use Hyperf\Pool\Pool;
@@ -26,24 +27,15 @@
  */
 class GoTaskConnection extends Connection implements ConnectionInterface
 {
-    /**
-     * @var RPC
-     */
-    private $connection;
+    private SocketIPCSender $connection;
 
-    /**
-     * @var SocketIPCFactory
-     */
-    private $factory;
-
-    public function __construct(ContainerInterface $container, Pool $pool, SocketIPCFactory $factory)
+    public function __construct(ContainerInterface $container, Pool $pool, private SocketIPCFactory $factory)
     {
         parent::__construct($container, $pool);
-        $this->factory = $factory;
         $this->reconnect();
     }
 
-    public function __call($name, $arguments)
+    public function __call(string $name, array $arguments): mixed
     {
         try {
             $result = $this->connection->{$name}(...$arguments);
@@ -67,7 +59,7 @@ public function reconnect(): bool
         return true;
     }
 
-    public function getActiveConnection()
+    public function getActiveConnection(): self
     {
         if ($this->check()) {
             return $this;
@@ -80,7 +72,7 @@ public function getActiveConnection()
         return $this;
     }
 
-    protected function retry($name, $arguments, Throwable $exception)
+    protected function retry($name, $arguments, Throwable $exception): mixed
     {
         $logger = $this->container->get(StdoutLoggerInterface::class);
         $logger->warning(sprintf('RemoteGoTask::__call failed, because ' . $exception->getMessage()));

src/GoTaskConnectionPool.php

@@ -17,6 +17,8 @@
 use Hyperf\Pool\Pool;
 use Psr\Container\ContainerInterface;
 
+use function Hyperf\Support\make;
+
 class GoTaskConnectionPool extends Pool
 {
     public function __construct(ContainerInterface $container, DomainConfig $config)

src/GoTaskFactory.php

@@ -16,7 +16,7 @@
 
 class GoTaskFactory
 {
-    public function __invoke(ContainerInterface $container)
+    public function __invoke(ContainerInterface $container): GoTask
     {
         $config = $container->get(DomainConfig::class);
         if ($config->getAddress()) {

src/GoTaskProxy.php

@@ -13,28 +13,20 @@
 
 class GoTaskProxy implements GoTask
 {
-    /**
-     * @var GoTask
-     */
-    private $goTask;
-
-    public function __construct(GoTask $goTask)
-    {
-        $this->goTask = $goTask;
+    public function __construct(
+        private GoTask $goTask
+    ) {
     }
 
-    public function __call($name, $arguments)
+    public function __call(string $name, array $arguments): mixed
     {
         $method = ucfirst($name);
         $path = explode('\\', static::class);
         $class = array_pop($path);
         return $this->call($class . '.' . $method, ...$arguments);
     }
 
-    /**
-     * {@inheritdoc}
-     */
-    public function call(string $method, $payload, int $flags = 0)
+    public function call(string $method, mixed $payload, int $flags = 0): mixed
     {
         return $this->goTask->call($method, $payload, $flags);
     }

src/IPC/IPCSenderInterface.php

@@ -25,8 +25,6 @@ interface IPCSenderInterface
     /**
      * @param mixed $payload an binary data or array of arguments for complex types
      * @param int $flags payload control flags
-     *
-     * @return mixed
      */
-    public function call(string $method, $payload, int $flags = 0);
+    public function call(string $method, mixed $payload, int $flags = 0): mixed;
 }

src/IPC/PipeIPCSender.php

@@ -14,36 +14,33 @@
 use Hyperf\GoTask\GoTask;
 use Hyperf\GoTask\Relay\ProcessPipeRelay;
 use Spiral\Goridge\RPC;
+use Swoole\Process;
 
 /**
  * Class PipeIPC uses pipes to communicate.
  * It can only be used in one coroutine.
  */
 class PipeIPCSender implements IPCSenderInterface, GoTask
 {
-    /**
-     * @var RPC
-     */
-    private $handler;
+    private RPC $handler;
 
     /**
      * PipeIPC constructor.
      * @mixin RPC
-     * @param mixed $process
      */
-    public function __construct($process)
+    public function __construct(Process $process)
     {
         $this->handler = new RPC(
             new ProcessPipeRelay($process)
         );
     }
 
-    public function __call($name, $arguments)
+    public function __call(string $name, array $arguments): void
     {
         $this->handler->{$name}(...$arguments);
     }
 
-    public function call(string $method, $payload, int $flags = 0)
+    public function call(string $method, $payload, int $flags = 0): mixed
     {
         return $this->handler->call($method, $payload, $flags);
     }

src/IPC/SocketIPCReceiver.php

@@ -11,39 +11,28 @@
  */
 namespace Hyperf\GoTask\IPC;
 
+use Hyperf\Context\ApplicationContext;
 use Hyperf\ExceptionHandler\Formatter\FormatterInterface;
 use Hyperf\GoTask\GoTask;
 use Hyperf\GoTask\Relay\ConnectionRelay;
 use Hyperf\GoTask\Wrapper\ByteWrapper;
-use Hyperf\Utils\ApplicationContext;
 use Spiral\Goridge\Exceptions\PrefixException;
 use Spiral\Goridge\Exceptions\ServiceException;
 use Spiral\Goridge\Exceptions\TransportException;
 use Spiral\Goridge\RelayInterface as Relay;
+use Swoole\Coroutine\Server;
 use Swoole\Coroutine\Server\Connection;
 use Throwable;
 
 class SocketIPCReceiver
 {
-    /**
-     * @var string
-     */
-    private $address;
+    private string $address;
 
-    /**
-     * @var \Swoole\Coroutine\Server
-     */
-    private $server;
+    private ?Server $server = null;
 
-    /**
-     * @var int
-     */
-    private $port;
+    private int $port;
 
-    /**
-     * @var bool
-     */
-    private $quit;
+    private bool $quit;
 
     public function __construct(string $address = '127.0.0.1:6001')
     {
@@ -114,7 +103,7 @@ public function start(): bool
         return true;
     }
 
-    public function close()
+    public function close(): void
     {
         if ($this->server !== null) {
             $this->quit = true;
@@ -123,7 +112,7 @@ public function close()
         $this->server = null;
     }
 
-    protected function dispatch($method, $payload)
+    protected function dispatch(string $method, mixed $payload): mixed
     {
         [$class, $handler] = explode('::', $method);
         if (ApplicationContext::hasContainer()) {
@@ -135,20 +124,17 @@ protected function dispatch($method, $payload)
         return $instance->{$handler}($payload);
     }
 
-    protected function isStarted()
+    protected function isStarted(): bool
     {
         return $this->server !== null;
     }
 
     /**
      * Handle response body.
      *
-     * @param string $body
-     *
-     * @return mixed
      * @throws ServiceException
      */
-    protected function handleBody($body, int $flags)
+    protected function handleBody(string $body, int $flags): mixed
     {
         if ($flags & GoTask::PAYLOAD_ERROR && $flags & GoTask::PAYLOAD_RAW) {
             throw new ServiceException("error '{$body}' on '{$this->server}'");
@@ -161,7 +147,7 @@ protected function handleBody($body, int $flags)
         return json_decode($body, true);
     }
 
-    private function formatError(Throwable $error)
+    private function formatError(Throwable $error): string
     {
         $simpleFormat = $error->getMessage() . ':' . $error->getTraceAsString();
         if (! ApplicationContext::hasContainer()) {