Added Client

Author: limingxinleo

.php_cs

@@ -1,12 +1,11 @@
 <?php
 
 $header = <<<'EOF'
-This file is part of Hyperf.
+This file is part of Simps.
 
-@link     https://www.hyperf.io
-@document https://hyperf.wiki
-@contact  [email protected]
-@license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+@link     https://simps.io
+@document https://doc.simps.io
+@license  https://github.com/simple-swoole/simps/blob/master/LICENSE
 EOF;
 
 return PhpCsFixer\Config::create()
@@ -83,7 +82,9 @@ return PhpCsFixer\Config::create()
     ])
     ->setFinder(
         PhpCsFixer\Finder::create()
+            ->exclude('public')
+            ->exclude('runtime')
             ->exclude('vendor')
             ->in(__DIR__)
     )
-    ->setUsingCache(false);
+    ->setUsingCache(false);

src/Client.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Simps.
+ *
+ * @link     https://simps.io
+ * @document https://doc.simps.io
+ * @license  https://github.com/simple-swoole/simps/blob/master/LICENSE
+ */
+namespace Simps\RpcMultiplex;
+
+use Multiplex\Socket;
+use Simps\Singleton;
+
+class Client extends Socket\Client
+{
+    use Singleton;
+
+    public function __construct(string $name, int $port)
+    {
+        parent::__construct($name, $port);
+    }
+
+    public function call(string $class, string $method, ...$params): Protocol
+    {
+        $protocol = new Protocol($class, $method, $params);
+
+        return unserialize(parent::request(serialize($protocol)));
+    }
+}

src/Protocol.php

@@ -2,12 +2,11 @@
 
 declare(strict_types=1);
 /**
- * This file is part of Hyperf.
+ * This file is part of Simps.
  *
- * @link     https://www.hyperf.io
- * @document https://hyperf.wiki
- * @contact  [email protected]
- * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ * @link     https://simps.io
+ * @document https://doc.simps.io
+ * @license  https://github.com/simple-swoole/simps/blob/master/LICENSE
  */
 namespace Simps\RpcMultiplex;
 

src/TcpServer.php

@@ -2,12 +2,11 @@
 
 declare(strict_types=1);
 /**
- * This file is part of Hyperf.
+ * This file is part of Simps.
  *
- * @link     https://www.hyperf.io
- * @document https://hyperf.wiki
- * @contact  [email protected]
- * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ * @link     https://simps.io
+ * @document https://doc.simps.io
+ * @license  https://github.com/simple-swoole/simps/blob/master/LICENSE
  */
 namespace Simps\RpcMultiplex;
 
@@ -22,6 +21,8 @@
 
 class TcpServer
 {
+    public static $incr = 0;
+
     /**
      * @var Server
      */
@@ -67,7 +68,7 @@ public function __construct()
         $this->_server->on('workerStart', [$this, 'onWorkerStart']);
         $this->_server->on('receive', [$this, 'onReceive']);
 
-        foreach ($wsConfig['callbacks'] as $eventKey => $callbackItem) {
+        foreach ($wsConfig['callbacks'] ?? [] as $eventKey => $callbackItem) {
             [$class, $func] = $callbackItem;
             $this->_server->on($eventKey, [$class, $func]);
         }
@@ -112,8 +113,8 @@ public function onReceive(Server $server, int $fd, int $fromId, string $data)
                 $class = $protocol->getClass();
                 $method = $protocol->getMethod();
                 $params = $protocol->getParams();
-                $protocol->setResult((new $class())->{$method}(...$params));
-                $result = serialize($protocol);
+
+                $result = serialize($protocol->setResult((new $class())->{$method}(...$params)));
             } catch (\Throwable $exception) {
                 $result = serialize($protocol->setError($exception->getCode(), $exception->getMessage()));
             } finally {

tests/Cases/AbstractTestCase.php

@@ -2,12 +2,11 @@
 
 declare(strict_types=1);
 /**
- * This file is part of Hyperf.
+ * This file is part of Simps.
  *
- * @link     https://www.hyperf.io
- * @document https://hyperf.wiki
- * @contact  [email protected]
- * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ * @link     https://simps.io
+ * @document https://doc.simps.io
+ * @license  https://github.com/simple-swoole/simps/blob/master/LICENSE
  */
 namespace HyperfTest\Cases;
 

tests/Cases/ExampleTest.php

@@ -2,12 +2,11 @@
 
 declare(strict_types=1);
 /**
- * This file is part of Hyperf.
+ * This file is part of Simps.
  *
- * @link     https://www.hyperf.io
- * @document https://hyperf.wiki
- * @contact  [email protected]
- * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ * @link     https://simps.io
+ * @document https://doc.simps.io
+ * @license  https://github.com/simple-swoole/simps/blob/master/LICENSE
  */
 namespace HyperfTest\Cases;
 

tests/bootstrap.php

@@ -2,11 +2,10 @@
 
 declare(strict_types=1);
 /**
- * This file is part of Hyperf.
+ * This file is part of Simps.
  *
- * @link     https://www.hyperf.io
- * @document https://hyperf.wiki
- * @contact  [email protected]
- * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ * @link     https://simps.io
+ * @document https://doc.simps.io
+ * @license  https://github.com/simple-swoole/simps/blob/master/LICENSE
  */
 require_once dirname(dirname(__FILE__)) . '/vendor/autoload.php';